test rabbit exclusive

使用RabbitMQ和Spring Integration(Java DSL)串行处理消息如果您需要使用RabbitMQ串行处理消息，并使用一组侦听器处理消息，我见过的最好方法是在每个侦听器上使用1个线程处理消息的侦听器上使用标志。独占消费者标志确保只有1个消费者可以从特定队列读取消息，并且该消费者上的1个线程确保消息被串行处理。但是有一个问题，我稍后会讲到。让我用基于Spring Boot和Spring Integration的RabbitMQ消息消费者来演示这种行为。首先，这是使用Spring java配置建立队列的配置，注意由于这是一个Spring Boot应用，当Spring-amqp库加入依赖列表时，它会自动创建一个RabbitMQ连接工厂： @Configuration public class RabbitConfig