解决粘包的基础方法

归档300

Web 开发137 编程语言93 Python 学习27 数据库26 运维与系统管理17

264 字

1 分钟

解决粘包的基础方法

2023-06-02

Python 学习

无标签

【八】解决粘包的基础处理方法#

问题的根源在于
- 接收端不知道发送端将要传送的字节流的长度，所以解决粘包的方法就是围绕
- 如何让发送端在发送数据前，把自己将要发送的字节流总大小让接收端知晓，然后接收端来一个死循环接收完所有数据
基础版本的解决方法
- 服务端

1
#_*_coding:utf-8_*_
2
__author__ = 'ly'
3
import socket,subprocess
4
ip_port=('127.0.0.1',8080)
5
s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
6
s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
7

8
s.bind(ip_port)
9
s.listen(5)
10

11
while True:
12
    conn,addr=s.accept()
13
    print('客户端',addr)
14
    while True:
15
        msg=conn.recv(1024)
16
        if not msg:break
17
        res=subprocess.Popen(msg.decode('utf-8'),shell=True,\
18
                            stdin=subprocess.PIPE,\
19
                         stderr=subprocess.PIPE,\
20
                         stdout=subprocess.PIPE)
21
        err=res.stderr.read()
22
        if err:
23
            ret=err
24
        else:
25
            ret=res.stdout.read()
26
        data_length=len(ret)
27
        conn.send(str(data_length).encode('utf-8'))
28
        data=conn.recv(1024).decode('utf-8')
29
        if data == 'recv_ready':
30
            conn.sendall(ret)
31
    conn.close()

客户端

1
#_*_coding:utf-8_*_
2
__author__ = 'ly'
3
import socket,time
4
s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
5
res=s.connect_ex(('127.0.0.1',8080))
6

7
while True:
8
    msg=input('>>: ').strip()
9
    if len(msg) == 0:continue
10
    if msg == 'quit':break
11

12
    s.send(msg.encode('utf-8'))
13
    length=int(s.recv(1024).decode('utf-8'))
14
    s.send('recv_ready'.encode('utf-8'))
15
    send_size=0
16
    recv_size=0
17
    data=b''
18
    while recv_size < length:
19
        data+=s.recv(1024)
20
        recv_size+=len(data)
21

22

23
    print(data.decode('utf-8'))