处理多个实例上的 WebSocket 连接。

Question

处理多个实例上的 WebSocket 连接。

javascriptnode.jswebsocketsocket.ionestjs

3

我需要理解在多个实例上处理WebSockets的概念，以便可以在所有实例之间共享。例如，我有三个正在运行的节点，由负载均衡器连接。在接收到需要在特定套接字上发出的数据时，我的最初想法是创建哈希映射或JSON对象来保存WebSocket连接。但是我意识到这不能以这种方式完成，因为它仅适用于特定实例。如果我在任何一个实例上接收到数据，那么大部分数据将不会发出到该WebSocket连接，因为它不知道WebSocket是在哪个实例上创建的。有没有一种好的方法来处理WebSocket连接，使其可以在所有实例上共享。我的想法是使用Redis或PostgreSQL数据库，因为它们在所有实例之间共享。

此外，我已经尝试过使用PostgreSQL解决方案来存储WebSocket连接，但当我保存连接时，它显示

TypeError: Converting circular structure to JSON

是否有一些好的解决方案来处理可以在所有实例之间共享的WebSocket连接。如果数据库是一个好的解决方案，我应该如何解决TypeError：Converting circular structure to JSON问题。

- JN_newbie

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Pascal Lamers · Answer 1

我猜你正在寻找的是 适配器，它在官方的 socket.io 文档中有比较好的记录（/v4/adapter/）。

当扩展到多个 Socket.IO 服务器时，您需要用另一种实现替换默认的内存适配器，以便事件正确路由到所有客户端。

您可以选择几个官方适配器：

Redis 适配器
MongoDB 适配器
Postgres 适配器
Cluster 适配器

这里是使用 MongoDB 适配器的示例：

npm install @socket.io/mongo-adapter mongodb

const { Server } = require("socket.io");
const { createAdapter } = require("@socket.io/mongo-adapter");
const { MongoClient } = require("mongodb");

// DATABASE CONNECTION
const DB = "mydb";
const COLLECTION = "socket.io-adapter-events";
const mongoClient = new MongoClient("mongodb://localhost:27017/?replicaSet=rs0", {
  useUnifiedTopology: true,
});

const io = new Server();

const main = async () => {
  await mongoClient.connect();

  try {
    await mongoClient.db(DB).createCollection(COLLECTION, {
      capped: true,
      size: 1e6
    });
  } catch (e) {
    // collection already exists
  }
  const mongoCollection = mongoClient.db(DB).collection(COLLECTION);

  // HERE COMES THE IMPORTANT PART :)
  // CREATE MONGO DB ADAPTER AND USE IT 
  io.adapter(createAdapter(mongoCollection));
  io.listen(3000);
}

main();

适配器将会处理剩下的部分。每个发送给多个客户端的数据包（例如io.to("room1").emit()或socket.broadcast.emit()）都会：

发送到所有连接到当前服务器的匹配客户端
插入到MongoDB的固定集合中，并被集群中其他Socket.IO服务器接收