RocketMQ中Topic与Tag举例-思维导图
2024-03-27 09:39:11 0 举报AI智能生成
思维导图-RocketMQ中Topic与Tag举例
作者其他创作
大纲/内容
注意事项：
针对不同的tag配置不同的group。
一个消费者集群中，topic和tag是一致的。
为什么集群中的topic和tag要一致?
订阅以集群为单位，如果集群中消费者1订阅了topicA， 消费者2订阅topicB，那么会覆盖，二者只有一个成功订阅。 这是第一个问题
第二个问题就是集群中会进行分摊，比如说消费者1 订阅了topicA ，来了100个topicA的消息， 也会分50个给消费者2 ,但是消费者2订阅的是topicB ，这样就有问题了。
为什么集群中的topic和tag要一致?
订阅以集群为单位，如果集群中消费者1订阅了topicA， 消费者2订阅topicB，那么会覆盖，二者只有一个成功订阅。 这是第一个问题
第二个问题就是集群中会进行分摊，比如说消费者1 订阅了topicA ，来了100个topicA的消息， 也会分50个给消费者2 ,但是消费者2订阅的是topicB ，这样就有问题了。
Topic:
消息类型定义的一级区分标签；
Tag:
一个Topic下面可以细分多个Tag出来；
消息类型定义的二级区分标签；
Group:
仅在消费者端使用，可用于集群下的客户端进行分组标识；
消息类型定义的一级区分标签；
Tag:
一个Topic下面可以细分多个Tag出来；
消息类型定义的二级区分标签；
Group:
仅在消费者端使用，可用于集群下的客户端进行分组标识；
举例:根据消息类型是否一致划分(Topic)
普通消息(Topic)
举例:根据业务场景划分(Topic)
淘宝(Topic_taobao)
举例:根据订单商品类型划分(Tag)
电器类订单(Tag_01)
女装类订单(Tag_02)
化妆品类订单(Tag_03)
食品类订单(Tag_04)
京东(Topic_jingdong)
举例:根据消息优先级划分(Tag)
京东物流配送订单(Tag_11)
第三方物流配送订单(Tag_12)
拼多多(Topic_pinduoduo)
举例:根据消息量级或优先级划分(Tag)
实时类订单(Tag_21)
非实时类订单(Tag_22)
事务消息(Topic)
举例:根据业务类型划分(Topic)
订单类消息(Topic_31)
Queue_01
Queue_02
Queue_03
Queue_04
支付类消息(Topic_32)
物流类消息(Topic_33)
定时(延时)消息(Topic)
Subtopic
Subtopic
顺序消息(Topic)
Subtopic
Subtopic
当使用顺序消费的回调MessageListenerOrderly时，由于顺序消费是要前者消费成功才能继续消费，所以没有RECONSUME_LATER的这个状态，只有SUSPEND_CURRENT_QUEUE_A_MOMENT来暂停队列的其余消费，直到原消息不断重试成功为止才能继续消费
0 条评论
下一页
