TCP协议的黏包问题与解决方法：

黏包：接收到的数据包乱了，有部分本次请求的数据临时存入了缓冲区，导致下次请求时一起显示

TCP协议会黏包，但是不会丢包

UDP协议不会黏包，但可能丢包

TCP黏包原因：1.多个send连在一起发送，且数据量小  2.多个recv接收，第一个数据量小   

本质上是TCP算法进行了内部优化 一个单位时间内，连续发送较小数据包会默认合并发送，降低多次发送的延时

为什么会黏包：

因为tcp是面向流的协议，在数据发送传输中有缓存机制来避免数据丢失，连续发送接收小数据时会黏包，根本是不知道接收数据的大小

****************************************************************************************

服务器端：

import socket
sk=socket.socket()
sk.bind(('127.0.0.1',8080))
sk.listen()

conn,addr=sk.accept()
while True:
    cmd=input('请输入...')
    if cmd=='q':
        conn.send(b'q')
        break
    conn.send(cmd.encode('gbk'))
    long=conn.recv(1024).decode('utf-8')
    conn.send(b'ok')  #服务器确认收到

    res=conn.recv(int(long)).decode('gbk')
    print(res)
conn.close()
sk.close()

客户端：

import socket
import subprocess
sk=socket.socket()

sk.connect(('127.0.0.1',8080))
while True:
    cmd=sk.recv(1024).decode('gbk')
    if cmd=='q':
        sk.send(b'q')
        break
    res=subprocess.Popen(cmd,shell=True,stdout=subprocess.PIPE,stderr=subprocess.PIPE)
    stdout=res.stdout.read()
    stderr=res.stderr.read()
    sk.send(str(len(stdout)+len(stderr)).encode('utf-8')) #告诉服务器要接收数据的长度
    sk.recv(1024)
    sk.send(stdout)
    sk.send(stderr)
sk.close()

 但是上述代码额外增加了一次send和recv 数据阻塞的时间延长了

>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>

用struct模块可以省去这次不必要的数据发送

struct可以将各种数据类型转为byte类型  struct.pack（‘i’,num）  i模式代表int类型 转为byte 通常为4个字节

struct.pack（‘i’,num）包装    struct.unpack（‘i’,num）[0]  还原 为元组形式取第一个元素就是值

server：

import struct
import socket
sk=socket.socket()
sk.bind(('127.0.0.1',8080))
sk.listen()

conn,addr=sk.accept()
while True:
    cmd=input('请输入...')
    if cmd=='q':
        conn.send(b'q')
        break
    conn.send(cmd.encode('gbk'))
    long=conn.recv(4)
    long=struct.unpack('i',long)[0]     #取元组的第一个元素

    res=conn.recv(long).decode('gbk')
    print(res)
conn.close()
sk.close()

client：

import struct
import socket
import subprocess
sk=socket.socket()

sk.connect(('127.0.0.1',8080))
while True:
    cmd=sk.recv(1024).decode('gbk')
    if cmd=='q':
        sk.send(b'q')
        break
    res=subprocess.Popen(cmd,shell=True,stdout=subprocess.PIPE,stderr=subprocess.PIPE)
    stdout=res.stdout.read()
    stderr=res.stderr.read()
    long=len(stdout)+len(stderr)
    long=struct.pack('i',long)
    sk.send(long) #告诉服务器要接收数据的长度 数字为4字节
    
    sk.send(stdout)
    sk.send(stderr)
sk.close()