RabbitMQ消费端限流

￡神魔★判官ぃ 2024-03-24 11:29 93阅读 0赞

### RabbitMQ消费端限流 ###

![在这里插入图片描述][df0a4170766c44d58c0d42a5cde83b43.png]  
**配置yml**  
Consumer 限流机制

1.  确保消息被确认。不确认是不继续处理其他消息的
2.  prefetch: 1,表示消费端每次从mq拉去一条消息来消费,直到手动确认消费完毕后,才会继续拉取下一条消息。

spring:
      rabbitmq:
        host: 192.168.121.140
        port: 5672
        username: admin
        password: admin
        virtual-host: /
        listener:
          simple:
            #表示手动确认
            acknowledge-mode: manual
            prefetch: 2

生产者先生产10条数据  
![在这里插入图片描述][92d8a2bde91f4fdc84bf72542514f13a.png]  
**添加手动签收方法 ，这样就可以确认消费限流**

/**
     * Consumer 限流机制
     *  1. 确保消息被确认。不确认是不继续处理其他消息的
     *  2. prefetch: 1,表示消费端每次从mq拉去一条消息来消费,直到手动确认消费完毕后,才会继续拉取下一条消息。
     */
    @Component
    public class QosListener implements ChannelAwareMessageListener {
        
    
        @RabbitListener(queues = "boot_queue100")
        @Override
        public void onMessage(Message message, Channel channel) throws Exception {
        
            Thread.sleep(1000);
            //1.获取消息
            System.out.println(new String(message.getBody()));
            //签收
            channel.basicAck(message.getMessageProperties().getDeliveryTag(),true);
        }
    }

Unacked一直是2
    接下来就是
    8 2 10
    7 2 9
    6 2 8

![消费][3be91f8313f94af7a2cd9a4a83079028.png]

### 消费端限流小结 ###

*  prefetch 属性设置消费端一次拉取多少条消息
 *  消费端的必须确认才会继续处理其他消息。

[df0a4170766c44d58c0d42a5cde83b43.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/e13fcde9fb46434fac60de77ac155e53.png
[92d8a2bde91f4fdc84bf72542514f13a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/d553a8002d8041e7ae23694ad4ad71af.png
[3be91f8313f94af7a2cd9a4a83079028.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/002932372c3b4167a37c312c6f6b341f.png