PySimpleGUI循环中socket.send首次发送后失效问题求助

1. 检查TCP连接状态 #

• 发送第一条消息后，用Ubuntu命令netstat -anp | grep <你的服务器端口>查看连接状态，如果发送后连接变为TIME_WAIT或CLOSED，说明代码里可能在单次发送后调用了socket.close()，要保持连接复用，除非明确需要断开。
• 确保socket对象在整个程序生命周期内只初始化一次，不要每次发送都重新创建连接。

2. 解决消息粘包/边界问题 #

• 测试客户端可能自动添加了消息边界（比如换行符），但二维码扫描后的消息没加，导致服务器端recv()一直等待完整消息，后续发送被阻塞。
• 修改客户端发送逻辑，每条消息末尾统一添加结束符，比如：

  sock.sendall((qr_scanned_data + "\n").encode('utf-8'))
  

  服务器端按行读取数据，避免粘包导致的接收阻塞。

3. 避免GUI事件循环阻塞 #

• 即使去掉多线程，二维码扫描如果是阻塞式操作，会卡住PySimpleGUI的主事件循环，导致后续扫描和发送无法触发。
• 把扫描+发送逻辑放到线程里执行，不阻塞主循环：

  import PySimpleGUI as sg
  import threading
  import socket
  
  # 全局或类内维护socket连接
  sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  sock.connect(('服务器IP', 端口号))
  
  def scan_and_send(window):
      qr_data = 你的二维码扫描函数()  # 替换为实际扫描逻辑
      if qr_data:
          try:
              sock.sendall((qr_data + "\n").encode('utf-8'))
              window.write_event_value('-SEND_SUCCESS-', qr_data)
          except Exception as e:
              window.write_event_value('-SEND_ERROR-', str(e))
  
  # GUI事件循环
  window = sg.Window("二维码扫描客户端", [[sg.Button("扫描发送")], [sg.Text("", key='-STATUS-')]])
  while True:
      event, values = window.read()
      if event == sg.WIN_CLOSED:
          sock.close()
          break
      if event == "扫描发送":
          threading.Thread(target=scan_and_send, args=(window,), daemon=True).start()
      elif event == '-SEND_SUCCESS-':
          window['-STATUS-'].update(f"已发送: {values[event]}")
      elif event == '-SEND_ERROR-':
          window['-STATUS-'].update(f"发送失败: {values[event]}")
  

4. 捕获Socket异常 #

• 无报错不代表没有异常，给发送逻辑加上异常捕获，定位问题：

  try:
      sock.sendall((qr_data + "\n").encode('utf-8'))
  except ConnectionResetError:
      # 连接被重置，尝试重连
      sock.close()
      sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
      sock.connect(('服务器IP', 端口号))
      sock.sendall((qr_data + "\n").encode('utf-8'))
  except Exception as e:
      print(f"发送异常: {str(e)}")
  

5. 验证服务器端接收逻辑 #

• 确认服务器端没有在接收第一条消息后退出循环，服务器需要保持持续接收：

  # 服务器端示例代码
  import socket
  
  server_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  server_sock.bind(('0.0.0.0', 12345))
  server_sock.listen(5)
  client_sock, addr = server_sock.accept()
  # 循环接收直到连接断开
  while True:
      data = client_sock.recv(1024).decode('utf-8').strip()
      if not data:
          break
      print(f"收到数据: {data}")
  client_sock.close()
  server_sock.close()
  

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