如何在服务端使用Node.js的ws库监听用户后续回复消息

核心逻辑为服务端为每个用户维护独立的监听状态，所有消息统一经过服务端中间件校验处理，全程无需客户端做适配改造。

实现步骤 #

• 预设触发规则和状态存储结构
  先梳理所有需要触发后续监听的命令（如/xyz），给每个活跃用户维护awaiting_follow_up状态字段，字段内需存储对应触发的命令类型、状态超时时间两个核心参数，避免无效监听和逻辑混淆。
• 统一消息入口的校验逻辑
  所有用户发送的消息先进入服务端统一消息处理中间件，按优先级执行两层校验：

  第一层优先判断当前用户是否存在有效监听状态：存在则直接将消息转发给对应命令的业务处理逻辑，处理完成后直接清除该用户的监听状态即可
  第二层判断当前消息是否匹配预设的触发命令规则：匹配成功则给该用户打上对应监听标记，可同步返回客户端提示语引导用户输入后续内容

• 增加超时回收机制
  给每个用户的监听状态设置超时时间（建议10-15分钟），到期后自动清除状态，避免长期占用存储资源，也防止用户后续发送无关消息被错误匹配处理。

代码示例（Node.js 场景，生产环境可适配对应技术栈） #

// 分布式部署场景可替换为Redis存储用户状态
const userListenStatus = new Map()
// 预设所有需要触发监听的命令列表
const TRIGGER_COMMANDS = ['/xyz', '/submit', '/feedback']

// 服务端消息处理主函数
async function handleIncomingMessage(userId, messageContent) {
  // 优先校验用户是否存在有效监听状态
  const activeStatus = userListenStatus.get(userId)
  if (activeStatus && Date.now() < activeStatus.expireTime) {
    // 执行对应命令的后续业务逻辑
    await executeCommandTask(activeStatus.triggerCommand, userId, messageContent)
    // 处理完成后清除监听状态
    userListenStatus.delete(userId)
    return { type: 'success', content: '操作已完成' }
  }

  // 无监听状态时校验是否是触发命令
  const trimContent = messageContent.trim()
  if (TRIGGER_COMMANDS.includes(trimContent)) {
    // 给用户打监听标记，设置15分钟超时
    userListenStatus.set(userId, {
      triggerCommand: trimContent,
      expireTime: Date.now() + 15 * 60 * 1000
    })
    return { type: 'tip', content: '请输入你需要提交的对应内容' }
  }

  // 普通消息走默认处理逻辑
  return handleNormalMessage(userId, messageContent)
}

生产环境注意事项 #

• 多实例部署场景必须用分布式缓存（如Redis）存储用户监听状态，避免单实例本地存储导致的状态不同步问题
• 可增加取消监听的通用规则，比如用户发送/cancel就直接清除当前用户的所有监听状态，提升使用体验
• 多命令场景下状态存储必须标记对应触发的命令类型，避免不同命令的后续处理逻辑被混淆

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