【消息队列】RocketMQ 消息的 topic 和 tag 区别以及使用方式

发布时间:2024年01月18日

一、简介

在 RocketMQ 中,消息的 Topic 和 Tag 是用于标识和分类消息的两个关键属性。它们有不同的作用和使用方式。

1、Topic(主题):

  • Topic 是消息的高层分类,用于区分不同类型或业务领域的消息。 一个 RocketMQ 集群中可以有多个 Topic,每个 Topic 包含一组相关的消息。
  • 生产者发送消息时,需要指定消息所属的 Topic。消费者订阅消息时,也需要指定要消费的 Topic。
  • 示例:假设有一个电商系统,可以有不同的 Topic 用于存储订单消息、库存消息等,如 OrderTopic、InventoryTopic。

2、Tag(标签):

  • Tag 是在 Topic 的基础上对消息进行更细粒度的分类,用于进一步筛选和过滤消息。
  • 每个消息可以有一个或多个 Tag。同一个 Topic 下的不同消息可以使用相同的 Tag,也可以使用不同的 Tag。Tag 的使用有助于根据业务需求更灵活地过滤和查询消息。
  • 示例:在 OrderTopic 中,可以有不同的 Tag 表示不同的订单状态,如 Paid、Shipped。

二、什么时候该用 Topic,什么时候该用 Tag?

可以从以下几个方面进行判断:

  • 消息类型是否一致:如普通消息、事务消息、定时(延时)消息、顺序消息,不同的消息类型使用不同的 Topic,无法通过 Tag 进行区分。
  • 业务是否相关联:没有直接关联的消息,如淘宝交易消息,京东物流消息使用不同的 Topic 进行区分;而同样是天猫交易消息,电器类订单、女装类订单、化妆品类订单的消息可以用 Tag 进行区分。
  • 消息优先级是否一致:如同样是物流消息,盒马必须小时内送达,天猫超市 24 小时内送达,淘宝物流则相对会慢一些,不同优先级的消息用不同的 Topic 进行区分
  • 消息量级是否相当:有些业务消息虽然量小但是实时性要求高,如果跟某些万亿量级的消息使用同一个 Topic,则有可能会因为过长的等待时间而“饿死”,此时需要将不同量级的消息进行拆分,使用不同的 Topic

总的来说,针对消息分类,您可以选择创建多个 Topic,或者在同一个 Topic 下创建多个 Tag。但通常情况下,不同的 Topic 之间的消息没有必然的联系,而 Tag 则用来区分同一个 Topic 下相互关联的消息,例如全集和子集的关系、流程先后的关系。

三、使用方式:

1、Topic 的使用方式:

在生产者发送消息时,需要指定消息所属的 Topic。例如,使用 RocketMQ Java SDK 的 send 方法时,需要传递 topic 参数。

在消费者订阅消息时,需要指定要消费的 Topic。例如,使用 RocketMQ Java SDK 的 subscribe 方法时,需要传递 topic 参数。

// 生产者发送消息
Message message = new Message("OrderTopic", "Paid", "Order123", "Hello RocketMQ".getBytes());
SendResult sendResult = producer.send(message);

// 消费者订阅消息
consumer.subscribe("OrderTopic", "*");

2、Tag 的使用方式:

在生产者发送消息时,可以为消息设置 Tag。例如,在 RocketMQ Java SDK 的 Message 对象中设置 tags 属性。

在消费者订阅消息时,可以根据需要过滤特定 Tag 的消息。例如,使用 RocketMQ Java SDK 的 subscribe 方法时,可以传递包含 Tag 的表达式,如 “Paid || Shipped”。

// 生产者发送消息,设置 Tag
Message message = new Message("OrderTopic", "Paid", "Order123", "Hello RocketMQ".getBytes());
SendResult sendResult = producer.send(message);

// 消费者订阅消息,过滤特定 Tag 的消息
consumer.subscribe("OrderTopic", "Paid || Shipped");

总体而言,Topic 用于大致分类消息,而 Tag 用于更具体地标识和过滤消息。使用这两个属性,可以在 RocketMQ 中更好地管理和组织消息。

文章来源:https://blog.csdn.net/weixin_45188218/article/details/135666554
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。