第四章 （7）简单消息监听容器SimpleMessageListenerContainer

简单消息容器SimpleMessageListenerContainer

• 这个类非常强大，我们可以对它进行很多设置，对于消费者的匹配项，这个类都可以满足
• 监听队列（多个队列）、自动启动、自动声明功能
• 设置事物特性、事物管理器、事物属性、事物容量（并发）、是否开启事物、回滚消息等
• 设置消费者数量、最小最大数量、批量消费
• 设置消息确认和自动确认模式、是否重回队列、异常捕获handler函数
• 设置消费者标签生成策略、是否独占模式、消费者属性等
• 设置具体的监听器、消息转换器等等
• 注意SimpleMessageListenerContailer可以进行动态设置，比如在运行中的应用可以动态的修改其消费者数量的大小、接收消息模式等
• 很多基于RabbitMQ的自制定化后端管控台进行动态设置的时候，也是根据这一特性去实现的。所以可以看出SpringAMQP非常强大

代码实现

@Bean
public SimpleMessageListenerContainer messageListenerContainer(ConnectionFactory connectionFactory){
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory);
    // 监听队列
    container.setQueues(queue001(), queue02(), queue003(), queue_image(), queue_pdf());
    container.setConcurrentConsumers(1);
    container.setMaxConcurrentConsumers(5);
    container.setDefaultRequeueRejected(false);
    container.setAcknowledgeMode(AcknowledgeMode.AUTO);
    container.setExposeListenerChannel(true);
    container.setConsumerTagStrategy(queue -> queue + "_" + UUID.randomUUID().toString());
    container.setMessageListener(new ChannelAwareMessageListener() {
        @Override
        public void onMessage(Message message, Channel channel) throws Exception {
            String msg = new String(message.getBody());
            System.err.println("--------消费者：" + msg);
        }
    });

    return container;
}

注意：本文归作者所有，未经作者允许，不得转载