RocketMQ中Topic与Tag举例-思维导图

针对不同的tag配置不同的group。

Topic:消息类型定义的一级区分标签；Tag:一个Topic下面可以细分多个Tag出来；消息类型定义的二级区分标签；Group:仅在消费者端使用，可用于集群下的客户端进行分组标识；

注意事项：

举例:根据消息类型是否一致划分(Topic)

举例:根据业务场景划分(Topic)

举例:根据订单商品类型划分(Tag)

电器类订单(Tag_01)

女装类订单(Tag_02)

化妆品类订单(Tag_03)

食品类订单(Tag_04)

淘宝(Topic_taobao)

举例:根据消息优先级划分(Tag)

京东物流配送订单(Tag_11)

第三方物流配送订单(Tag_12)

京东(Topic_jingdong)

举例:根据消息量级或优先级划分(Tag)

实时类订单(Tag_21)

非实时类订单(Tag_22)

拼多多(Topic_pinduoduo)

普通消息(Topic)

举例:根据业务类型划分(Topic)

Queue_01

Queue_02

Queue_03

Queue_04

订单类消息(Topic_31)

支付类消息(Topic_32)

物流类消息(Topic_33)

事务消息(Topic)

Subtopic

定时(延时)消息(Topic)

当使用顺序消费的回调MessageListenerOrderly时，由于顺序消费是要前者消费成功才能继续消费，所以没有RECONSUME_LATER的这个状态，只有SUSPEND_CURRENT_QUEUE_A_MOMENT来暂停队列的其余消费，直到原消息不断重试成功为止才能继续消费

顺序消息(Topic)

RocketMQ中Topic与Tag举例