本文介绍什么是全球消息路由以及如何管理全球消息路由任务,以便您按需同步消息,实现数据跨地域(Region)的一致性。
什么是全球消息路由
消息队列RocketMQ版的全球消息路由功能常用于同步不同地域之间的消息,保证地域之间数据的一致性。您可以同步所有消息,也可以按过滤规则,例如通过指定的Tag将消息过滤之后再进行同步。该功能依托阿里云优质基础设施实现的高速通道专线(高速通道无需另行开通),高效地实现不同地域之间的消息同步复制。具体实现如下图所示。

计费影响
全球消息路由为消息队列RocketMQ版的高级功能,使用该功能会带来额外的费用,包含消息传输费用和任务资源占用费用。更多信息,请参见全球消息路由定价详情。
地域限制
- 目前仅公网地域不支持全球消息路由功能,其他地域均支持。
- 全球消息路由功能不支持传递路由,例如地域A到地域B再到地域C,地域A的消息不会经过地域B再路由到地域C,如有需要请直接创建地域A到地域C的路由。
- 为加强网络信息安全管理,提高数据安全性,全球消息路由功能不支持跨境及跨国传输,具体规则如下:
说明 如果您的业务需要跨境或跨国数据传输,建议您提交工单咨询并定制合规方案。
- 中国内地的各地域之间可以同步消息,中国内地不支持和中国香港及海外地区的所有地域同步消息。
- 中国香港地域仅支持在本地域内同步消息,不支持和中国内地及海外地区所有地域同步消息。
- 海外地区仅支持在同一国家内不同地域间同步消息,各国家之间的地域不支持同步消息。
注意事项
- 源Topic和目标Topic的消息类型需保持一致,如果源Topic是普通消息,则同步到的目标Topic也应是普通消息。
- 考虑到需要同步的消息量以及网络带宽瓶颈,消息同步可能会产生一定的时间延迟,即消息到达目标Topic的时间会晚于该消息进入源Topic的时间。
创建全球消息路由任务
您可以登录消息队列RocketMQ版控制台,根据业务需求创建跨地域的全球消息同步任务。
前提条件
- 创建全球消息路由任务前,请确保需同步消息的源地域和目标地域支持全球消息路由功能。
- 源实例和源Topic以及目标实例和目标Topic已创建并可用,且源Topic和目标Topic的消息类型保持一致。
创建实例和Topic的具体步骤,请根据您所使用的协议类型参见创建TCP协议资源和创建HTTP协议资源。
操作步骤
其他操作

搜索任务
在全球消息路由页面,您可根据源地域、源实例ID、源Topic、目标地域、目标实例ID、目标Topic查询任务。

启停单项任务
在全球消息路由页面的任务列表中,找到需要启停的任务,在其操作列选择 或 来启用或停用规则。

- 任务启动后,该任务的状态会切换至已启用。
- 任务停止后,该任务的状态会切换至已停用。
批量启停任务
消息队列RocketMQ版支持批量启停任务,当您的业务使用了多个消息路由任务,为了提高维护操作效率,您可以使用批量启停功能一键启停多个任务。
在全球消息路由页面的任务列表中,选中需要批量启停的多个任务,单击列表上方的批量启用规则或批量停用规则,然后在弹出的提示对话框中的单击确认。

- 批量启用规则后,所有被选中的任务的状态会切换至已启用。
- 批量停用任务后,所有被选中的任务的状态会切换至已停用。
删除任务
前提条件:删除任务前需要先停止任务。
在全球消息路由页面的任务列表中,找到需要删除的任务,在其操作列选择 ,即可删除该任务。
任务被删除后将不会在任务列表中展示。
查看任务详情
在全球消息路由页面的任务列表中,找到需要查看的任务,在其操作列单击详情,即可查看该任务的任务详情和消息详情,以及编辑过滤规则。

全球消息路由详情页面的关键字段的说明如下表所示。
参数 | 说明 |
---|---|
任务状态 | 任务状态可以是未启用、已启用、已停用。 |
消息同步TPS | 每分钟统计一次消息同步的TPS值;TPS即平均每秒传输的消息数量。 |
消息延迟 | 当前同步到的位点和最新消息位点之间的时间差。 |
消息堆积量 | 当前还没有来得及同步的消息数量。 |
最新同步时间 | 最近一次消息同步发生的时间。 |
编辑过滤规则
前提条件:编辑过滤规则,需先停止任务。
在基础信息区域的过滤规则一栏,单击编辑图标,即可对过滤规则进行修改。
您可直接输入Tag名按Tag过滤,例如您的消息Tag属性为CartService,则直接输入CartService;如果需要过滤多个Tag属性,则用双竖线(||)隔开,例如CartService||Inventroy||Payment。具体过滤方法,请参见消息过滤。