Rebus是否支持发布-订阅模式下的轮询式单消费者消息处理？

当然可以！Rebus完全支持你说的这种轮询（round-robin）模式的消息分发——也就是每条消息只会被一个订阅者处理，多个订阅者轮流接收消息，这其实就是典型的工作队列（work queue）模式，正好匹配你的需求。

实现思路与配置要点 #

Rebus的底层消息传输（比如RabbitMQ）本身就原生支持这种轮询分发逻辑，你只需要做好以下几点：

• 让所有需要参与轮询的订阅者，都监听同一个共享队列，而不是各自创建独立的专属队列。默认情况下Rebus会给每个订阅者生成独立队列，所以你需要显式指定队列名称。
• 发布端正常发布消息，不管是直接发送到共享队列，还是通过发布订阅的主题路由到该队列，最终都会被多个订阅者轮询处理。

简单代码示例 #

发布端配置

// 初始化发布端
using var publisher = Configure.With(new BuiltinHandlerActivator())
    .Transport(t => t.UseRabbitMq("amqp://localhost", "task_publisher"))
    .Start();

// 发布任务消息
await publisher.Publish(new ProcessingTask { TaskDetails = "生成报表" });

订阅端配置（多个应用实例共用此配置）

// 初始化订阅端，指定共享队列名称
using var subscriber = Configure.With(new BuiltinHandlerActivator())
    .Transport(t => t.UseRabbitMq("amqp://localhost", "shared_task_queue"))
    // 映射消息类型到共享队列
    .Routing(r => r.TypeBased().Map<ProcessingTask>("shared_task_queue"))
    .Start();

// 注册消息处理器
subscriber.Handle<ProcessingTask>(async task =>
{
    Console.WriteLine($"实例 {Environment.MachineName} 处理任务：{task.TaskDetails}");
    // 这里编写你的业务处理逻辑
});

额外说明 #

• 当多个订阅端实例启动后，RabbitMQ会自动采用轮询策略把消息分发给各个实例，确保每条消息只会被一个实例处理。
• 如果你的场景是严格的发布订阅（而非点对点工作队列），只需要确保所有订阅者都绑定到同一个队列来接收主题消息，同样能实现轮询效果。
• 这种模式天然具备负载均衡的能力，能很好地把任务分散到多个应用实例中处理。

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