单元化路由

最近更新时间: 2026-06-30 15:06:00

操作场景

在单元化的场景下,TDMQ RocketMQ 支持生产者客户端给位于不同单元的消费者发送消息,同时也支持消费者客户端消费来自不同单元的生产者发送的消息。

操作步骤

前提条件

已经在单元化管理平台上完成了架构规划,并将架构推送到了 RocketMQ 并创建了支持单元化的 RocketMQ 集群。

创建单元化路由规则

在左侧导航栏选择 单元化路由 页签,点击 新建路由规则,按照要求填写以下字段:

  • 规则名称:200字符以内,只能包含 中文、数字、字母、“-”和“_”。
  • 规则类型:支持集群内单元路由和跨集群路由。
    • 集群内单元路由:仅能选择支持单元化的 RocketMQ 集群。
    • 跨集群单元路由:需同时选择好源集群和目标集群。
  • Topic:选择需要跨单元路由规则适用的 Topic;对于支持单元化的集群,为了保证各个单元环境的一致性,在任一单元创建了 topic/group 后,会在其他单元创建同样的 topic/group。
  • 路由类型:选择不同类型间的单元的路由,当前支持四种(从 SDU 到 SDU,从 SDU 到 GDU,从 GDU 到 SDU 和从GDU 到 GDU)。
  • 复制起始位置:支持从最新的位点开始复制或者指定时间点开始复制。
  • 是否立即开启任务:如果打开开关,在规则创建完成后就按照当前规则的配置进行跨单元的消息路由。

查看规则详情

路由规则列表页

在单元化路由规则创建完成后,您可以在单元化路由的规则列表页看到新增的单元化路由规则和状态。单击操作列的 启动/暂停可以快速的开启和暂停单元化路由。
运行中的单元化路由无法修改配置信息,如果要修改单元化路由规则的配置,请先暂停单元化路由后。单击操作栏的 编辑,或者进入路由规则详情页,单击“基本信息”右上角的 编辑,修改规则的信息。

路由规则详情页

您可以单击路由规则 ID,进入规则详情页。

在页面的 “基本信息” 部分会展示当前规则的详细信息,如规则的创建时间,路由的起始时间等等。
在页面的 “路由拓扑” 部分会展示当前规则的拓扑概览,因为涉及的单元可能会比较多,因此该拓扑图并未展示所有的单元,仅展示单元类型间的消息路由图示。
在页面的 “单元化路由任务明细” 部分,会详细展示按照当前规则运行的若干子任务。以上图为例,规则的类型为“从 SDU 到 GDU”,在任务明细处,展示了规则在执行时,分为了5个子任务,即从不同的 5 个 SDU 路由到 1 个 GDU 时,同时执行的路由任务。
在页面的 “监控” 部分,您可以查看当前规则在运行时,不同子任务消息路由情况的实时监控。通过选择切换 源单元 和 目标单元,查看不同子任务的详细数据,如消息路由的条数,消息路由的速率(TPS),消息路由失败条数、消息路由延迟 和 平均路由耗时等指标。