SpringAMQP 消息容器 - SimpleMessageListenerContainer

SimpleMessageListenerContainer 即简单消息监听容器。

• 这个类很是的强大，咱们能够对他进行不少的设置，用对于消费者的配置项，这个类均可以知足。它有监听单个或多个队列、自动启动、自动声明功能。

• 它能够设置事务特性、事务管理器、事务属性、事务并发、是否开启事务、回滚消息等。可是咱们在实际生产中，不多使用事务，基本都是采用补偿机制。

• 它能够设置消费者数量、最小最大数量、批量消费。

• 它能够设置消息确认和自动确认模式、是否重回队列、异常捕获 Handler 函数。

• 它能够设置消费者标签生成策略、是否独占模式、消费者属性等。

• 它还能够设置具体的监听器、消息转换器等等。

  注意: SimpleMessageListenerContainer 能够进行动态设置，好比在运行中的应用能够动态的修改其消费者数量的大小、接收消息的模式等。

不少基于 rabbitMQ 的自制定化后端管控台在进行设置的时候，也是根据这一去实现的。因此能够看出 SpringAMQP 很是的强大。

代码示例：

代码地址：  https://github.com/hmilyos/rabbitmqdemo.git  rabbitmq-api 项目下
复制代码

在上一节的 SpringAMQP 之 RabbitTemplate 的 RabbitMQConfig 原有代码的基础上加上

@Bean   //connectionFactory 也是要和最上面方法名保持一致
    public SimpleMessageListenerContainer messageContainer(ConnectionFactory connectionFactory) {
        SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(connectionFactory);
        container.setQueues(queue001(), queue002(), queue003());    //监听的队列
        container.setConcurrentConsumers(1);    //当前的消费者数量
        container.setMaxConcurrentConsumers(5); //  最大的消费者数量
        container.setDefaultRequeueRejected(false); //是否重回队列
        container.setAcknowledgeMode(AcknowledgeMode.AUTO); //签收模式
        container.setExposeListenerChannel(true);
        container.setConsumerTagStrategy(new ConsumerTagStrategy() {    //消费端的标签策略
            @Override
            public String createConsumerTag(String queue) {
                return queue + "_" + UUID.randomUUID().toString();
            }
        });


        container.setMessageListener(new ChannelAwareMessageListener() {
            @Override
            public void onMessage(Message message, Channel channel) throws Exception {
                String msg = new String(message.getBody());
                log.info("----------消费者: " + msg);
            }
        });
        return container;
    }
复制代码

单元测试里面仍是继续使用上一次的代码

@Test
    public void testSendMessage2() throws Exception {
        //1 建立消息
        MessageProperties messageProperties = new MessageProperties();
        messageProperties.setContentType("text/plain");
        Message message = new Message("mq 消息1234 --spring.abc".getBytes(), messageProperties);

        rabbitTemplate.send("topic001", "spring.abc", message);

        rabbitTemplate.convertAndSend("topic001", "spring.amqp", "hello object message send! -spring.amqp");
        rabbitTemplate.convertAndSend("topic002", "rabbit.abc", "hello object message send! -rabbit.abc");
    }
复制代码

运行 test 看日志，绑定的三个队列都能被消费

自此，SimpleMessageListenerContainer 的简单使用就介绍完毕， container 里面还有不少方法等着你来使用，我就不继续介绍了。