上云无忧 > 文档中心 > 天翼云分布式消息服务RocketMQ topic、queue的规划
分布式消息服务RocketMQ
天翼云分布式消息服务RocketMQ topic、queue的规划

文档简介:
在RocketMQ中,队列数直接影响到消费者实例数的上限,同一消费组消费者实例数的上限=队列数,需要集群消费的情况,需考虑队列数的设置。 在RocketMQ中,队列能分布到不同的Broker上,是RocketMQ分布式的基础。
*产品来源:中国电信天翼云。免费试用 咨询热线:400-826-7010,为您提供专业的售前咨询,让您快速了解云产品,助您轻松上云! 微信咨询
  免费试用、价格特惠

在RocketMQ中,队列数直接影响到消费者实例数的上限,同一消费组消费者实例数的上限=队列数,需要集群消费的情况,需考虑队列数的设置。
在RocketMQ中,队列能分布到不同的Broker上,是RocketMQ分布式的基础。Queue分布在Broker中,则能使用Broker的资源,包括存储、IO等,一般情况下,分布在某个Broker上的Queue比例越大,则占用此Broker的资源越多,Topic中的Queue分布到的Broker数量越多,则性能越好、存储越大。若Broker的所在机器性能不同,可以通过调整Queue数量,达到资源调优的目的,在应用设计时,需要充分利用上述特性。

在Push消费模式中,API会默认为每个队列预拉取消息1000条,若队列数过大、或者单条消息包体过大,则需要考虑设置减少预拉数量,防止预拉消息过大导致内存溢出。


相似文档
  • Java客户端必须使用Push Consumer (1)使用Pull可以实现的所有场景,均可使用Push实现,并且更简单。 (2)Push其实是长轮询的Pull(依然是由客户端发起),在客户端通过配置参数是可以实现流控的,并不会出现服务端的流量压垮客户端的情况。
  • 有序消息。 在业务场景允许的情况下,优先选择无序消息,或者在业务能变通的情况下,将有序消息转化为无序消息。 无序消息的优点: 1)生产者可以使用多进程、多线程往同一个Topic发送消息,性能更好。
  • (1)RocketMQ无法避免消息重复,原因主要有以下几点: 1)签收的偏移量是定时(每5秒/次)同步到服务端的。 2)为保证消息不丢失,SDK每次提交的总是队列未签收的最小偏移量
  • Topic:消息主题,通过 Topic 对不同的业务消息进行分类。 Tag:消息标签,用来进一步区分某个 Topic 下的消息分类,消息队列 RocketMQ 允许消费者按照 Tag 对消息进行过滤,确保消费者最终只消费到他关注的消息类型。
  • RocketMQ 里的一个 Consumer Group 代表一个 Consumer 群组。对于大多数分布式应用来说,一个 Consumer Group 下通常会有多个 Consumer 实例。订阅关系一致指的是同一个 Consumer Group 下所有 Consumer 实例的处理逻辑必须完全一致,一旦订阅关系不一致,消息消费的逻辑就会混乱,甚至导致消息丢失。
官方微信
联系客服
400-826-7010
7x24小时客服热线
分享
  • QQ好友
  • QQ空间
  • 微信
  • 微博
返回顶部