本文通过介绍什么是全球消息路由以及全球消息路由任务管理，以便您按需同步消息，实现数据跨地域（Region）的一致性。

什么是全球消息路由

消息队列 RocketMQ 版的全球消息路由功能常用于不同地域之间同步所有或按过滤规则（例如通过特定的 Tag 过滤）过滤后的消息，保证地域之间的数据一致性。该功能依托阿里云优质基础设施实现的高速通道专线（高速通道无需另行开通），高效地实现不同地域之间的消息同步复制。具体实现如下图所示。

全球路由
注意
  • 不支持传递路由，例如地域 A 到地域 B 再到地域 C，地域 A 的消息不会经过地域 B 再路由到地域 C，如有需要请直接创建地域 A 到地域 C 的路由。
  • 目前仅公网地域不支持全球消息路由功能，其他地域均支持。
  • 源 Topic 和目标 Topic 的消息类型需保持一致，如果源 Topic 是普通消息，则同步到的目标 Topic 也应是普通消息。
  • 考虑到需要同步的消息量以及网络带宽瓶颈，消息同步可能会产生一定的时间延迟，即消息到达目标 Topic 的时间会晚于该消息进入源 Topic 的时间。

创建全球消息路由任务

您可以登录消息队列 RocketMQ 版控制台，根据业务需求创建跨地域的全球消息同步任务。

前提条件

  • 创建全球消息路由任务前，请确保需同步消息的源地域和目标地域支持全球消息路由功能。
  • 源实例和源 Topic 以及目标实例和目标 Topic 已创建并可用，且源 Topic 和目标 Topic 的消息类型保持一致。

创建实例和 Topic 的具体步骤，请根据您所使用的账号类型参见主账号快速入门或子账号快速入门中的创建资源部分。

操作步骤

请按照以下步骤创建全球消息路由任务：

  1. 登录消息队列 RocketMQ 版控制台。在顶部导航栏，选择地域，如华北1（杭州）。
  2. 在左侧导航栏，单击全球消息路由。
  3. 在全球消息路由页面的右上方，单击创建任务按钮。
  4. 在创建任务对话框，填写以下信息后，单击确认。您需填写的信息如下表所示。
参数 说明
源地域 选择需要同步的消息所属 Topic 的实例所在地域
源实例 选择需要同步的消息所属 Topic 所在实例
源Topic 输入需要同步的消息所属 Topic 名称
目标地域 选择消息将被同步到的 Topic 所属实例所在地域
目标实例 选择消息将被同步到的 Topic 所属实例
目标Topic 输入消息将被同步到的 Topic 名称
起始同步位点 选择从源 Topic 中的消息队列的哪个位置开始进行消息同步，即从这个位置之后进入队列的消息都会被同步到目标 Topic。目前仅支持最大位点，即从队列当前最新的一条消息开始同步。
过滤规则 输入过滤规则，按照该规则过滤后的消息才会被同步。您可选择按 Tag 过滤，直接输入 Tag 名即可，例如“TagA”。具体过滤方法请参见消息过滤。
描述 输入对该同步任务的具体描述或备注，以作区分和记录。

任务创建完成后，您可以在全球消息路由页面的任务列表中看到刚才创建的任务。

说明 全球消息路由任务创建成功后，该任务将处于待运行状态，您需手动启动该任务。

您可以在全球消息路由页面搜索、启停、查看、删除任务，也可为任务编辑过滤规则。

搜索任务

在全球消息路由，在源和目标两栏按需输入源地域、源实例、源 Topic、目标地域、目标实例、目标 Topic 后，单击搜索按钮，即可查询到符合搜索条件的任务。

启停任务

在全球消息路由页面的任务列表中，找到需要启停的任务，在其操作列单击开始或停止图标，启动或停止该任务。

  • 任务启动后，该任务的状态会切换至运行中。
  • 任务停止后，该任务的状态会切换至已停止。

删除任务

前提条件：删除任务前需要先停止任务。

在全球消息路由页面的任务列表中，找到需要删除的任务，在其操作列单击删除，即可删除该任务。

任务被删除后将不会再在搜索结果中展示。

查看详情

在全球消息路由页面的任务列表中，找到需要查看的任务，在其操作列单击查看详情图标，即可查看该任务的任务详情和消息详情。同时，您还可以根据需求，编辑过滤规则。

任务详情页的关键字段的说明如下表所示。

参数 说明
任务状态 任务状态可以是待运行、运行中、已停止。
消息同步 TPS 每分钟统计一次消息同步的 TPS 值；TPS 即平均每秒传输的消息数量
消息延迟 当前同步到的位点和最新消息位点之间的时间差
消息堆积量 当前还没有来得及同步的消息数量
最新同步时间 最近一次消息同步发生的时间

编辑过滤规则

前提条件：编辑过滤规则，需先停止任务。

在任务详情区域的过滤规则一栏，单击编辑图标，即可对过滤规则进行修改。