如何使用公共交通让 rabbitmq 有多个竞争消费者
How to have multiple competing consumers for rabbitmq using masstransit
我将 MassTransit 库与 RabbitMQ 一起使用。我想将我的消费者扩展到不同的机器上,但是我需要确保他们没有收到相同的消息。我将我的消费者部署在不同的服务器上,但他们收到相同的消息。有办法解决这个问题吗?
当您发布消息时,它会进入消息交换。绑定到消息交换的每个端点交换将获取其消息副本并将其发送到端点队列。
为了实现竞争消费者,您必须对所有应用程序实例使用相同的端点名称。
全部可用in the docs。
我将 MassTransit 库与 RabbitMQ 一起使用。我想将我的消费者扩展到不同的机器上,但是我需要确保他们没有收到相同的消息。我将我的消费者部署在不同的服务器上,但他们收到相同的消息。有办法解决这个问题吗?
当您发布消息时,它会进入消息交换。绑定到消息交换的每个端点交换将获取其消息副本并将其发送到端点队列。
为了实现竞争消费者,您必须对所有应用程序实例使用相同的端点名称。
全部可用in the docs。