解决粘包问题的终极大招

2021-08-10 16:03:35 阅读：189 来源： 互联网

标签：res 大招粘包 dic header str 终极 recv size

服务端

import socket
import struct
import subprocess
import json

server = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
server.bind(('127.0.0.1',8080))
server.listen(5)

while True:
    conn,client_addr = server.accept()
    print('客户端的ip和端口是：',client_addr)

    while True:
        try:
            data = conn.recv(1024)
            if len(data) == 0:break
            print('客户端发来的消息是：',data.decode('utf-8'))

            res = subprocess.Popen(
                data.decode('utf-8'),
                shell=True,
                stdout=subprocess.PIPE,
                stderr=subprocess.PIPE
            )
            stdout_res = res.stdout.read()
            stderr_res = res.stderr.read()
            res_size = len(stdout_res) + len(stderr_res)
            print('服务端返回消息的长度为：',res_size)

            header_dic = {
                'filename':'aa.txt',
                'filesize':res_size,
                'md5':'fadsj54335k5432k5lh5jk23j4jk'
            }

            header_dic_str = json.dumps(header_dic)
            header_dic_str_bytes = header_dic_str.encode('utf-8')
            header_dic_str_bytes_struct = struct.pack('i',len(header_dic_str_bytes))

            conn.send(header_dic_str_bytes_struct)
            conn.send(header_dic_str_bytes)
            conn.send(stdout_res)
            conn.send(stderr_res)

        except Exception:
            break
    conn.close()
server.close()

客户端

import socket
import struct
import json

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

while True:
    msg = input('cmd:').strip()
    if len(msg) == 0:continue
    client.send(msg.encode('utf-8'))

    header_dic_str_bytes_struct = client.recv(4)
    header_dic_str_bytes_size = struct.unpack('i',header_dic_str_bytes_struct)[0]
    header_dic_str_bytes = client.recv(header_dic_str_bytes_size)
    header_dic_str = header_dic_str_bytes.decode('utf-8')
    header_dic = json.loads(header_dic_str)
    print(header_dic)
    total_size = header_dic['filesize']
    recv_size = 0
    while recv_size < total_size:
        recv_data = client.recv(1024)
        recv_size += len(recv_data)
        print('服务端发来的消息是：',recv_data.decode('gbk'))
    else:
        print('客户端收到的消息长度是:',recv_size)
client.close()

标签：res,大招,粘包,dic,header,str,终极,recv,size
来源： https://www.cnblogs.com/MRPython/p/15124224.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

解决粘包问题的终极大招