RabbitMQ消费端并发和限流设置_rabbitmq并发消费者数量

rabbitmq专栏： rabbitmq
代码地址： 码云

提高消息处理性能分两种情况，
一是通过提高消息处理程序的并发量，来提高消息的处理能力

二是通过在消费端限流

1. 提高消息处理程序的并发量

通过提高消息处理程序的并发量，来提高消息的处理能力，从而加快消息的处理速度

1.1 配置concurency=“min-max”

最小并发数是5，10代表最大并发

1.2 测试发送20条消息

可以看到上图中确认是5个消费者并发的情况，但下面的deliveryTag却是按顺序的，很显然这不是并发消费的情况，怀疑是机器性能比较好

1.3 测试发送500条消息

刚才用200条测试还是不行，索性发送500条测试，如下图：

可以看到有多个deliveryTag=1打印出来，这说明确实有多个并发的消费者在处理这500个消息了。

2. 限流

消费者端处理并发太大的时候，会影响消息处理端的性能，这时候需要限流

2.1 注入CachingConnectionFactory

	@Autowired
    CachingConnectionFactory cachingConnectionFactory;

    @Bean(name="limitContainerFactory")
    public SimpleRabbitListenerContainerFactory simpleRabbitListenerContainerFactory(){
        SimpleRabbitListenerContainerFactory factory=new SimpleRabbitListenerContainerFactory();
        factory.setConnectionFactory(cachingConnectionFactory);
        factory.setPrefetchCount(3);  // 每次最多拿3个，等这三个处理完之后，再去队列中拿第二批，起到了限流的作用
        return factory;
    }
1
2
3
4
5
6
7
8
9
10

2.2 配置containerFactory = “limitContainerFactory”

2.3 测试

参考视频： https://www.bilibili.com/video/BV13K4y1H7Zh?p=16