作为一个练习,我试图找到一个实现竞争消费者的例子。
许多生产者 -> MSMQueue <- 竞争消费者
到目前为止,我没有找到任何关于如何实现这一点的文档。我第一次尝试弄清楚在 MassTransit 或 NServiceBus 中是如何实现的,但多次间接失败。
任何帮助将不胜感激。
作为一个练习,我试图找到一个实现竞争消费者的例子。
许多生产者 -> MSMQueue <- 竞争消费者
到目前为止,我没有找到任何关于如何实现这一点的文档。我第一次尝试弄清楚在 MassTransit 或 NServiceBus 中是如何实现的,但多次间接失败。
任何帮助将不胜感激。
借助 MassTransit 和 MSMQ,您可以使用Distributor组件实现此目的。
请注意,如果您将 MassTransit 与RabbitMQ而不是 MSMQ 一起使用,您可以在不使用 Distributor 的情况下实现竞争消费者场景,只需为所有消费者设置相同的队列名称即可。如果您可以在 MSMQ 和 RabbitMQ 之间进行选择,我会选择 RabbitMQ,因为您可以获得更好的管理工具和 SSL 加密,并且它也可以很好地与防火墙配合使用。
MassTransit Google Groups 论坛上对此进行了一些讨论。