在一个通道中消耗多个队列

Question

我使用 rabbitMq 来管理和处理队列。我有多个队列。它们的数量不具体。我使用直接交换来发布消息。如何仅使用一个通道使用每个队列的所有消息（基于routing_key）？此时我假设我有 5 个队列。我已经使用 for 循环并为每个队列创建一个通道。像这样：

 stuff=["shoes","pants","hats","jewels","glasses"];

  stuff.forEach(cnt => 
    {
        var ex = 'stuff';
        var cq=cnt;

        amqp
        .connect('amqp://localhost')
        .then(conn => conn.createChannel())
        .then(ch => {

            ch.assertExchange(ex, 'x-delayed-message', { durable: true, 
     arguments: { 'x-delayed-type': 'direct' } })
     return ch
             .assertQueue(cq, { durable: true })
             .then(() =>  {   ch.bindQueue(cq, ex, cq)  /*second cq is routing*/  
                 })
                  .then(() => {
                  ch.consume(cq, (msg) =>
                  {

                   console.log("['%s']  '%s'",cq, msg.content.toString()); 
                   if( msg.content.toString()!=null)
                   console.log(cq);

                          reciveMSG=JSON.parse(msg.content.toString());

                    }, { noAck: true });
               }); 
         }) 


     });

但我只想用一个频道来做。因为它更乐观并且使用更少的内存（我不知道这是真的还是假的！）。有没有办法处理非特定数量的队列？

Answer 1

每个队列必须使用一个通道来使用消息。这是 AMQP 规范的一部分，没有办法绕过它。

_{注：在RabbitMQ的团队监控的rabbitmq-users邮件列表，只有时StackOverflow上回答问题。}