多个 SimpleMessageListenerContainer 容器
Multiple SimpleMessageListenerContainer containers
我正在监听 2 个 RabbitMQ 队列。对于 1 个队列,我需要一个消费者来确保一次只处理一条消息。
第二个队列可以在一秒钟内接收大量消息,我需要能够一次消费很多消息。
我有以下代码,它确实按我预期的那样工作。但是我想看看有没有更好的方法。
@Bean
SimpleMessageListenerContainer container(ConnectionFactory connectionFactory,
MessageListenerAdapter listenerAdapter) {
SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
container.setMessageConverter(Jackson2JsonMessageConverter());
container.setQueueNames(QUEUE1);
container.setMessageListener(listenerAdapter);
container.setAdviceChain(new Advice[]{interceptor()});
return container;
}
@Bean
SimpleMessageListenerContainer container1(ConnectionFactory connectionFactory,
MessageListenerAdapter listenerAdapter) {
SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
container.setMessageConverter(Jackson2JsonMessageConverter());
container.setQueueNames(QUEUE2);
container.setMessageListener(listenerAdapter);
container.setAdviceChain(new Advice[]{interceptor()});
container.setConcurrentConsumers(1);
container.setMaxConcurrentConsumers(10);
return container;
}
@Bean
MessageListenerAdapter listenerAdapter() {
return new MessageListenerAdapter(queueService, "consume");
}
你的做法是完全正确的。如果不同的队列需要不同的消费者,就得配置不同的ListenerContainer
。您也可以考虑使用 Spring Integration AMQP Channel Adapters:https://docs.spring.io/spring-integration/docs/5.0.3.RELEASE/reference/html/amqp.html
我正在监听 2 个 RabbitMQ 队列。对于 1 个队列,我需要一个消费者来确保一次只处理一条消息。 第二个队列可以在一秒钟内接收大量消息,我需要能够一次消费很多消息。
我有以下代码,它确实按我预期的那样工作。但是我想看看有没有更好的方法。
@Bean
SimpleMessageListenerContainer container(ConnectionFactory connectionFactory,
MessageListenerAdapter listenerAdapter) {
SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
container.setMessageConverter(Jackson2JsonMessageConverter());
container.setQueueNames(QUEUE1);
container.setMessageListener(listenerAdapter);
container.setAdviceChain(new Advice[]{interceptor()});
return container;
}
@Bean
SimpleMessageListenerContainer container1(ConnectionFactory connectionFactory,
MessageListenerAdapter listenerAdapter) {
SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
container.setMessageConverter(Jackson2JsonMessageConverter());
container.setQueueNames(QUEUE2);
container.setMessageListener(listenerAdapter);
container.setAdviceChain(new Advice[]{interceptor()});
container.setConcurrentConsumers(1);
container.setMaxConcurrentConsumers(10);
return container;
}
@Bean
MessageListenerAdapter listenerAdapter() {
return new MessageListenerAdapter(queueService, "consume");
}
你的做法是完全正确的。如果不同的队列需要不同的消费者,就得配置不同的ListenerContainer
。您也可以考虑使用 Spring Integration AMQP Channel Adapters:https://docs.spring.io/spring-integration/docs/5.0.3.RELEASE/reference/html/amqp.html