本文共 3637 字，大约阅读时间需要 12 分钟。

粘包问题及其解决方案

粘包问题（Glue Problem）在网络通信中是一个常见的现象，尤其是在使用TCP协议进行通信时。粘包问题的核心在于接收端接收到的数据并非完整的消息片段，而是部分或全部消息的数据片段与前后消息的数据混合在一起。这一问题的出现主要源于TCP协议的面向流特性，使得消息的边界信息不明确。

粘包问题的原因

粘包问题的解决方法

优化方法示例

普通青年版：

• 服务器端：

  import socket, subprocess
  ip_port = ('127.0.0.1', 8080)
  s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
  s.bind(ip_port)
  s.listen(5)
  while True:
      conn, addr = s.accept()
      print('客户端', addr)
      while True:
          cmd = conn.recv(1024)
          if not cmd:
              break
          res = subprocess.Popen(cmd.decode('utf-8'), shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
          stderr = res.stderr.read()
          stdout = res.stdout.read()
          data_length = len(stdout)
          conn.send(str(data_length).encode('utf-8'))
          data = conn.recv(1024).decode('utf-8')
          if data == 'recv_ready':
              conn.sendall(stdout)
      conn.close()

• 客户端：

  import socket
  ip_port = ('127.0.0.1', 8080)
  s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  res = s.connect_ex(ip_port)
  while True:
      msg = input('> : ').strip()
      if len(msg) == 0:
          continue
      if msg == 'quit':
          break
      s.send(msg.encode('utf-8'))
      length = int(s.recv(1024).decode('utf-8'))
      s.send('recv_ready'.encode('utf-8'))
      send_size = 0
      recv_size = 0
      data = b''
      while recv_size < length:
          data += s.recv(1024)
          recv_size = len(data)
      print(data.decode('utf-8'), end='')

文艺青年版二：

• 服务器端：

  import socket, struct, json
  ip_port = ('127.0.0.1', 8080)
  phone = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  phone.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
  phone.bind(ip_port)
  phone.listen(5)
  while True:
      conn, addr = phone.accept()
      while True:
          cmd = conn.recv(1024)
          if not cmd:
              break
          res = subprocess.Popen(cmd.decode('utf-8'), shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
          err = res.stderr.read()
          stdout = res.stdout.read()
          back_msg = err if err else stdout
          headers = {'data_size': len(back_msg)}
          head_json = json.dumps(headers)
          head_json_bytes = bytes(head_json, encoding='utf-8')
          phone.send(struct.pack('i', len(head_json_bytes)))
          phone.send(head_json_bytes)
          phone.sendall(back_msg)
      conn.close()

• 客户端：

  from socket import *
  import struct, json
  ip_port = ('127.0.0.1', 8080)
  client = socket(AF_INET, SOCK_STREAM)
  client.connect(ip_port)
  while True:
      cmd = input('> : ').strip()
      if not cmd:
          continue
      if cmd == 'quit':
          break
      client.send(bytes(cmd, encoding='utf-8'))
      head = client.recv(4)
      head_json_len = struct.unpack('i', head)[0]
      head_json = json.loads(client.recv(head_json_len).decode('utf-8'))
      data_len = head_json['data_size']
      recv_size = 0
      recv_data = b''
      while recv_size < data_len:
          recv_data += client.recv(1024)
          recv_size = len(recv_data)
      print(recv_data.decode('utf-8'), end='')

总结

粘包问题源于TCP协议的面向流特性，解决方法包括明确消息边界、使用自定义报头、优化数据传输策略等。选择具体方法需根据应用场景和性能需求综合考量。