通知所有消费者消息

Question

我们正在使用 Rebus 4.2.1 和 RabbitMQ

我们想要实现的是让三个（或更多）实例上的处理程序都对同一消息做出反应。

据我了解（这可能是错误的）- .Publish 在 IBus 接口上应该完全做到这一点（我们一直在 MSMQ 上运行）。

RabbitMQ 的工作方式有什么我遗漏的吗？

（编辑：我认为 RabbitMQ 中使用的术语是“扇出”式消息）

EDIT2：mookid8000 让我走上了正轨——问题是每个副本都要求相同的队列。一旦我做到了这一点 - 一切都开始按预期（和预期）工作。

Answer 1

使用 Rebus + RabbitMQ，这非常简单，因为 RabbitMQ 原生支持基于主题的发布/订阅消息传递。

在每个订阅者中，您只需调用

await bus.Subscribe<YourEvent>();

这将使Rebus从你的事件类型中生成一个主题字符串，然后将它绑定到订阅者的输入队列，然后在你的发布者中

await bus.Publish(new YourEvent(...));

然后每个订阅者将在其输入队列中获得事件的副本。

在幕后，Rebus 使用 RabbitMQ 的“主题交换”交换类型来完成这项工作。