首先，您需要维护每个客户端到其订阅的聊天ID的Map。您可以使用JavaScript Map来实现这一点，其中键是客户端对象，值是它们订阅的聊天ID的数组：

const subscriptionsMap = new Map();

字符串
当客户端连接到WebSocket时，将其订阅信息存储在subscriptionsMap中。当客户端断开连接时，请确保从Map中删除其订阅：

wss.on('connection', (client) => {
  // Handle client connection

  // Assume `json.body.subscriptions` contains the array of chat IDs the client is subscribed to
  subscriptionsMap.set(client, json.body.subscriptions);

  // Handle client disconnection
  client.on('close', () => {
    subscriptionsMap.delete(client);
    // Perform any necessary cleanup
  });
});

型
现在，当您在特定聊天中收到需要发送给客户端的消息时，请遍历已连接的客户端，并仅将消息发送给订阅了相关聊天ID的客户端：

// Assuming `json.body.chatId` contains the chat ID for the message
const chatId = json.body.chatId;

wss.clients.forEach((client) => {
  if (subscriptionsMap.has(client) && subscriptionsMap.get(client).includes(chatId)) {
    client.send(message);
  }
});

型