我在socket.io我的项目中使用www.example.com nodejs集群，我不知道为什么同一个事件会发生两次。我尝试了www.example.com的各种版本Socket.io，但我仍然得到一个错误，2个相同的事件可以去。套接字版本：2.0.5

服务器代码

const cluster = require("cluster");
const http = require("http");
const { Server } = require("socket.io");
const redisAdapter = require("socket.io-redis");
const numCPUs = require("os").cpus().length;
const { setupMaster, setupWorker } = require("@socket.io/sticky");

if (cluster.isMaster) {
  console.log(`Master ${process.pid} is running`);

  const httpServer = http.createServer();
  setupMaster(httpServer, {
    loadBalancingMethod: "least-connection", // either "random", "round-robin" or "least-connection"
  });
  httpServer.listen(3000);

  for (let i = 0; i < numCPUs; i++) {
    cluster.fork();
  }

  cluster.on("exit", (worker) => {
    console.log(`Worker ${worker.process.pid} died`);
    cluster.fork();
  });
} else {
  console.log(`Worker ${process.pid} started`);

  const httpServer = http.createServer();
  const io = new Server(httpServer);
  io.adapter(redisAdapter({ host: "localhost", port: 6379 }));
  setupWorker(io);

  io.on("connection", (socket) => {
    console.log("connected");
    socket.join("data");
    io.to('data').emit("event", "data");
  });

}

客户编码

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

const socket = io.connect("http://localhost:3000");

socket.on("event", (data) => {
  console.log("Received data:", data);
});