检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
00400053 the upgrade instance version equals to current version. 升级版本与当前版本相同 请重新选择升级的版本号 400 DMS.00400055 Resource sold out. 资源不足，包括ecs，volume等 请稍后再试
的连接信息。 2022年3月30日及以后购买的实例支持定时消息功能，在此之前购买的实例不支持此功能。 客户端连接RocketMQ实例5.x版本收发定时消息前，需要确保Topic的消息类型为“定时”。 适用场景 定时消息适用于以下场景： 消息对应的业务逻辑有时间窗口要求，如电商交易
全局顺序消息和分区顺序消息的区别仅为队列数量不同，代码没有区别。 收发顺序消息前，请参考收集连接信息收集RocketMQ所需的连接信息。 客户端连接RocketMQ实例5.x版本收发顺序消息前，需要确保Topic的消息类型为“顺序”。 发送顺序消息 参考如下示例代码（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。
消费者对回滚的消息不可见。 收发事务消息前，请参考收集连接信息收集RocketMQ所需的连接信息。 客户端连接RocketMQ实例5.x版本收发事务消息前，需要确保Topic的消息类型为“事务”。 发送事务消息 参考如下示例代码（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。
、下划线组成，长度3~64个字符。 brokers 否 Array of strings 关联的代理列表（仅RocketMQ实例4.8.0版本需要填写此参数）。 broadcast 否 Boolean 是否广播。 retry_max_time 否 Integer 最大重试次数，取值范围为1~16。
以下示例仅介绍同步发送的示例代码。 收发普通消息前，请参考收集连接信息收集RocketMQ所需的连接信息。 客户端连接RocketMQ实例5.x版本收发普通消息前，需要确保Topic的消息类型为“普通”。 准备环境 在命令行输入python，检查是否已安装Python。得到如下回显，说明Python已安装。
Q网络要求页面。 已配置安全组。 已创建Topic。 客户端所在服务器已安装Java Development Kit 1.8.111或以上版本，并完成环境变量配置。 命令行模式连接实例 登录客户端所在服务器。 下载“rocketmq-tutorial”示例软件包。 wget https://dms-demos
RocketMQ实例5.x版本支持gRPC协议，4.8.0版本不支持。 客户端连接RocketMQ实例5.x版本收发普通消息前，需要确保Topic的消息类型为“普通”。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为5.0.5。 使用Maven方式引入依赖。
Q网络要求页面。 已配置安全组。 已创建Topic。 客户端所在服务器已安装Java Development Kit 1.8.111或以上版本，并完成环境变量配置。 命令行模式连接实例 登录客户端所在服务器。 下载“rocketmq-tutorial”示例软件包。 wget https://dms-demos
全局顺序消息和分区顺序消息的区别仅为队列数量不同，代码没有区别。 收发顺序消息前，请参考收集连接信息收集RocketMQ所需的连接信息。 客户端连接RocketMQ实例5.x版本收发顺序消息前，需要确保Topic的消息类型为“顺序”。 准备环境 执行以下命令，检查是否已安装Go。 go version 返回如下回显时，说明Go已经安装。
的连接信息。 2022年3月30日及以后购买的实例支持定时消息功能，在此之前购买的实例不支持此功能。 客户端连接RocketMQ实例5.x版本收发定时消息前，需要确保Topic的消息类型为“定时”。 适用场景 定时消息适用于以下场景： 消息对应的业务逻辑有时间窗口要求，如电商交易
消费者对回滚的消息不可见。 收发事务消息前，请参考收集连接信息收集RocketMQ所需的连接信息。 客户端连接RocketMQ实例5.x版本收发事务消息前，需要确保Topic的消息类型为“事务”。 准备环境 执行以下命令，检查是否已安装Go。 go version 返回如下回显时，说明Go已经安装。
式消息服务RocketMQ专享版页面。 RocketMQ实例支持通过筛选来查询对应的RocketMQ实例。当前支持的筛选条件为状态、名称、版本、实例类型、规格、已用/可用存储空间、计费模式、可用区、企业项目和标签。RocketMQ实例状态请参见表1。 表1 RocketMQ实例状态说明
响应Body参数 参数 参数类型 描述 engine String 消息引擎类型。 versions Array of strings 消息引擎支持的版本。 products Array of RocketMQExtendProductInfoEntity objects 规格变更的产品信息。
Array of brokers objects 关联的代理。 message_type String 消息类型（RocketMQ实例5.x版本才包含此参数）。 表3 brokers 参数 参数类型 描述 broker_name String 代理名称。 read_queue_num
回响应，接着发送下一条消息。 收发普通消息前，请参考收集连接信息收集RocketMQ所需的连接信息。 客户端连接RocketMQ实例5.x版本收发普通消息前，需要确保Topic的消息类型为“普通”。 准备环境 执行以下命令，检查是否已安装Go。 go version 返回如下回显时，说明Go已经安装。
Array of brokers objects 关联的代理。 message_type String 消息类型（RocketMQ实例5.x版本才包含此参数）。 表5 brokers 参数 参数类型 描述 broker_name String 代理名称。 read_queue_num
消费者订阅详情列表。 表4 ClientData 参数 参数类型 描述 language String 客户端语言。 version String 客户端版本。 client_id String 客户端ID。 client_addr String 客户端地址。 subscriptions Array
engine 是 String 消息引擎。取值填写为：reliability。 engine_version 是 String 消息引擎的版本。取值填写为：4.8.0。 storage_space 是 Integer 存储空间。 vpc_id 是 String 虚拟私有云ID。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
