如何将RabbitMQ队列连接到Socket IO服务器并将消息从Socket IO服务器并发发送到客户端

const amqp = require('amqplib/callback_api');
const http = require('http');
const socketIo = require('socket.io');

// 创建HTTP服务器
const server = http.createServer();
const io = socketIo(server);

// RabbitMQ连接配置
const rabbitMQUrl = 'amqp://localhost';

// 连接到RabbitMQ
amqp.connect(rabbitMQUrl, (err, conn) => {
  if (err) {
    throw err;
  }

  // 创建通道
  conn.createChannel((err, ch) => {
    if (err) {
      throw err;
    }

    const queue = 'test_queue';

    // 断言队列存在
    ch.assertQueue(queue, { durable: false });

    console.log(" [*] Waiting for messages in %s. To exit press CTRL+C", queue);

    // 监听队列消息
    ch.consume(queue, (msg) => {
      const message = msg.content.toString();
      console.log(" [x] Received %s", message);

      // 将消息发送到所有Socket.IO客户端
      io.emit('message', message);
    }, { noAck: true });
  });
});

// Socket.IO事件监听
io.on('connection', (socket) => {
  console.log('New client connected');

  socket.on('disconnect', () => {
    console.log('Client disconnected');
  });
});

// 启动服务器
server.listen(3000, () => {
  console.log('Server listening on port 3000');
});