消费端限流

如果业务促销,流量暴增,可能出现发送端和消费端性能不一致, 瞬间,大量消息同时推给消费端,导致消费端崩溃。

RabbitMQ提供了消费端限流机制。 限制消息推送速度,保证消费端服务稳定。

如果是微服务,不同物理机部署相同的服务,由于硬件的处理能力差异,最终导致处理慢的机器, 就挂了。

qos(服务质量保证) 不适用自动确认,确保在一定数量的消息未被确认前,不消费新消息。

参数配置
prefetchCount 一个消费端最多推送多少个未确认的消息(如果设置3,意味着如果有3条未被确认,那么就不推送了)
global设置为true 针对整个消费端限流;false针对当前channel
prefetchSize 0 单个消息大小限制,一般设置为0

后2个rabbitmq还没有实现,只是amqp协议里面的

RabbitMQ该如何学习

计算机学科是一个要求动手能力很强的学科,通过实战,用实际项目,把知识牢牢掌握住。

《Go语言+RabbitMQ实战课》-课程目录海报 《Go+RabbitMQ课程》-优惠券
添加微信 公众号更多内容
wechat gzh