我正在运行服务(多个实例)以使用easynetQ在RabbitMQ中使用消息。
我想检查是否已向实例1接收了该消息,并且如果它无法在实例1中进行处理,则实例1应该使用该消息并入队。因此,实例2应该使用它并尝试处理该消息。我正在考虑手动确认消息。
是否有可能使用EasyNetQ实现这一目标?或任何其他解决方案?
这是有关RabbitMQ拓扑如何设计和配置以及与您使用的客户端框架无关的问题。
并且如果您有多个使用者,从同一队列中消费消息,则默认情况下,他们以循环方式获取消息。
在您所说的情况下,如果Instance1无法处理该消息,则它应该对该消息进行nack,在这种情况下,该消息将被排队,并将被传递到下一个实例。