Socket.IO 4.x自定义房间无法转发消息问题求助

核心问题 #

你手动修改了Socket.IO的socket.id属性，这是导致房间消息无法转发的关键原因。socket.id是Socket.IO内部用来唯一标识连接的核心字段，自定义赋值会破坏框架的连接追踪与房间管理逻辑，使得后续的房间消息路由失效。

修复步骤 #

1. 修正服务端代码 #

移除socket.id = user.id这一行，改用join方法将用户加入以自身ID命名的房间，而非替换内部标识：

io.on('connection', (socket) => {
    const token = extractToken(socket.handshake.headers)
    const decodedToken = jwt.decode(token, { complete: true })
    const user = decodedToken.payload.user_information

    socket.leave(socket.id) // 可选：离开默认的socket.id房间
    socket.join(user.id) // 将用户加入以自己ID命名的房间，不修改socket.id

    socket.on('room', (room) => {
        socket.join(room)
    })

    socket.on('lobby', async (data) => {
        const { message, room } = data
        console.log(data)
        // 用io.to()确保消息发送给房间内所有客户端（包括发送者自己可选），或者socket.to()排除发送者
        io.to(room).emit('lobby', message)
    })

    socket.on('disconnect', () => {
        console.log(user.username + ' has disconnected')
    })
})

2. 客户端代码优化 #

socket.emit是异步操作但无需await，可以移除多余的await：

messageForm.addEventListener('submit', (e) => {
    e.preventDefault()
    if (messageInput.value) {
        socket.emit('room', roomInput.value)
        socket.emit('lobby', { 'message': messageInput.value, 'room': roomInput.value })
        messageInput.value = ''
    }
})

额外验证建议 #

• 服务端可以在用户加入房间后打印房间成员，确认客户端是否正确加入：

  socket.on('room', (room) => {
      socket.join(room)
      // 打印房间内的所有socket ID，验证加入状态
      io.in(room).allSockets().then(sockets => {
          console.log(`Room ${room} members:`, sockets)
      })
  })
  

• 确保房间名称格式一致（比如无空格、大小写统一），避免因名称不匹配导致消息无法投递。

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