Node.js使用Socket.io实现实时通知 如何向指定用户推送消息

首先明确你疑问的基础事实：
同一账号在多设备、多浏览器标签页建立的Socket连接会生成完全独立、全局唯一的socket.id，不存在重复，如果你直接绑定单个socket.id到用户账号，必然会出现仅最后一次登录的设备能收到通知的问题。

你原有代码存在的核心问题是依赖单socket.id做推送目标，完全可以用Socket.io原生的房间（Room）机制解决，不需要额外在数据库存储socket.id映射，实现步骤如下：

步骤1：连接鉴权后将用户加入专属ID房间 #

用户建立Socket连接时，先通过握手携带的身份凭证完成鉴权，拿到当前连接对应的用户唯一ID后，直接将该Socket连接加入以用户ID命名的专属房间。同一账号的所有在线连接都会进入同一个房间，天然支持多端同步接收。
服务端实现代码：

const jwt = require('jsonwebtoken');
const YOUR_JWT_SECRET = "替换为你的业务鉴权密钥";

io.on("connection", async (socket) => {
  // 从连接握手参数中取前端传入的身份凭证，做合法性校验
  const token = socket.handshake.auth.token;
  let userId;
  try {
    const userInfo = jwt.verify(token, YOUR_JWT_SECRET);
    userId = userInfo.userId; // 取到当前连接对应的用户唯一标识，比如John Doe的用户ID为1001
  } catch (err) {
    socket.disconnect(true); // 鉴权失败直接断开非法连接
    return;
  }

  // 核心逻辑：将当前连接加入专属用户房间
  const userPrivateRoom = `user:${userId}`;
  socket.join(userPrivateRoom);

  // 连接断开时Socket.io会自动将连接从房间中移除，不需要手动写清理逻辑
  socket.on("disconnect", () => {
    console.log(`用户ID${userId}的一个设备已下线`);
  });
});

前端连接时需要传入有效鉴权凭证：

import { io } from "socket.io-client";

const socket = io({
  auth: {
    token: "当前登录用户的业务鉴权token"
  }
});

步骤2：推送时直接向用户专属房间发消息 #

给指定用户发通知时，不需要查询任何socket.id，直接向目标用户的专属房间发送消息即可，房间内所有在线的设备连接都会实时收到消息。
修正后的推送逻辑代码：

socket.on("notify", async (message) => {
  // 业务侧先查询到John Doe对应的用户ID，示例值为1001
  const targetJohnDoeId = 1001;
  const targetRoom = `user:${targetJohnDoeId}`;
  
  // 向房间推送实时消息，所有John Doe的在线登录设备都会收到
  io.to(targetRoom).emit("notification", {
    type: "club_invite",
    content: "你收到一条俱乐部加入邀请",
    ...message
  });

  // 离线兜底：将通知写入数据库，用户不在线时下次上线拉取未读消息即可，避免消息丢失
  await NotificationModel.create({
    userId: targetJohnDoeId,
    content: message,
    isRead: false
  });
});

注意：你原有代码中事件名notificaton存在拼写错误，正确拼写为notification，否则前端无法正确监听触发消息回调。

方案优势 #

• 天然支持多端同步推送：同一账号的所有在线设备都会加入同一专属房间，推送时所有端实时收到通知，不存在单设备接收的问题
• 无额外维护成本：Socket.io原生维护房间内的连接列表，连接断开、重连时自动更新房间成员，不需要手动维护用户和socket.id的映射关系，不会产生脏数据
• 兼容集群部署：如果后续服务做多实例集群部署，只需要接入Socket.io官方的Redis适配器，房间逻辑可以跨实例生效，不需要修改业务代码
• 离线场景兼容：实时推送+消息落库的组合逻辑，既保证在线用户的实时性，也保证离线用户不会丢消息，上线后拉取未读即可

为什么不建议把socket.id存入数据库绑定用户：

1. socket.id是连接级临时标识，每次Socket重连都会生成新值，需要频繁更新数据库，额外开销大
2. 多端登录场景下需要额外维护「一个用户对应多个socket.id数组」的关系，还要手动处理断开连接时的数组清理，逻辑冗余容易出bug
3. 多实例部署时，单实例内存/数据库存储的socket.id映射无法跨实例生效，扩展性差

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