什么是粘包现象以及socket收发消息原理

只有tcp才会出现粘包问题
解决粘包问题的核心思想:每次都会读完收到的内容

自定义报头:

固定报头长度,报头内容为数据长度

:
该模块可以把一个类型，如数字，转成固定长度的bytes,这样就可以把数据长度转换成固定长度的bytes
用法:struct.pack('i',1111111111111)

但是之前我们了解过报头的内容并不止这一个,所以,我们可以用字典的形式作为报头,字典内容比如是文件名,md5值,数据长度,然后用json来序列化这个字典给他发送出去

这样又会产生一个新的问题,,,,接收方因为无法确定字典的长度而又会粘包

所以就是:
首先通过struct发送转换成bytes的字典的长度,,然后发送报头字典,最后发送数据

练习

让我们基于tcp先制作一个远程执行命令的程序（1：执行错误命令 2：执行dir 3：执行tasklist(查看进程列表))
res.stdout.read()读出的就是GBK编码的，在接收端需要用

服务端

from socket import *
import json, struct, subprocess



server = socket()
server.bind(('127.0.0.1', 8080))

server.listen(5)
while True:
    conn, addr = server.accept()

    while True:
        try:
            cmd = conn.recv(1024)
            res = subprocess.Popen(cmd.decode('utf-8'), shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
            stdout = res.stdout.read()
            stderr = res.stderr.read()

            # 这是报头字典
            hand_dic={
                'file_name':'a.txt',
                'md5':'4f56ds4f65ds4f',
                'data_size':len(stdout)+len(stderr)
            }

            #字典序列化后转化为二进制
            hand_json = json.dumps(hand_dic)
            hand_bytes = hand_json.encode('utf-8')

            #发报头字典长度
            hand_size=struct.pack('i',len(hand_bytes))
            conn.send(hand_size)

            #发报头字典
            conn.send(hand_bytes)

            #发数据
            conn.send(stdout + stderr)
        except ConnectionResetError:
            break
        except ConnectionAbortedError:
            break
    conn.close()
server.close()

客户端

from socket import *
import json, struct


client=socket()
client.connect(('127.0.0.1',8080))

while True:
    cmd=input('::>').strip()
    client.send(cmd.encode('utf-8'))

    #接收报头字典长度
    hand_size=struct.unpack('i',client.recv(4))[0]

    #接收报头
    hand_bytes=client.recv(hand_size)#收到bytes格式的json
    hand_json=hand_bytes.decode('utf-8')#还原成json格式
    hand=json.loads(hand_json)#反序列化

    #数据长度
    total_size=hand['data_size']

    # 循环取值
    data_size=0#已经接收的长度
    res=b''#用来存放每次取出的数据
    while data_size<total_size:
        data=client.recv(1024) #每次取1024字节
        res+=data       #取完后存于res
        data_size+=len(data)#更新已经取出的长度
    print(res.decode('gbk'))#打印取出的数据,注意!!!Windows默认gbk编码的,所以这里要用gbk解码


client.close()