您好,消费速率受购买的时候的规则引擎TPS限制,实时消息一个连接最大是1000TPS,堆积消息,限流200TPS,如果没有超出TPS,跟客户端回复ACK的速度有关系。
就是平台把一条消息推送给AMQP客户端之后,客户端再回复ACK给平台,平台收到ACK后,就会推送下一条消息给AMQP客户端。
提高消费速率的方法: (1)如果TPS已经达到瓶颈,可以提升企业实例的配置,购买更多的规则引擎TPS。 一个客户端最大是1000TPS,如果已经突破这个瓶颈,可以开启多个客户端,最多64个。 如果没有单个客户端没有达到1000TPS,假设规则引擎TPS是200,就需要提升配置。 规则引擎TPS是这个实例下边 所有的消费限制,比如其中一个消费组用了200,规则引擎TPS如果只有200,那另外的消费组直接就消费不了了。
(2)在TPS没有达到瓶颈时,就是提升客户端回复ACK的速度。 a、首先业务逻辑的处理,不要放在主线程,接收到消息之后,开启线程去处理业务逻辑 b、开启多个客户端,一个客户端消费不过来,就开2个,多个,最多可以64个。 c、提升客户端的性能,包括带宽,CPU,内存等硬性条件。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。