我正在创建一个简单的聊天应用程序，
1.可以有多个用户和多个聊天室。
1.每个聊天室可以容纳多个用户。

1. rabbitMQ连接在服务器启动时建立。
   1.当用户连接到服务器时，在rabbitMQ通道中打开套接字连接。
   1.当客户端（用户）通过socket发送消息时，rabbitmq channel使用特定的路由键将其推送到交换机。
   1.在消费时，如果套接字是活动的，那么通过它发送并确认它。如果没有，不要确认它，并重新排队。
   {

//Creating a new connection
amqp.connect('amqp://localhost', (err, conn) => {

conn.createChannel(function(err, ch) {

ch.assertExchange(exchangeName, 'direct', { durable: false });
const routingKey = // some routing key;    

wss.on('connection', (ws, req) => {
  // Creating a new queue for the user
  ch.assertQueue('', { exclusive: true, persist: true, durable: true }, (err, q) => {
    // Binds with the routing key
    ch.bindQueue(q.queue, exchangeName, routingKey);

    ch.consume(q.queue, (msg) => {
      if (ws.readyState === 1) {
        ch.ack(msg);
        ws.send(` [-] Received ${msg.content.toString()}`);
      } else {
        // What will come here so that it will be requeued to a new queue with the same routing id?
      }
    }, { noAck: false });
  });

  ws.on('message', (message) => {
    ch.publish(exchangeName, routingKey, new Buffer(message));
    console.log(`[x] Sent ${message} to the exchange with routingKey ${routingKey}`);
  });
})

当所有用户都在与服务器连接的套接字中时，这将正常工作。我想实现的是，当用户的套接字连接死亡时，如果他错过了基于路由键（特定于用户）的消息，他应该能够在重新连接时再次接收这些消息。我觉得这是可能的，因为如果在任何队列中没有确认，消息可以保留在交换中。但不知道如何实施。