上云无忧 > 文档中心 > 天翼云分布式消息服务RocketMQ集群消费和广播消息
分布式消息服务RocketMQ
天翼云分布式消息服务RocketMQ集群消费和广播消息

文档简介:
广播消费: 注意:使用消费模式,在很多使用场景都会带来影响或限制,在RocketMQ中,应尽量避免使用此消费模式。 在RocketMQ中,消费者有两种不同的方式消费topic中的消息,其中一种是广播消费。
*产品来源:中国电信天翼云。免费试用 咨询热线:400-826-7010,为您提供专业的售前咨询,让您快速了解云产品,助您轻松上云! 微信咨询
  免费试用、价格特惠

广播消费:
注意:使用消费模式,在很多使用场景都会带来影响或限制,在RocketMQ中,应尽量避免使用此消费模式。
在RocketMQ中,消费者有两种不同的方式消费topic中的消息,其中一种是广播消费。在广播消费模式下,一条消息被多个Consumer消费,即使这些Consumer属于同一个Consumer Group,消息也会被Consumer Group中的每个Consumer都消费一次,广播消费中的Consumer Group概念可以认为在消息划分方面无意义。


集群消费:
一个Topic可以被一个或多个Consumer Group消费,每个Consumer Group有自己独立的消费进度,消费进度是保存在服务端的。
一个Consumer Group中的消费者实例可以平均分摊消费消息,做到负载均衡。例如某个Topic有9条消息,其中一个Consumer Group有3个不同的消费者实例(可能是3个进程,或者3台机器),那么每个实例只消费其中的3条消息。
在此消费模式下,可以做到Point-To-Point的消费,也可以做到JMS里面广播消费,能满足绝大部分场景,推荐使用此消费模式。


相似文档
  • 从应用的角度,在RocketMQ中,支持push与pull消费方式。 Push消费: 1)客户端通过注册监听Listener的方式,当有个消息可消费时,API会调用Listener方法,主动推送消息;
  • 无序消息、顺序消息,更多是针对消费者来说的。不同的队列数,配上不同的生产模式、消费者模式,可以适用于无序消费,有序消费的场景。 有序消费的缺点: 发送顺序消息无法利用集群FailOver特性;
  • 有序消息不能跳跃签收,当消费者消费消息失败后,消息队列 RocketMQ 会自动不断进行消息重试(每次间隔时间为 1 秒),这时,应用会出现消息消费被阻塞的情况。因此,建议您使用有序消息时,务必保证应用能够及时监控并处理消费失败的情况,避免阻塞现象的发生。
  • 消费重试次数 消息队列 RocketMQ 默认允许每条消息最多重试 16 次,每次重试的间隔时间如下: 第几次重试 与上次重试的间隔时间 1 10 秒 2 30 秒
  • 1)消息Tag,用于对某个 Topic 下的消息进行分类。 消息队列RocketMQ允许消费者按照 Tag 对消息进行过滤,确保消费者最终只消费到关心的消息类型。 2)针对消息归类,您可以选择创建多个 Topic, 或者在同一个 Topic 下创建多个 Tag。
官方微信
联系客服
400-826-7010
7x24小时客服热线
分享
  • QQ好友
  • QQ空间
  • 微信
  • 微博
返回顶部