python入行037(粘包问题)

Posted mmmmmrz

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了python入行037(粘包问题)相关的知识,希望对你有一定的参考价值。

1 粘包问题

  粘包问题是针对TCP协议的,UDP协议不会遇到这个问题。TCP是流式协议遇到的粘包问题主要还是因为接收方不知道消息之间的界限,不知道一次性提取多少字节的数据所造成的。

 2 解决粘包问题的代码模板

# 服务端
import subprocess
import struct
import json
from socket import *

server = socket(AF_INET, SOCK_STREAM)
server.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)  # 就是它,在bind前加
server.bind((127.0.0.1, 8083))
server.listen(5)

#  服务端应该做两件事
# 第一件事:循环地从板连接池中取出链接请求与其建立双向链接,拿到链接对象
while True:
    conn, client_address = server.accept()

    # 第二件事:拿到链接对象,与其进行通信循环
    while True:
        try:
            cmd = conn.recv(1024)
            if len(cmd) == 0: break
            obj = subprocess.Popen(cmd.decode(utf-8),
                                   shell=True,
                                   stdout=subprocess.PIPE,
                                   stderr=subprocess.PIPE
                                   )

            stdout_res = obj.stdout.read()
            stderr_res = obj.stderr.read()
            total_size = len(stdout_res) + len(stderr_res)

            # 1、制作头
            header_dic = {
                "filename": "a.txt",
                "total_size": total_size,
                "md5": "123123xi12ix12"
            }

            json_str = json.dumps(header_dic)
            json_str_bytes = json_str.encode(utf-8)

            # 2、先把头的长度发过去
            x = struct.pack(i, len(json_str_bytes))
            conn.send(x)

            # 3、发头信息
            conn.send(json_str_bytes)
            # 4、再发真实的数据
            conn.send(stdout_res)
            conn.send(stderr_res)

        except Exception:
            break
    conn.close()
# 客户端
import struct
import json
from socket import *

client=socket(AF_INET,SOCK_STREAM)
client.connect((127.0.0.1,8083))

while True:
    cmd=input(请输入命令>>:).strip()
    if len(cmd) == 0:continue
    client.send(cmd.encode(utf-8))

    # 接收端
    # 1、先手4个字节,从中提取接下来要收的头的长度
    x=client.recv(4)
    header_len=struct.unpack(i,x)[0]

    # 2、接收头,并解析
    json_str_bytes=client.recv(header_len)
    json_str=json_str_bytes.decode(utf-8)
    header_dic=json.loads(json_str)
    print(header_dic)
    total_size=header_dic["total_size"]

    # 3、接收真实的数据
    recv_size = 0
    while recv_size < total_size:
        recv_data=client.recv(1024)
        recv_size+=len(recv_data)
        print(recv_data.decode(utf-8),end=‘‘)
    else:
        print()

 

以上是关于python入行037(粘包问题)的主要内容,如果未能解决你的问题,请参考以下文章

Python入门100题 | 第037题

leetcode python 037 求解数独

Python基础 - 第八天 - Socket编程进阶

python 网络编程-03 粘包问题及处理

Python Day30 粘包

python-day30--粘包