检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
RocketMQ是否支持自建Broker连接云上nameserver？ 不支持。自建Broker连接到云上RocketMQ的nameserver，会影响管理面功能，导致查询不到Topic等问题。 父主题： 连接问题
兼容开源RocketMQ客户端。 提供顺序、延迟、定时、重投、死信、事务消息等功能，更好的适配电商、金融等多样的业务场景。 提供消息追踪、消息溯源、链路诊断、死信导出、监控告警等能力，帮助您全方面的了解服务状况，保证业务正常运行。 产品架构 图1 产品架构示意图 示意图说明： Broker：负责接收和存储
xx:8080" AccessKey = os.Getenv("ROCKETMQ_AK") //用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险，建议在配置文件或者环境变量中密文存放,使用时解密。 SecretKey = os.Getenv("ROCKETMQ_SK")
收发事务消息 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证，通过两阶段的方式提供对事务消息的支持，事务消息交互流程如图1所示。 图1 事务消息交互流程 事务消息生产者首先发送半消息，然后执行本地事务。如果执行成功，则发送事务提交，否则发送事务
本章节介绍分布式消息服务RocketMQ版不同版本支持的实例类型和部署架构，5.x版本相比4.8.0版本的优势，以及不同实例类型、部署架构之前的差异，为您选择适合您业务的实例提供参考。 不同版本支持的实例类型和部署架构 表1 不同版本支持的实例类型和部署架构 实例版本 实例类型 部署架构 4.8.0 专业版
元数据迁移 新建元数据迁移任务 查询实例下所有迁移任务或查询指定迁移任务信息 删除元数据迁移任务 父主题： API V2（推荐）
迁移元数据 RocketMQ元数据迁移概述 迁移其他RocketMQ的元数据到RocketMQ实例 迁移RabbitMQ的元数据到RocketMQ实例
String 迁移任务名称，名称规则参考创建实例。 type 是 String 迁移任务类型，分为自建RocketMQ上云(rocketmq)、自建RabbitMQ上云(rabbitToRocket) 请求参数 表3 请求Body参数 参数 是否必选 参数类型 描述 topicConfigTable
正常消息的保留时间和死信消息的保留时间都是由消息老化时间控制，消息老化时间修改后，正常消息的保留时间和死信消息的保留时间都会被修改。 实例创建后，您可以根据业务需要修改消息老化时间。修改老化时间，不会重启实例。消息老化时间默认为48小时。 前提条件 已购买RocketMQ实例。 修改RocketMQ消息保留时间
使用TCP协议，通过公网访问元数据节点的端口。 入方向 TCP 10100-10199 使用TCP协议，通过内网访问业务节点的端口。 入方向 TCP 10101-10199 使用TCP协议，通过公网访问业务节点的端口。 表3 安全组规则（RocketMQ实例5.x版本） 方向 协议 端口 源地址 说明
消息。 支持区域： 全部 创建Topic 查询Topic信息 修改Topic参数 变更实例规格 RocketMQ实例创建成功后，您可以根据业务需要，扩容存储空间和代理个数。不支持同时扩容存储空间和代理个数，如果需要可以分别进行扩容。 当前只支持扩容，不支持缩容。扩容存储空间有次数限制，只能扩容20次。
收发事务消息 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证，通过两阶段的方式提供对事务消息的支持，事务消息交互流程如图1所示。 图1 事务消息交互流程 事务消息生产者首先发送半消息，然后执行本地事务。如果执行成功，则发送事务提交，否则发送事务
归属企业项目：告警规则所属的企业项目。只有拥有该企业项目权限的用户才可以查看和管理该告警规则。 标签：标签用于标识云资源，当您拥有相同类型的许多云资源时，可以使用标签按各种维度（例如用途、所有者或环境）对云资源进行分类。 单击“立即创建”，完成告警规则的设置。 告警规则创建完成后，在云监控服务的“告警
收发事务消息 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证，通过两阶段的方式提供对事务消息的支持，事务消息交互流程如图1所示。 图1 事务消息交互流程 事务消息生产者首先发送半消息，然后执行本地事务。如果执行成功，则发送事务提交，否则发送事务
例如：原实例Topic01的读队列个数为3，云上实例Topic01的读队列个数为2，开启同名覆盖后，云上实例Topic01的读队列个数变为3。 如果不开启同名覆盖，同名元数据的迁移将失败。 例如：原实例的Topic包含Topic01和Topic02，云上实例的Topic包含Topic01
消费组（Consumer Group） 多个消费者组成同一个消费组，同一消费组内的消费者具有相同的消费属性。 代理（Broker） 一组节点构成的一个业务集群。 NameServer 存储元数据信息的轻量级注册中心。生产者/消费者在生产/消费消息前，需要先从NameServer获取元数据。
and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"] projectId = "{project_id}"
设置实例网络环境信息，如图4所示，配置详情请参考表4。 表4 设置实例网络环境信息 参数 说明 虚拟私有云 虚拟私有云在RocketMQ实例创建完成后，不支持修改。 选择准备工作中设置好的虚拟私有云。 子网 子网在RocketMQ实例创建完成后，不支持修改。 选择准备工作中设置好的子网。 安全组
and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"] projectId = "{project_id}"
PLAINTEXT > SSL 存量实例会重启，业务会中断，需要在客户端修改实例接入方式。 新实例不会重启，但是业务会中断，需要在客户端修改实例接入方式。 SSL > PLAINTEXT PLAINTEXT > PERMISSIVE 实例不会重启，业务不会中断。 SSL > PERMISSIVE
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
