天翼云分布式消息服务RocketMQ消费者堆积量

分布式消息服务RocketMQ

简介/价格/文档

天翼云分布式消息服务RocketMQ消费者堆积量

文档简介：

不建议高堆积量的消费，为了预防出现高堆积的情况，建议：边生产边消费，如果消费速度跟不上，增加消费者。消费者一直在线，不要等生产了一段时间再开启消费者，这样会造成消费的堆积。

*产品来源：中国电信天翼云。免费试用咨询热线：400-826-7010，为您提供专业的售前咨询，让您快速了解云产品，助您轻松上云！微信咨询

免费试用、价格特惠

文档详情

不建议高堆积量的消费，为了预防出现高堆积的情况，建议：
边生产边消费，如果消费速度跟不上，增加消费者。
消费者一直在线，不要等生产了一段时间再开启消费者，这样会造成消费的堆积。

相似文档

天翼云分布式消息服务RocketMQ topic、queue的规划
在RocketMQ中，队列数直接影响到消费者实例数的上限，同一消费组消费者实例数的上限=队列数，需要集群消费的情况，需考虑队列数的设置。在RocketMQ中，队列能分布到不同的Broker上，是RocketMQ分布式的基础。
天翼云分布式消息服务RocketMQ Java客户端Pull和Push的选择
Java客户端必须使用Push Consumer （1）使用Pull可以实现的所有场景，均可使用Push实现，并且更简单。（2）Push其实是长轮询的Pull（依然是由客户端发起），在客户端通过配置参数是可以实现流控的，并不会出现服务端的流量压垮客户端的情况。
天翼云分布式消息服务RocketMQ有序消息和无序消息的选择
有序消息。在业务场景允许的情况下，优先选择无序消息，或者在业务能变通的情况下，将有序消息转化为无序消息。无序消息的优点： 1)生产者可以使用多进程、多线程往同一个Topic发送消息，性能更好。
天翼云分布式消息服务RocketMQ消费幂等
(1）RocketMQ无法避免消息重复，原因主要有以下几点： 1）签收的偏移量是定时（每5秒/次）同步到服务端的。 2）为保证消息不丢失，SDK每次提交的总是队列未签收的最小偏移量
天翼云分布式消息服务RocketMQ业务消息设计：Topic 与 Tag
Topic：消息主题，通过 Topic 对不同的业务消息进行分类。 Tag：消息标签，用来进一步区分某个 Topic 下的消息分类，消息队列 RocketMQ 允许消费者按照 Tag 对消息进行过滤，确保消费者最终只消费到他关注的消息类型。

文档中心

全民上云·上云补贴申领

免费试用（限企业）