RabbitMQ单消费者（通用监听器）监听多队列实现咨询

没问题！要实现一个通用监听器（单消费者实例）同时监听多个RabbitMQ队列，其实操作很直接——不用给每个队列单独建消费者，同一个消费者就能搞定。我结合你给出的代码片段，整理了完整的可运行实现方案：

using RabbitMQ.Client;
using System.Text;
using System.Collections.Generic;

var factory = new ConnectionFactory() { HostName = "localhost" }; // 替换成你的RabbitMQ服务地址
using var connection = factory.CreateConnection();
using var channel = connection.CreateModel();

// 1. 声明交换机（示例用fanout类型，你也可以根据需求用direct/topic等）
channel.ExchangeDeclare(exchange: "logs", type: ExchangeType.Fanout);

// 2. 定义需要监听的多个队列列表
var targetQueues = new List<string> { "QueueName.Instance1", "QueueName.Instance2", "QueueName.Instance3" };

// 3. 绑定每个队列到交换机（队列不存在会自动创建，已存在则直接复用）
foreach (var queueName in targetQueues)
{
    channel.QueueDeclare(queue: queueName, durable: true, exclusive: false, autoDelete: false, arguments: null);
    channel.QueueBind(queue: queueName, exchange: "logs", routingKey: "");
}

// 4. 创建通用消费者实例
var universalConsumer = new EventingBasicConsumer(channel);

// 5. 通用消息处理逻辑——可根据来源队列做差异化处理，也可以统一处理
universalConsumer.Received += (sender, ea) =>
{
    var messageBody = ea.Body.ToArray();
    var messageContent = Encoding.UTF8.GetString(messageBody);
    var sourceQueue = ea.QueueName; // 直接获取消息来自哪个队列（新版本RabbitMQ.Client支持）
    
    Console.WriteLine($" [x] 从队列 {sourceQueue} 收到消息: {messageContent}");

    // 生产环境推荐手动确认消息，避免丢失
    channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
};

// 6. 让同一个消费者监听所有目标队列
foreach (var queueName in targetQueues)
{
    // autoAck设为false开启手动确认，测试场景可设为true自动确认
    channel.BasicConsume(queue: queueName, autoAck: false, consumer: universalConsumer);
}

Console.WriteLine(" [*] 通用监听器已启动，等待多队列消息...");
Console.ReadLine();

• 单消费者多队列的核心逻辑：RabbitMQ允许同一个EventingBasicConsumer实例，在同一个信道上对多个队列调用BasicConsume，所有队列的消息都会触发同一个Received事件处理逻辑，完美实现通用监听器的需求。
• 区分不同队列的消息：可以通过ea.QueueName直接获取消息来源队列，也可以从ea.ConsumerTag中解析，方便对不同队列的消息做差异化业务处理。
• 消息确认机制：示例中用了手动确认（autoAck: false），这是生产环境的最佳实践，能有效避免消息丢失；如果是快速测试场景，也可以设置autoAck: true自动确认。
• 队列与交换机绑定：如果你的队列已经提前在RabbitMQ控制台创建好，那可以跳过QueueDeclare步骤，直接执行QueueBind即可。

• 确保RabbitMQ服务正常运行，连接参数（HostName、用户名密码等）配置正确。
• 如果需要高并发处理，可以添加channel.BasicQos(0, 10, false)来限制消费者预取消息数，避免消息堆积。
• 消费者实例的生命周期要和信道保持一致，不要在信道关闭后继续使用该消费者。

内容的提问来源于stack exchange，提问作者user3747994