java - Spring Boot 中所有 @RabbitListener-s 使用 RabbitMQ 消息

Question

我正在配置一个示例来检查 RabbitMQ 是否可以解决我的问题，但我遇到了问题。

任务:我在网关后面有 3 台机器，只有其中一台具有处理消息所需的数据。我想通过条件检查来解决这个问题。

问题:我尝试配置一些监听器来模拟这种情况，就好像几台机器消费该消息一样。

@RabbitListener(queues = "spring-boot")
public void receiveMessage1(String message) {
    if(canProcess()){
        System.out.println("Received 1 <" + message + ">");
    }
}

@RabbitListener(queues = "spring-boot")
public void receiveMessage2(String message) {
    if(canProcess()){
        System.out.println("Received 2 <" + message + ">");
    }
}

但是，只有一个随机监听器处理该消息。其他人就是不明白。我有一种方法让所有听众都使用它，然后我自己决定哪一个通过“canProcess”方法处理它？

Answer 1

其他监听器不会处理您的消息，因为其中之一已正确使用该消息。 receivemessage 方法结束且没有错误后，rabbit 监听器会在内部将您的消息标记为已处理。它不知道你的流量。因此，解决此问题的方法可能是在无法处理消息时抛出异常，但其修复方法很丑陋 - 它处理消息的方式不是很有效。

我发现这篇文章涵盖了这种类型的架构 https://derickbailey.com/2015/07/22/airport-baggage-claims-selective-consumers-and-rabbitmq-anti-patterns/