不同队列的多个侦听器 - Spring 兔子

Question

我有多个模块，它们通过消息队列相互通信 (Spring Rabbit)。一些模块产生消息，而另一些模块使用它们。但是，单个模块可以监听不同的队列，我在列表中有一个队列名称列表，所以我为每个队列名称创建了一个 SimpleMessageListenerContainer，如下所示。

public void build() {
    for (String queueName: queues) {
        SimpleMessageListenerContainer listenerContainer = new SimpleMessageListenerContainer();
        listenerContainer.setConnectionFactory(connectionFactory());
        listenerContainer.setQueueNames(queueName);
        listenerContainer.setMessageListener(listenerAdapter());
    }
}

@Bean
private MessageListenerAdapter listenerAdapter() {
    return new MessageListenerAdapter(new MessageListener() {
        @Override
        public void onMessage(Message message) {
            System.out.println(message.getBody());
        }
    }, "onMessage");
}

此实现对我不起作用，消费者未在队列中注册，并且在执行期间抛出任何错误或异常。

注意：我使用的是Spring，并且仅限于不使用@RabbitListener

等注解

Answer 1

当您手动声明 SimpleMessageListenerContainer 时，而不是作为 beans，您还必须确保应用程序上下文回调和生命周期：

listenerContainer.setApplicationContext()
listenerContainer.setApplicationEventPublisher()
listenerContainer.afterPropertiesSet()
listenerContainer.start()

不要忘记在申请结束时 stop() 和 destroy() 它们。

不同队列的多个侦听器 - Spring 兔子

Multiple Listeners for different queues - Spring Rabbit

java

spring

rabbitmq

spring-amqp

spring-rabbit