工作随笔——rabbitmq的多线程监听（Springboot）

一、需求

使用rabbitmq转发大量消息，提高效率。由于springboot中rabbitmq默认是单线程监听，所以需要我们加以配置。

二、方案

配置rabbitmq多线程监听，提供SimpleRabbitListenerContainerFactory类的bean，为数据量大的队列指定这个bean。
设置多线程批量处理。在任意配置类中，提供这个bean。（注意配置类中的Listener会覆盖配置文件中的配置）

    // 配置批量监听容器
    @Bean("batchQueueRabbitListenerContainerFactory")
    public SimpleRabbitListenerContainerFactory batchQueueRabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
     
        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        //设置批量
        factory.setBatchListener(true);
        factory.setConsumerBatchEnabled(true);//设置BatchMessageListener生效
        factory.setBatchSize(1000);//设置监听器一次批量处理的消息数量
        factory.setConcurrentConsumers(10);  //设置线程数
        factory.setMaxConcurrentConsumers(10); //最大线程数
        return factory;
    }

为队列指定这个bean

    // 创建消费者，比较两者时间
    @RabbitListener(queues = "xiaomi",containerFactory = "batchQueueRabbitListenerContainerFactory")
    public void xiaomiHandler(List<Message> messages) throws IOException, ClassNotFoundException {
     
        log.info("xiaomiHandler>>>>>" + messages.size());
    }

三、测试

确实是10个线程并发监听。