如何让Socket.io仅向请求发起者发送通知？

问题本质 #

你的代码核心问题不是socket.emit的行为异常，而是Redis频道的订阅逻辑错误：
你在io.on('connection')回调内部执行了iosubClient.subscribe(UPSTREAM_MESSAGE, ...)，这意味着每有一个客户端连接到Socket.io服务器，就会新增一个Redis频道的订阅回调。当Redis发布UPSTREAM_MESSAGE消息时，所有已注册的回调（对应所有在线客户端的socket实例）都会触发，每个socket都会执行一次emit，最终表现为所有客户端都收到消息，看起来像广播。

修复方案 #

要实现“仅向发起请求的客户端发送响应”，需要把请求的客户端标识（socket.id）和请求内容绑定，在Redis消息中传递目标socket.id，然后在全局唯一的Redis订阅回调中，找到对应socket实例再发送消息。

步骤1：全局订阅Redis频道

把Redis订阅逻辑移到io.on('connection')外部，确保整个服务器只订阅一次：

// 在全局范围（连接回调外部）订阅Redis频道
iosubClient.subscribe(UPSTREAM_MESSAGE, (message) => {
  // 解析消息，获取目标socket.id和实际内容
  const { targetSocketId, data } = JSON.parse(message);
  // 根据socket.id找到对应的客户端连接
  const targetSocket = io.sockets.sockets.get(targetSocketId);
  if (targetSocket) {
    targetSocket.emit(UPSTREAM_MESSAGE, data);
  }
});

步骤2：发送请求时携带客户端标识

在处理客户端的DOWNSTREAM_MESSAGE时，把当前socket的id和消息内容一起发布到Redis：

io.on('connection', function (socket) {
  console.log(`connection made from ${socket.id}`);

  socket.on('disconnect', function () {
    console.log(`connection ${socket.id} closed`);
  });

  socket.on(DOWNSTREAM_MESSAGE, function (msg) {
    // 将目标socket.id和消息打包后发布到Redis
    const payload = JSON.stringify({
      targetSocketId: socket.id,
      data: msg
    });
    iopubClient.publish(DOWNSTREAM_MESSAGE, payload);
  });

  // 移除这里的Redis订阅逻辑
});

补充说明 #

1. 会话粘性（HAProxy基于Cookie）解决的是多Socket.io实例下，客户端请求路由到同一实例的问题，和你当前的问题无关，因为你的问题是单实例内重复订阅导致的。
2. 注意消息的序列化：因为Redis只能传递字符串，所以需要用JSON.stringify和JSON.parse处理带标识的消息体。

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