RabbitMQ消高级篇七 消费端限流息中间件技术精讲14

消费端的限流？

场景：

假设，我们mq服务器上有上万条未处理的消息，我们随便打开一个消费者客户端，会出现什么样的情况呢？

大量的消息瞬间被全部推送给了这个消费者，但是单个消费者是无法消费这么多消息的。会导致系统崩溃，线上故障发生。

Rabbit MQ提供了一种qos(服务直连保证)功能，即在非自动确认消息的前提下，如果一定数目的消息(通过基于consumer或者是channel设置Qos的值)未被确认前，不进行消费新的消息。这样就保证了大量消息瞬间被推送时候，不至于拖垮服务。

方法：

Void BasiceQos(unit prefetchSize,ushort prefetchCount, boole global);

说明：