Socket.IO服务器未收到客户端确认回调问题排查求助

核心问题在于你使用了广播模式发送事件，而Socket.IO的确认回调仅支持直接向单个Socket实例发送的场景。socket.to(targetSocketId).emit() 属于广播方法，它会将事件投递给目标socket，但不会监听该socket的确认响应，所以服务端永远收不到回调。

修复步骤 #

1. 获取目标Socket实例并直接发送 #

服务端需要先从Socket.IO的连接管理器中拿到对应targetSocketId的socket实例，再调用其emit方法，这样才能正常接收确认回调：

修改后的服务端代码：

async function emitData(
    socket: Socket,
    targetSocketId: string,
    event: configUpdate,
    data: any,
    callback: Function,
    mpu_id: string
) {
    console.log('Emitting event:', event, 'to socket ID:', targetSocketId);
    try {
        // 获取目标socket实例
        const targetSocket = socket.server.sockets.sockets.get(targetSocketId);
        
        if (!targetSocket) {
            callback({ status: 'error', message: 'Target client is not connected.' });
            return;
        }

        // 直接调用目标socket的emit方法，支持确认回调
        targetSocket.emit(event, data, async (acknowledgment: any) => {
            console.log('Acknowledgment received:', acknowledgment); 
            if (acknowledgment && acknowledgment.status === 'ok') {
                await updateSendToMpu(mpu_id);
                callback({ status: 'ok', message: `${event} successfully updated.` });
            } else {
                callback({
                    status: 'error',
                    message: acknowledgment
                        ? 'Client failed to acknowledge.'
                        : 'No acknowledgment received from client.',
                });
            }
        });
    } catch (error) {
        console.error('Error emitting data:', error);
        callback({ status: 'error', message: 'Failed to emit event.' });
    }
}

2. 额外排查点 #

• 确认targetSocketId的有效性：可以在服务端打印当前在线socket列表验证：

  console.log('Online sockets:', Array.from(socket.server.sockets.sockets.keys()));
  

• 确保客户端与服务端的Socket.IO版本一致：版本不兼容可能导致回调机制异常
• 检查客户端是否在回调调用后立即断开连接：如果客户端处理完事件后立即断开，可能导致确认包无法送达服务端

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