Python中Socket.IO服务器向客户端发送数据失败求助

核心问题梳理 #

你的代码存在几个关键问题导致客户端无法接收服务器消息：

1. 事件名不匹配：服务器发送的事件是response_from_server，但客户端监听的是server_response，两者必须完全一致才能触发回调。
2. 未指定消息目标客户端：sio.emit默认会广播给所有客户端，若未通过room=sid指定目标会话，消息无法精准发送到对应客户端。
3. 线程模型冲突：Eventlet依赖协程调度，混用Python标准库的Thread会破坏其协程环境，导致Socket.IO的消息调度异常。
4. 消息发送时机过早：模拟SQS的函数会在服务器启动后立即执行，此时客户端尚未完成连接，Redis中还没有对应的sid，导致消息无法发送。

分步修复代码 #

1. 修复服务器端消息发送逻辑

修改send_response_to_client函数，确保事件名与客户端一致，并指定目标房间：

def send_response_to_client(sid, resp):
    """发送响应到指定客户端"""
    # 匹配客户端监听的事件名，同时指定room=sid精准发送
    sio.emit('server_response', f'response : {resp}', room=sid)
    print("data sent to client ")

2. 调整SQS模拟函数的执行时机

添加延迟，确保客户端完成连接并将sid存入Redis后再发送消息：

def listen_sqs_queue():
    """模拟SQS消息监听逻辑"""
    # 延迟3秒，等待客户端连接完成
    time.sleep(3)
    data = {
        "communicationStatus": "OKAY",
        "status": "Complete"
    }
    unique_id = "123789"
    if unique_id:
        print("inside sqs impl is : ", unique_id)
        sid = get_sid_by_unique_id(unique_id=unique_id)
        if sid:
            print("calling send response to client")
            send_response_to_client(sid, data)
            print(
                f"Response has been sent to the client with sessionId: {sid} and uniqueId : {unique_id}")
        else:
            print(f"Client not found for the given uniqueId: {unique_id}")

3. 适配Eventlet协程模型

改用Eventlet的spawn启动后台任务，替代Python标准库的Thread：

def start_server():
    initialize_redis_conn()

    # 用eventlet.spawn启动后台任务，符合协程调度规则
    eventlet.spawn(listen_sqs_queue)

    # 直接启动服务器，无需放入普通线程
    eventlet.wsgi.server(eventlet.listen(('localhost', 5000)), app)

4. 修复客户端连接的请求头传递

确保客户端连接时传递服务器预期的token：

# 替换原connect代码，添加headers
sio.connect(url, headers={'token': token})

额外排查建议 #

• 验证Redis存储：在客户端连接后，手动检查Redis中是否存在DATA_KEY_123789键，确认sid已正确存入。
• 启用调试日志：在服务器和客户端初始化时添加logger=True，查看Socket.IO的详细交互日志：

  # 服务器端
  sio = socketio.Server(logger=True)
  # 客户端
  sio = socketio.Client(logger=True)
  

• 检查传输方式：确保客户端使用的传输方式与服务器兼容，可显式指定transports=['websocket', 'polling']。

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