Function initServer

examples/cluster-engine-redis/server.js:10–39

(port)

const { createProxyServer } = proxyModule;

async function initServer(port) {
  const httpServer = createServer((req, res) => {
    res.writeHead(404).end();
  });

  const pubClient = createClient();
  const subClient = pubClient.duplicate();

  await Promise.all([pubClient.connect(), subClient.connect()]);

  const engine = new RedisEngine(pubClient, subClient);

  engine.attach(httpServer, {
    path: class="st">"/socket.io/",
  });

  const io = new Server({
    adapter: createAdapter(pubClient, subClient),
  });

  io.bind(engine);

  io.on(class="st">"connection", (socket) => {
    socket.on(class="st">"hello", () => {
      socket.broadcast.emit(class="st">"hello", socket.id, port);
    });
  });

  httpServer.listen(port);
}

function initProxy() {
  const proxy = createProxyServer();