基于Socket.io的反向WebSocket连接：Socket ID跟踪问题

你的场景很有意思——把常规的Socket.io服务端/客户端角色反过来，让App A作为客户端主动连接多个独立的服务端（B/E）。目前遇到的核心问题有两个：一是连接回调里的变量引用错误导致无法获取正确的Socket ID，二是缺少统一的连接管理机制来跟踪每个App对应的socket实例。下面一步步帮你解决：

一、修正App A的连接回调，正确获取Socket ID #

你当前的代码里，在socketB.on('connect')回调里用了未定义的socket变量，应该用当前的socket实例（比如socketB）来访问id属性。同时我们可以用一个对象统一管理所有连接，方便后续定向操作：

const io = require('socket.io-client');

// 建立连接映射：用App标识（比如'B'、'C'）关联对应的socket实例
const appConnections = {
  B: io('http://10.11.18.1:3000'),
  C: io('http://10.11.19.1:3000'),
  D: io('http://10.11.20.1:3000'),
  E: io('http://10.11.21.1:3000'),
};

// 遍历所有连接，统一处理connect、disconnect事件和消息监听
Object.entries(appConnections).forEach(([appName, socket]) => {
  socket.on('connect', () => {
    console.log(`已连接到App ${appName}，Socket ID: ${socket.id}`);
    // 可选：把Socket ID存入映射表备用
    socket.socketId = socket.id;
  });

  socket.on('disconnect', () => {
    console.log(`与App ${appName}断开连接`);
  });

  // 监听服务端（B/E）发来的特定事件回复
  socket.on('event-reply', (data) => {
    console.log(`收到App ${appName}的回复:`, data);
  });
});

二、定向发送消息到指定App #

有了appConnections映射表，你可以随时给特定App发送消息，比如触发App B的某个操作：

// 给App B发送指令
appConnections.B.emit('trigger-operation', { task: '生成报表', params: { date: '2024-05-20' } });

这种方式比维护Socket ID列表更直观，因为每个App的连接都是独立的socket实例，直接通过标识就能定位。

三、修正App B/E的服务端代码 #

你当前的服务端代码存在初始化错误——const socket = io();是客户端的初始化方式，服务端需要正确创建Socket.io服务器实例。修正后的代码（App B、C、D、E通用）：

const { Server } = require('socket.io');
const http = require('http');

// 创建HTTP服务器（Socket.io依赖HTTP协议）
const server = http.createServer();
const io = new Server(server);
const PORT = 3000; // 注意和App A连接的端口保持一致

io.on('connection', (client) => {
  console.log(`App A已连接，Socket ID: ${client.id}`);

  // 监听App A发来的触发事件
  client.on('trigger-operation', (data) => {
    console.log('收到App A的指令:', data);
    // 在特定事件下回复消息给App A
    client.emit('event-reply', { status: 'success', result: '报表生成完成' });
  });

  client.on('disconnect', () => {
    console.log('与App A断开连接');
  });
});

server.listen(PORT, () => {
  console.log(`App服务端运行在端口 ${PORT}`);
});

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