当套接字重新连接时，如何让socket.io服务器向特定套接字重新发送消息？

Question

我的服务器代码使用io.to(socketId).emit('xxx')；将消息发送到特定的套接字，请参阅https://socket.io/docs/emit-cheatsheet/

但是，当连接坏了，客户机断开并再次连接时，socketId会发生变化，并且io.to(socketId).emit('xxx')；会失败。那么如何实现re-emit方法来处理重新连接呢？

我的问题与此相反，socket.io在x秒/第一次尝试获得响应失败后停止重新发出事件，从中我了解到socket.io客户端在重新连接时可以重新发出事件。但是服务器代码似乎缺乏这种支持。

---更新---

第三，当我得到redis pub事件而socketId值变得陈旧时，我的问题就会发生。实际上，socketid的值是最新的值，但是套接字可能无法发送消息。

io.on('connection', async function (socket) {
  socket.on('login', async function (user_id, fn) {
    ...
    await redis
      .multi()
      .hset('websocket:socket_user', socket.id, user_id)
      .hset(
        `websocket:${user_id}`,
        'socketid',
        socket.id
      )
      .exec()
    await sub.subscribe(user_id)
    ...
  }
                
  socket.on('disconnect', async function (reason) {     
    let user_id = await redis.hget('websocket:socket_user', socket.id)
    await redis.del(`websocket:${user_id}`)
    sub.unsubscribe(user_id)
    ...
  }
  
  //Here is what problem happens when socket is trying to reconnect 
  //while I got redis pub message

  sub.on('message', async function (channel, message) {
  let socketid = await redis.hget(`websocket:${channel}`, 'socketid')
  if (!socketid) {
    return
  }
  //so now I assume the socketid is valid, 
  //but it turns out clients still complain they didn't receive message
  io.to(socketid).emit('msg', message) //When it fails how do I re-emit?
})

Answer 1

通过覆盖默认方法生成套接字ID，可以为套接字客户端生成自定义socket.id。在这种情况下，socket.id将为您所知，并且可以在相同的id联机时重新发出。

//调用该函数时使用节点请求对象（http.IncomingMessage）作为第一个参数。根据socket.io文档

io.engine.generateId = (req) => {
  return "custom:id:" + user_unique_id; // custom id must be unique
}