TCP套接字服务端
- 创建一个TCP流式套接字
# 导入 socket 标准库
import socket
# 功能：
# 创建一个套接字
# 参数：
# socket_family : 选择地址族类型 AF_INET(IPv4) / AF_INET6(IPv6)
# socket_type : 套接字类型 SOCK_STREAM(流式) /SOCK_DGRAM(数据报)
# proto : 选择子协议类型 通常为0
# 返回值：
# 返回套接字对象
sockfd = socket.socket(socket_family = AF_INET,socket_type = SOCK_STREAM,proto = 0)
- 绑定服务端地址(本机的IP和端口号)
# 功能：绑定IP地址
# 参数：一个包含两个元素的元组,元组第一个元素是主机名,第二个是使用的端口号
sockfd.bind(addr)
# IP地址的组合：
# localhost / 127.0.0.1 可以被本机用
# 192.168.205.120 可以被所有人用192.168.205.120访问
# 0.0.0.0 可以被所有人用192.168.205.120访问,也可被自己用127.0.0.1访问
- 设置监听套接字
# 功能：将套接字设置为监听套接字，创建监听队列
# 参数：n 表示监听队列大小
# 一个监听套接字可以连接多个客户端套接字
sockfd.listen(n)
- 等待处理客户端连接请求
# 功能：阻塞等待处理客户端连接
# 参数：无
# 返回值：
# connfd 客户端交互的新的套接字
# addr 连接进来的客户端地址
# 阻塞函数：程序运行过程中遇到阻塞函数则暂停运行，直到某种阻塞条件达成再继续运行
connfd，addr = sockfd.accept()
- 消息收发
# 功能：接收对应客户端消息,如果没有消息则会阻塞
# 参数：一次最多接收多少字节
# 返回值：接收到的内容
data = connfd.recv(buffersize)
# 功能：发送消息给对应客户端
# 参数：要发送的内容，必须是bytes格式
# 返回值：返回实际发送消息的大小
n = connfd.send(data)
- 关闭套接字
# 功能：关闭套接字
connfd.close()
sockfd.close()
TCP套接字客户端
- 创建套接字
import socket
# 必须相同类型的套接字才能通信
sockfd = socket.socket(socket_family = AF_INET,socket_type = SOCK_STREAM,proto = 0)
- 建立连接
# 功能：建立连接
# 参数：元组,服务端地址
sockfd.connect(servr_addr)
- 消息发收
# 消息收发要和服务端配合,避免两边都出现recv阻塞
# `recv`和`send`要与服务器配合,避免`recv`死阻塞
sockfd.send(data)
data = sockfd.recv(buffersize)
- 关闭套接字
sockfd.close()
套接字传输注意事项
- 监听套接字存在客户端即可发起连接,但是最终连接的处理需要
accept进行处理 - 如果连接的另外一段退出,则
recv会立即返回空子串不再阻塞 - 当连接的另一端退出时,再试图
send发送就会产生BrokenPipeError
网络收发缓冲区
- 协调收发(处理)速度
- 减少交互次数
-
send和recv实际上是和缓冲区进行交互,发送缓冲区满时就无法发送,接收缓冲区满时recv才阻塞
TCP粘包
- tcp套接字以字节流方式传输，没有消息边界
- 发送和接收并不能保证每次发送都及时的被接收
粘包的影响
如果每次发送内容表达一个独立的含义此时可能需要处理粘包防止产生歧义
粘包处理方法
- 每次发送的消息添加结尾标志(人为增加消息边界)
- 发送数据结构体
- 协调收发速度，每次发送后都预留接收时间
