Socket.io Rooms无法向特定用户发送消息问题求助

核心问题 #

React Native Expo 集成 Socket.io 实现实时通知时，后端能正确接收joinRoom和purchaseCompleted参数，但用户A无法收到purchaseConfirmation事件。

排查方向与修复步骤 #

1. 确保 Socket 实例全局一致 #

React Native 中如果重复创建 Socket 实例，会导致事件监听失效。建议全局维护一个 Socket 实例：

// socket.js
import io from 'socket.io-client';

// 替换为你的后端地址，强制使用 websocket 传输（避免 polling 适配问题）
const socket = io('http://your-server-address', {
  transports: ['websocket'],
  reconnection: true,
});

export default socket;

用户A和用户B的组件都导入这个全局实例，确保连接唯一。

2. 调整事件监听与房间加入顺序 #

先监听事件、确认连接状态，再执行房间加入操作，避免异步时序问题：

// 用户A前端代码
import socket from './socket';

React.useEffect(() => {
  const userId = 'd48d76e6-a733-4d6c-aab7-48525ea44294';

  // 监听连接状态
  const onConnect = () => {
    console.log('Socket 已连接');
    socket.emit('joinRoom', userId);
  };

  // 监听房间加入确认
  const onRoomJoined = (room) => {
    console.log(`已加入房间：${room}`);
  };

  // 监听购买确认
  const onPurchaseConfirm = (data) => {
    console.log('收到购买确认：', data);
  };

  const onDisconnect = () => {
    console.log('Socket 已断开');
  };

  // 绑定监听
  socket.on('connect', onConnect);
  socket.on('roomJoined', onRoomJoined);
  socket.on('purchaseConfirmation', onPurchaseConfirm);
  socket.on('disconnect', onDisconnect);

  // 组件卸载时清理监听
  return () => {
    socket.off('connect', onConnect);
    socket.off('roomJoined', onRoomJoined);
    socket.off('purchaseConfirmation', onPurchaseConfirm);
    socket.off('disconnect', onDisconnect);
    socket.leave(userId);
  };
}, []);

3. 完善后端日志与确认机制 #

在后端增加连接、房间加入、事件触发的日志，确保每一步都执行正常：

// 后端代码
function purchaseNotification(io) {
  io.on('connection', (socket) => {
    console.log(`客户端连接：${socket.id}`);

    socket.on('joinRoom', (roomName) => {
      socket.join(roomName);
      console.log(`Socket ${socket.id} 加入房间：${roomName}`);
      // 给客户端发送加入确认
      socket.emit('roomJoined', roomName);
    });
        
    socket.on('purchaseCompleted', (data) => {
      console.log(`收到购买完成请求：用户ID=${data.userId}，消息=${data.message}`);
      // 仅需一种 emit 方式即可
      io.to(data.userId).emit('purchaseConfirmation', data.message);
      console.log(`已向房间 ${data.userId} 发送购买确认`);
    });

    socket.on('disconnect', () => {
      console.log(`客户端断开：${socket.id}`);
    });
  });
}

module.exports = purchaseNotification;

4. 强制匹配 Socket.io 版本 #

前后端 Socket.io 版本必须完全一致，否则会出现事件无法传递的兼容性问题：

• 后端安装指定版本：npm install socket.io@4.7.2
• 前端安装对应版本：npm install socket.io-client@4.7.2

5. 验证房间名称一致性 #

确认用户A加入的房间名（userId）与用户B发送的data.userId完全一致，无大小写、空格或格式差异。

总结排查流程 #

1. 查看前后端日志，确认 Socket 连接正常
2. 确认用户A成功加入目标房间（后端打印+前端接收roomJoined事件）
3. 确认后端执行了purchaseConfirmation的 emit 操作
4. 验证前后端 Socket.io 版本匹配

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