什么是消费端限流，这个一种保护消费者的手段，假如说，现在是业务高峰期了，消息有大量堆积，导致MQ消费需要不断的进行消息消费，很容易被打挂，甚至重启之后还是会被大量消息涌入，继续被打挂。

为了解决这个问题,RabbitMQ提供了basicQos的方式来实现消费者端限流。我们可以在消费者指定最大的未确认消息数，当达到这个限制时，RabbitMQ将不再推送新的消息给消费者，直到有一些消息得到确认。

想要实现这个功能，首先需要把自动提交关闭。

 接着进行限流配置：

如以上配置，可以实现消费者在处理一条消息后，才会获取下一条消息。

然后再在消费者处理完一条消息之后，手动发送确认消息给到RabbitMQ，这样就可以拉取下一条消息了；

完整代码：