讨论一下 Python socket 该怎么正确的读所谓的"粘包", 主要是 Python 语言的细节

感谢各位，最后代码如下。

# server.py

import socket
import struct

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind(('localhost', 20080))
s.listen(5)


def handle(sock):
    header_bytes = sock.recv(4, socket.MSG_WAITALL)   # 这里强制阻塞读取全部4字节
    if len(header_bytes) != 4:
        print("header bytes not valid")
        sock.close()
        return
    print('header bytes %s' % header_bytes)
    length = struct.unpack('>i', header_bytes)[0]
    print('unpack body length %d' % length)
    res = []
    while length:
        read_length = min((length, 4096))
        data = sock.recv(read_length)
        print('   --> now read', len(data), data)
        if not data:
            print("body size < header claimed")
            sock.close()
            return
        res.append(data)
        length -= len(data)

    print("Got data %s" % b''.join(res))
    sock.sendall(b'Got it %d' % len(b''.join(res)))
    sock.close()
    print("close")

while 1:
    c, addr = s.accept()
    print("Accept from (%s,%s)" % addr)
    handle(c)


# client.py

#coding: utf-8

import socket
import time
import struct
import random

s = socket.socket()
s.connect(('localhost', 20080))
kk = [1, 4, 6, 8, 16, 32, 64, 128, 256, 512, 1024, 2048, 4096, 19201, 4097, 4095, 3302, 1234]
n = sum(kk)
data = b'i' * n
byte = struct.pack('>i', n)
print('will total sent', n)
for i in range(4):
    s.sendall(byte[i:i+1])
    # 4字节分批模拟交通阻塞
    time.sleep(random.random())

send = 0
for v in kk:
    s.sendall(data[send:send+v])
    send += v
    print('send', send, '+', v)
    time.sleep(random.random())
s.shutdown(1)
print("Got", s.recv(1024))