使用Socket与Node Express向role_id为1的特定用户广播消息的实现方法

以下方案默认你使用的是Node生态常用的Socket.IO库，匹配你的Express技术栈：

1. 核心逻辑 #

你当前用的广播逻辑默认会给全量连接用户推送，要实现定向发送，首先要让服务端能识别每个Socket连接对应的用户角色，再筛选目标用户推送即可。

2. 基础实现（适合用户量较小的场景） #

第一步：Socket连接绑定用户身份 #

用户登录成功后，把用户角色信息挂载到对应Socket实例上，同时维护全局在线用户映射：

// 服务端全局存储在线用户映射，key为用户id，value为对应socket实例
const onlineUsers = new Map()

// 监听socket连接
io.on('connection', (socket) => {
  // 前端登录成功后，主动把包含role_id的用户信息传给服务端
  socket.on('user_login', (userInfo) => {
    if (userInfo.loginSuccess) {
      // 把用户信息挂载到socket实例上，后续直接读取
      socket.user = {
        userId: userInfo.userId,
        role_id: userInfo.role_id,
        status: 'Online'
      }
      // 存入全局映射表
      onlineUsers.set(userInfo.userId, socket)
    }
  })

  // 用户断开连接时清理映射，避免内存泄漏
  socket.on('disconnect', () => {
    if (socket.user) {
      onlineUsers.delete(socket.user.userId)
    }
  })
})

第二步：筛选角色推送消息 #

需要发消息时，遍历所有在线Socket，只给role_id=1的用户推送：

const targetMsg = 'hello role 1 users'
// 遍历所有在线socket
io.sockets.sockets.forEach(socket => {
  if (socket.user?.role_id === 1) {
    socket.emit('message', targetMsg)
  }
})

3. 优化实现（适合用户量较大的场景） #

用Socket.IO自带的「房间」功能，不需要遍历全量Socket，推送性能更高：

登录时加入对应角色房间 #

socket.on('user_login', (userInfo) => {
  if (userInfo.loginSuccess) {
    socket.user = {
      userId: userInfo.userId,
      role_id: userInfo.role_id,
      status: 'Online'
    }
    // 加入对应角色的专属房间，比如role_1、role_2
    socket.join(`role_${userInfo.role_id}`)
  }
})

直接给角色房间发消息 #

// 一行代码即可给所有role_id=1的用户发消息，不需要遍历
io.to('role_1').emit('message', targetMsg)

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