Python多线程Socket服务器无法接收矩阵计算客户端返回数据问题

核心问题定位 #

出现“放开服务端结果接收逻辑后，客户端收不到任务分片、也回传不了计算结果”的现象，本质是三处代码逻辑错误叠加触发的连锁反应，不存在底层网络层面的连通性问题。

具体错误拆解 #

• 最核心的逻辑误区：TCP流式套接字没有内置消息边界，绝不能把“recv返回空值（代表对端关闭连接）”当成单次独立消息的接收完成信号
  不管是服务端还是客户端，当前的收包逻辑都是“一直循环recv，直到收到空包（连接断开）才退出循环、开始反序列化数据”，但双向传输的流程下，双方都不会在发完第一份数据后主动关连接：
  • 服务端发完矩阵分片任务后，要等客户端回传结果才会关连接
  • 客户端发完计算结果后，要等自己的计算线程跑完才会关连接
    这就导致两边都卡在recv循环里死等对方断连：客户端收到了所有分片任务的字节，但因为没等到连接断开，永远走不到反序列化、计算结果的步骤，自然不会发出回传数据；服务端也因为收不到客户端的回传，永远卡在接收循环里。
• 服务端接收代码段本身的语法错误
  原来放开的接收逻辑里，反序列化时错误引用了循环内的临时变量：

  while 1:
      dat = self.client.recv(buf)
      pick_ += dat
      if not dat:break
  res = pickle.loads(dat) # 错误：应该加载累计的pick_，不是最后一次循环的dat
  

  这行代码一旦执行，会因为拿到的dat只是最后一段零散的字节、不是完整的pickle数据，直接抛出反序列化异常，触发服务端的_stop流程立刻关闭客户端连接，客户端刚连上就收到连接重置，自然拿不到完整的分片任务。
• 流程时序错位
  服务端当前的逻辑是：只要ClientHandling线程走完run()方法，就立刻关闭连接。一旦接收段触发异常，连接会在客户端还没读完分片数据的时候就被强行关掉，直接表现为“客户端无法正常接收到待计算的矩阵分片”。

针对性修复步骤 #

• 改写双向的收包逻辑，把“等连接断开”的退出条件换成“尝试反序列化成功”的退出条件，适配TCP流式传输的特点：
  1. 客户端接收分片任务的代码替换为：

     pick_str = b''
     while True:
         data = connexion_avec_serveur.recv(buf)
         if not data:
             connexion_avec_serveur.close()
             raise ConnectionError("服务端提前断开连接")
         pick_str += data
         # 尝试反序列化，成功说明完整的任务数据已经收全
         try:
             dic = pickle.loads(pick_str)
             break
         except pickle.UnpicklingError:
             # 数据未收全，继续等待剩余字节
             continue
     

  2. 服务端接收客户端回传结果的代码替换为：

     pick_ = b''
     while True:
         dat = self.client.recv(buf)
         if not dat:
             break
         pick_ += dat
         try:
             res = pickle.loads(pick_)
             # 收全回传结果后退出循环
             break
         except pickle.UnpicklingError:
             continue
     

• 修正接收段的变量引用错误，所有pickle反序列化操作一律加载累计的完整字节串，不要使用循环内的临时分片变量。
• 调整连接关闭时机：等服务端收齐所有10个客户端的回传分片、按分片序号拼接成最终的结果矩阵C后，再逐次调用客户端的close_connection方法，不要在流程中途提前关连接。

修复后完整的交互时序为：服务端监听客户端连接→逐次给每个连上的客户端分配分片任务→客户端收全任务→本地完成矩阵乘法→回传计算结果→服务端收全所有结果→拼接得到最终乘积矩阵→统一关闭所有客户端连接。

内容的提问来源于stack exchange，提问作者johncoded