Python Tcp编程

网络连接与通信是我们学习任何编程语言都绕不过的知识点。Python 也不例外,本文就介绍因特网的核心协议 TCP ,以及如何用 Python 实现 TCP 的连接与通信。

TCP 协议

TCP协议(Transmission Control Protocol, 传输控制协议)是一种面向连接的传输层通信协议,它能提供高可靠性通信,像 HTTP/HTTPS 等网络服务都采用 TCP 协议通讯。那么网络通讯方面都会涉及到 socket 编程,当然也包括 TCP 协议。

Network Socket

我们来看看定义:

Network Socket(网络套接字)是计算机网络中进程间通信的数据流端点,广义上也代表操作系统提供的一种进程间通信机制。

这些计算机术语都很学术,难于理解,每个字都认识,加在一起就不认识了。我们可以通俗地理解成发快递:A 需要给 B 寄快递,首先需要知道 B 的地址和手机号码,那么这个地址就相当于 网络中的主机 IP 地址,而手机就相当于 主机的端口号。然后 A 还需要指定哪家快递公司,是顺丰还是中通?这个快递公司就相当于通信的传输协议。

TCP 连接流程

上述快递的例子中,寄快递的我们可以叫做客户端,收快递的我们叫做服务器。专业点就是主动发起连接的一方叫做客户端,被动响应的一方叫做服务器。例如,我们在浏览器中访问百度搜索时,我们自己的电脑就是客户端,浏览器会向百度的服务器发送连接请求,如果百度的服务器接受了我们的请求,那么一个 TCP 连接就建立起来了,后面就是百度向我们传输搜索结果了。

我们来看一个流程图:

图片

TCP服务器的建立可以归纳这几步:

  • 创建 socket(套接字)

  • 绑定 socket 的 IP 地址和端口号

  • 监听客户端的连接请求

  • 接受客户端的连接请求

  • 与客户端对话

  • 关闭连接

TCP客户端的创建可总结为这几步:

  • 创建 socket(套接字)

  • 连接服务器 socket

  • 与服务器对话

  • 关闭连接

这里需要注意的是 TCP 客户端连接到服务器的 IP 和端口号必须是 TCP 服务器的 IP 和监听的端口号,服务器调用 listen() 开始监听端口,然后调用 accept() 时刻准备接受客户端的连接请求,此时服务器处于阻塞状态,直到服务器监听到客户端的请求后,接收请求并建立连接为止。

TCP 客户端

创建 socket 连接,可以这样做:

# 导入socket库import socket# 创建一个sockets = socket.socket(socket.AF_INET, socket.SOCK_STREAM)# 建立连接s.connect(("127.0.0.1", 6000))

创建 socket 时,第一个参数 socket.AF_INET 表示指定使用 IPv4 协议,如果要使用 IPv6 协议,就指定为 socket.AF_INET6。SOCK_STREAM 指定使用面向流的 TCP 协议。然后我们调用 connect() 方法,传入 IP 地址(或者域名),指定端口号就可以建立连接了。

接下来我们就可以向服务器发送数据了:

s.send(b'Hello, Mr Right!')

接收数据时,调用 recv(max) 方法,一次最多接收指定的字节数,因此,在一个 while 循环中反复接收,直到 recv() 返回空数据,表示接收完毕,退出循环。​​​​​​​

# 接收数据buffer = []while True:    # 每次最多接收1k字节    d = s.recv(1024)    if d:        buffer.append(d)    else:        breakdata = b''.join(buffer)

最后,我们需要关闭连接,很简单:

s.close()

TCP 服务器

相比于客户端,服务器端稍微复杂一些,需要先绑定一个 IP 地址和端口号,然后监听客户端的请求,收到请求后丢到一个线程去处理。

创建 socket 跟客户端方法一样:

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

接下来需要绑定监听地址和端口:

s.bind(('127.0.0.1', 6000))

然后就可以开始监听端口了,监听时需要传入一个参数,指定等待连接的最大数量:

s.listen(5)

接下来就是无限循环等待客户端的连接,直到有连接请求过来,就用一个线程去处理:​​​​​​​

while True:    # 接受一个新连接    sock, addr = s.accept()    # 创建新线程来处理TCP连接    t = threading.Thread(target=tcplink, args=(sock, addr))    t.start()

这里为什么需要多线程处理呢?想象一下菜鸟驿站,如果里面只有一个人的话,那么多个人寄件就需要排队,一个个来;但是如果有多个人的话,那么每个人都可以处理一个寄件请求。

我们来看一下处理客户端请求的方法:​​​​​​​

# 处理tcp连接def tcplink(conn, addr):    print("Accept new connection from %s:%s" % addr)    # 向客户端发送欢迎消息    conn.send(b"Server: Welcome!\n")    while True:        conn.send(b"Server: What's your name?")        data = conn.recv(1024)        # 如果客户端发送 exit 过来请求退出,结束循环        if data == b"exit":            conn.send(b"Server: Good bye!\n")            break        conn.send(b"Server: Hello %s!\n" % data)    # 关闭连接    conn.close()    print("Connection from %s:%s is closed" % addr)

例子中,我们先想客户端发送欢迎消息,然后询问客户端名称,收到名称后发送欢迎消息,直到接收到客户端的 'exit' 命令,退出循环,关闭连接。

实例

我们把上面的分步讲解代码合并起来,形成一个可运行的实例。

服务器端代码:​​​​​​​

import socketimport threadingimport time# 处理tcp连接def tcplink(conn, addr):    print("Accept new connection from %s:%s" % addr)    # 向客户端发送欢迎消息    conn.send(b"Server: Welcome!\n")    while True:        conn.send(b"Server: What's your name?")        data = conn.recv(1024)        # 如果客户端发送 exit 过来请求退出,结束循环        if data == b"exit":            conn.send(b"Server: Good bye!\n")            break        conn.send(b"Server: Hello %s!\n" % data)    time.sleep(5)    # 关闭连接    conn.close()    print("Connection from %s:%s is closed" % addr)# 创建 sockets = socket.socket(socket.AF_INET, socket.SOCK_STREAM)# 监听端口s.bind(("127.0.0.1", 6000))# 设定等待连接的最大数量为5s.listen(5)print("Waiting for connection...")# 等待接收连接while True:    # 接受一个新连接    conn, addr = s.accept()    # 创建新线程来处理TCP连接    t = threading.Thread(target=tcplink, args=(conn, addr))    t.start()

客户端代码:​​​​​​​

import socketimport time# 创建 sockets = socket.socket(socket.AF_INET, socket.SOCK_STREAM)# 建立连接s.connect(("127.0.0.1", 6000))# 接收服务器消息print(s.recv(1024).decode())for data in [b'Michael', b'Tracy', b'Sarah']:    # 发送数据    s.send(data)    time.sleep(2)    # 打印接收到的数据    print(s.recv(1024).decode('utf-8'))    time.sleep(1)time.sleep(3)# 请求退出s.send(b'exit')time.sleep(2)print(s.recv(1024).decode('utf-8'))# 关闭连接s.close()

注意,在代码中,我加入了一些休眠(sleep)操作,主要是为了控制台能够顺利打印出来,不然程序运行太快,打印顺序和内容有可能和预期不一样。

先运行服务器端代码,然后再运行客户端代码,我们可以看到服务器端控制台打印内容如下:# 服务器端打印消息

Waiting for connection...Accept new connection from 127.0.0.1:53503Connection from 127.0.0.1:53503 is closed

客户端控制台打印内容如下:​​​​​​​

# 客户端打印消息Server: Welcome!Server: What's your name?Server: Hello Michael!Server: What's your name?Server: Hello Tracy!Server: What's your name?Server: Hello Sarah!Server: What's your name?Server: Good bye!

大家可以对照着打印内容和代码,体会一下服务器端和客户端通信的原理。

总结

本文为大家介绍了 TCP 编程的基本原理和如何使用 Python 实现一个最简单的 TCP 通信过程。通过介绍和实例,大家要在脑海中形成一个 TCP 通信的过程,熟悉了这个过程是处理后续复杂通信需求的基础。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/65902.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Flutter关于StatefulWidget中State刷新时机的一点实用理解

刚入门flutter开发,使用StatefulWidget踩了很多坑,就我遇到典型问题谈谈见解。 1.initState方法只会在控件初始化的时候执行一遍。 2.控件内部执行setState方法,则会每次执行build方法。 3.控件销毁会执行dispose方法,所以一些…

2023年6月电子学会Python等级考试试卷(三级)答案解析

青少年软件编程(Python)等级考试试卷(三级) 一、单选题(共25题,共50分) 1. 请选择,下面代码运行之后的结果是?( ) a = 2 b = 4 try: c = a * b print(c) except: print(程序出错!) else: print(程序正确!) A.

大模型的能力边界在哪里?

随着人工智能领域的不断发展,大型神经网络模型已经成为了研究和应用中的主要工具之一。这些大模型,尤其是像GPT-3这样的巨型语言模型,展示了令人印象深刻的自然语言处理能力,甚至能够生成高质量的文本、回答问题、模仿不同的写作风…

从入门到精通,30天带你学会C++【第六天:与或非三兄弟和If判断语句(博主目前最长文章,2514字)】(学不会你找我)

目录 前言 计算机里的真和假 与或非三兄弟 与运算(&&) 具体说明表格: 举个栗子1: 或运算(||) 具体说明表格: 举个栗子2: 非运算(!) 具体…

Linux之超强16进制命令:xxd(三十)

简介: CSDN博客专家,专注Android/Linux系统,分享多mic语音方案、音视频、编解码等技术,与大家一起成长! 优质专栏:Audio工程师进阶系列【原创干货持续更新中……】🚀 人生格言: 人生…

Win 教程 Win7实现隔空投送

一直觉得自己写的不是技术,而是情怀,一个个的教程是自己这一路走来的痕迹。靠专业技能的成功是最具可复制性的,希望我的这条路能让你们少走弯路,希望我能帮你们抹去知识的蒙尘,希望我能帮你们理清知识的脉络&#xff0…

独家首发!openEuler 主线集成 LuaJIT RISC-V JIT 技术

RISC-V SIG 预期随主线发布的 openEuler 23.09 创新版本会集成 LuaJIT RISC-V 支持。本次发版将提供带有完整 LuaJIT 支持的 RISC-V 环境并带有相关软件如 openResty 等软件的支持。 随着 RISC-V SIG 主线推动工作的进展,LuaJIT 和相关软件在 RISC-V 架构下的支持也…

Python|小游戏之猫捉老鼠!!!

最近闲(mang)来(dao)无(fei)事(qi),喜欢研究一些小游戏,本篇文章我主要介绍使用 turtle 写的一个很简单的猫捉老鼠的小游戏,主要是通过鼠标控制老鼠(Tom)的移动,躲避通过电脑控制的猫(Jerry)的追捕。 游戏主体思考逻辑&#xff1…

嵌入式开发-SPI通信介绍

SPI(Serial Peripheral Interface)是一种串行外设接口规范,它是由摩托罗拉公司制定的一种通讯协议。它广泛应用于微控制器、存储器和其他外设之间的通信。 SPI是一种同步串行通信协议,它支持四线通信: SCK&#xff0…

Aspose导出word使用记录

背景:Aspose系列的控件,功能实现都比较强大,可以实现多样化的报表设计及输出。 通过这次业务机会,锂宝碳审核中业务功需要实现Word文档表格的动态导出功能,因此学习了相关内容,在学习和参考了官方API文档的…

C#知识点、常见面试题

相关源码 https://github.com/JackYan666/CSharpCode/blob/main/CSharpCode.cs 0.简要概括 1.删除集合元素 1.For循环删除集合元素:从后面往前删除 从前往后删,有可能不能完全删除 #region 01.For循环删除集合元素void Test01_ForDelListElement(){//错误代码 虽然可以跑…

监督学习的介绍

一、定义 监督学习是利用一组已知类别的样本调整分类器的参数,使其达到所要求性能的过程,也称为监督训练或有教师学习。它是一种机器学习的方法,目的是让模型能够从已知的输入和输出之间的关系中学习,并且能够对新的输入做出正确…

Golang并发编程

Golang并发编程 进程和线程及协程并行和并发golang 创建一个协程golang停止一个协程golang协程休眠Golang协程状态golang协程安全golang共享变量和临界区golang协程优先级golang协程安全数据类型golang如何解决协程安全问题golang通道golang通道缓冲golang通道同步golang通道方…

nginx部署web网站

安装教程:https://blog.csdn.net/qq_42716761/article/details/126970218 一、查看 nginx 运行状态状态 ps -ef | grep nginx 二、查看配置文件 nginx.conf 路径 nginx -t 三、nginx启动(linux命令) nginx 查询 nginx 是否启动 ps -ef |…

iSCSI存储服务器

目录 一、ISCSI是什么? 二、ISCSI产生背景 三、存储分类 四、ISCSI架构 五、ISCSI存储服务搭建案例 一、ISCSI是什么? ISCSI名为互联网小型计算机系统接口又称为IP-SAN,是一种新的远程存储技术,提供存储服务的目标服务器默认使用的…

Go和Java实现备忘录模式

Go和Java实现备忘录模式 下面通过一个保存游戏进度的案例来说明备忘录模式的使用。 1、备忘录模式 备忘录模式保存一个对象的某个状态,以便在适当的时候恢复对象。备忘录模式属于行为型模式。 意图:在不破坏封装性的前提下,捕获一个对象的…

【C++】学习STL中的stack和queue

❤️前言 今天这篇博客的内容主要关于STL中的stack、queue和priority_queue三种容器。 正文 stack和queue的使用方式非常简单,我们只要根据之前学习数据结构的经验和文档介绍就可以轻松上手。于是我们直接开始对它们的模拟实现。 stack和queue的模拟实现 stack和q…

大数据HBase学习圣经:一本书实现HBase学习自由

学习目标:三栖合一架构师 本文是《大数据HBase学习圣经》 V1版本,是 《尼恩 大数据 面试宝典》姊妹篇。 这里特别说明一下:《尼恩 大数据 面试宝典》5个专题 PDF 自首次发布以来, 已经汇集了 好几百题,大量的大厂面试…

Leetcode98. 验证二叉搜索树

力扣(LeetCode)官网 - 全球极客挚爱的技术成长平台 给你一个二叉树的根节点 root ,判断其是否是一个有效的二叉搜索树。 有效 二叉搜索树定义如下: 节点的左子树只包含 小于 当前节点的数。节点的右子树只包含 大于 当前节点的数。…

实际并行workers数量不等于postgresql.conf中设置的max_parallel_workers_per_gather数量

1 前言 本文件的源码来自PostgreSQL 14.5,其它版本略有不同并行workers并不能显箸提升性能。个人不建议使用并行worker进程,大多数情况下采用postgresql.conf默认配置即可。 PostgreSQL的并行workers是由compute_parallel_worker函数决定的&#xff0c…