RabbitMQ消费端限流_mq一次可以消费多少条

消费端限流

Consumer 限流机制

1. 确保ack机制为手动确认。

2. listener-container配置属性

   • perfetch = 1000,表示消费端每次从mq拉取1000条消息来消费，直到手动确认消费完毕后，才会继续拉去下1000条消息。

         <!--定义监听器容器-->
         <rabbit:listener-container connection-factory="connectionFactory" acknowledge="manual" prefetch="1000" >
     1
     2

@Component
public class QosListener implements ChannelAwareMessageListener {

    @Override
    public void onMessage(Message message, Channel channel) throws Exception {
        //1.获取消息
        System.out.println(new String(message.getBody()));

        //2. 处理业务逻辑

        //3. 签收
        channel.basicAck(message.getMessageProperties().getDeliveryTag(),true);

    }
}


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17