上云无忧 > 文档中心 > 腾讯云消息队列 RocketMQ - Topic 管理
消息队列 RocketMQ 版
腾讯云消息队列 RocketMQ - Topic 管理

文档简介:
操作场景: Topic 是 TDMQ RocketMQ 版中的核心概念。Topic 通常用来对系统生产的各类消息做一个集中的分类和管理,例如和交易的相关消息可以放在一个名为 “trade” 的 Topic 中,供其他消费者订阅。
*此产品及展示信息均由腾讯云官方提供。免费试用 咨询热线:400-826-7010,为您提供专业的售前咨询,让您快速了解云产品,助您轻松上云! 微信咨询
  免费试用、价格特惠

操作场景

Topic 是 TDMQ RocketMQ 版中的核心概念。Topic 通常用来对系统生产的各类消息做一个集中的分类和管理,例如和交易的相关消息可以放在一个名为 “trade” 的 Topic 中,供其他消费者订阅。 在实际应用场景中,一个 Topic 往往代表着一个业务聚合,由开发者根据自身系统设计、数据架构设计来决定如何设计不同的 Topic。
本文档可以指导您使用 TDMQ RocketMQ 版时,利用 Topic 对消息进行分类管理。

操作步骤

创建 Topic

1. 登录 RocketMQ 控制台
2. 在左侧导航栏选择 Topic 管理页签,选择好地域和集群后,单击新建进入创建 Topic 页面。
3. 在新建 Topic 对话框中,填写以下信息。
Topic 名称:填写 Topic 名称(创建后不可修改),3-64个字符,只能包含字母、数字、“-”及“_”
类型:选择消息类型,包括:普通、顺序消息、延迟消息和事务消息(关于消息类型的说明,请参见 消息类型)。
分区数:选择分区数量,最大支持16分区。多分区可以提高单 Topic 的生产消费性能,但是无法保证顺序性。
Topic 说明:填写 Topic 的说明信息,最长128字符。
4. 单击提交,在 Topic 列表中即可看见创建好的 Topic。

发送测试消息

RocketMQ 控制台支持手动发送消息,在控制台进行相应的操作即可实现消息发送给指定的 Topic。
1. Topic 管理列表中,单击目标Topic 操作栏的发送测试消息
2. 在弹窗中输入消息 Key,消息 Tag 和消息内容,单击发送

查看订阅的 Group

1. Topic 管理列表中,单击目标 Topic 的“ID”。
2. 页面跳转到 Group 列表,展示订阅该 Topic 的 Group 信息。

查询 Topic

您可以在 Topic 管理列表页右上角的搜索框中,通过 Topic 名称进行搜索查询,TDMQ RocketMQ 版将会模糊匹配并呈现搜索结果。

编辑 Topic

1. Topic 管理列表中,找到需要编辑的 Topic ,单击操作栏中的编辑

2. 在弹出的对话框中可以对 Topic 的说明进行编辑。
3. 单击提交即完成对 Topic 的编辑。

删除 Topic

批量删除:Topic 管理列表中,勾选所有需要删除的 Topic,单击左上角的批量删除,在弹出的提示框中,单击删除,完成删除。
单个删除:Topic 管理列表中,找到需要删除的 Topic,单击操作列的删除,在弹出的提示框中,单击删除,完成删除。


注意:
删除了 Topic 之后也会清除该 Topic 下积累的未消费消息,请谨慎执行。

元数据导入导出

元数据导出

您可以通过 Topic 列表页右上角的

按钮直接导出元数据,元数据的导出格式为 .xlsx 格式的表格文件。

元数据导入

如果您需要将一个集群的 Topic 信息载入到另一个集群内,在导出元数据后,您可以击 Topic 列表页右上角的

按钮,将 Topic 数据导入到指定的命名空间下。
相似文档
  • 操作场景: Group 用于标识一类 Consumer,这类 Consumer 通常消费同一类消息,且消息订阅的逻辑一致。 该任务指导您使用消息队列 TDMQ RocketMQ 版时在控制台上创建,删除和查询 Group。
  • 操作场景: TDMQ RocketMQ 支持监控您账户下创建的资源,包括集群、Topic、Group 等,您可以根据这些监控数据,分析集群的使用情况,针对可能存在的风险及时处理。同时您也可以对监控项设置报警规则,以便数据异常时收到报警消息,及时处理风险,保障系统的稳定运行。
  • 当一条消息从生产者发送到 TDMQ RocketMQ 版服务端,再由消费者进行消费,TDMQ RocketMQ 版会完整记录这条消息中间的流转过程,并以消息轨迹的形式呈现在控制台。 消息轨迹记录了消息从生产端到 TDMQ RocketMQ 版服务端,最后到消费端的整个过程,包括各阶段的时间(精确到微秒)、执行结果、生产者 IP、消费者 IP 等。
  • 为了给业务处理业务失败,给消息消费失败的情况兜底,保证消息生命周期的完整,RocketMQ 实现了消费失败后重试的策略。 如果您使用的是 RocketMQ 4.x 客户端,消息的重试次数以您在客户端内设置消息重试次数为准。
  • 操作场景: 死信队列是一种特殊的消息队列,用于集中处理无法被正常消费的消息的队列。当消息在达到一定重试次数后仍未能被正常消费,TDMQ RocketMQ 版会判定这条消息在当前情况下无法被消费,将其投递至死信队列。
官方微信
联系客服
400-826-7010
7x24小时客服热线
分享
  • QQ好友
  • QQ空间
  • 微信
  • 微博
返回顶部