检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
已获取RocketMQ实例的实例ID，以及实例所在区域的项目ID。 使用华为云SDK 5.x版本批量创建不同类型的Topic 新建“topics.txt”文件，用于存放待创建的Topic信息。 文件内容格式为“Topic名称 消息类型”，消息类型包含普通（NORMAL）、顺序（FIFO）、定时（DELAY
8</version> </dependency> 下载依赖JAR包。 生产者增加用户认证信息 生产者初始化时需要增加“rpcHook”参数。 普通消息、顺序消息和定时消息，增加如下代码。 RPCHook rpcHook = new AclClientRPCHook(new Sessi
通过消费者的setMaxReconsumeTimes函数配置最大重试次数。若未设置参数值，默认为无限重试。 普通消费 重试时间间隔根据重试次数阶梯变化，如表2所示。 创建消费组时设置。 取值范围：1-16。 表2 普通消费重试时间间隔 重试次数 与上次的间隔时间 重试次数 与上次的间隔时间 1 10s 9
密等企业级特性。 产品功能 支持基础的消息收发能力 支持常见的消息类型（如普通消息、顺序消息、事务消息、定时消息） 支持消息轨迹 支持SSL 支持ACL 支持基础的消息收发能力 支持常见的消息类型（如普通消息、顺序消息、事务消息、定时消息） 支持消息轨迹 支持SSL 支持ACL 支持弹性TPS
ic名称为“test%01”，在云监控中Topic名称显示为“test_01”。 消息类型 选择消息的类型，支持的消息类型：普通、顺序、定时和事务。 普通消息：没有特殊功能的消息，区别于定时消息、顺序消息和事务消息。 定时消息：生产者生产消息到分布式消息服务RocketMQ版后，
使用gRPC协议连接RocketMQ实例时，消费者是否顺序消费消息，取决于消费组中是否开启顺序消费，并非在消费代码中设置，顺序消费消息的代码与普通消费的代码相同。 准备环境 执行以下命令，检查是否已安装Go。 go version 返回如下回显时，说明Go已经安装。 go version
具体可参见创建用户。 进入“rocketmq-tutorial/bin”目录。 cd rocketmq-tutorial/bin 运行生产普通消息示例。 sh mqadmin sendMessage -n "${连接地址}" -t ${Topic名称} -p "hello rocketmq"
使用gRPC协议连接RocketMQ实例时，消费者是否顺序消费消息，取决于消费组中是否开启顺序消费，并非在消费代码中设置，顺序消费消息的代码与普通消费的代码相同。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为5.0.5。 使用Maven方式引入依赖。
具体可参见创建用户。 进入“rocketmq-tutorial/bin”目录。 cd rocketmq-tutorial/bin 运行生产普通消息示例。 JAVA_OPT=-Dtls.enable=true sh mqadmin sendMessage -n "${连接地址}" -t
all（发布+订阅） message_type 否 String 消息类型（仅RocketMQ实例5.x版本需要填写此参数）。 取值范围： NORMAL（普通消息） FIFO（顺序消息） DELAY（定时消息） TRANSACTION（事务消息） topics 否 Array of strings
程数是指单个客户端所包含的线程数量，客户端数量是指消费组所包含的客户端（消费者）数量。对于普通消息、定时/延时消息、事务消息及顺序消息的消费并发度计算方法如下： 消息类型 消费并发度 普通消息 单客户端线程数 * 客户端数 定时/延时消息 事务消息 顺序消息 Min(单客户端线程数
选择需要创建消费组的代理，支持选择多个代理，可同步创建消费组，无需为每个代理单独创建。 创建消费组后不能修改关联代理。 最大重试次数 设置普通消费的最大重试次数。 取值范围：1～16 如果是顺序消费，可通过消费者的setMaxReconsumeTimes函数配置。 是否允许以广播模式消费
保证顺序，不同orderId的消息不需要保证顺序，所以将orderId作为选择队列的sharding key。 订阅顺序消息 只需要在订阅普通消息的代码基础上增加orderly=True，参考如下示例代码（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。 import time
TransactionStatus.UNKNOWN：无法判断状态，期待服务端向生产者再次回查该消息的状态。 订阅事务消息 订阅事务消息的代码与订阅普通消息的代码相同。 父主题： Python（TCP协议）
LocalTransactionState.UNKNOW：无法判断状态，期待服务端向生产者再次回查该消息的状态。 订阅事务消息 订阅事务消息的代码与订阅普通消息的代码相同。 父主题： Java（TCP协议）
全部 实例诊断 收发消息 使用RocketMQ开源客户端访问分布式消息服务RocketMQ版来收发消息的示例代码。 支持区域： 全部 收发普通消息 收发顺序消息 收发事务消息 定时消息 分布式消息服务RocketMQ版支持任意时间的定时消息，最大推迟时间可达到1年。同时也支持定时消息的取消。
限制，默认消息老化时间为2天。例如，设置定时消息5天后才能被消费，如果第5天后一直没被消费，那么这条消息将在第7天被删除。 定时消息将占用普通消息约3倍的存储空间，大量使用定时消息时需要注意存储空间占用。 准备环境 执行以下命令，检查是否已安装Go。 go version 返回如下回显时，说明Go已经安装。
TransactionResolution.UNKNOW：无法判断状态，期待服务端向生产者再次回查该消息的状态。 订阅事务消息 订阅事务消息的代码与订阅普通消息相同。 父主题： Go（gRPC协议）
限制，默认消息老化时间为2天。例如，设置定时消息5天后才能被消费，如果第5天后一直没被消费，那么这条消息将在第7天被删除。 定时消息将占用普通消息约3倍的存储空间，大量使用定时消息时需要注意存储空间占用。 准备环境 在命令行输入python，检查是否已安装Python。得到如下回显，说明Python已安装。
保证顺序，不同orderId的消息不需要保证顺序，所以将orderId作为选择队列的sharding key。 订阅顺序消息 只需要在订阅普通消息的代码基础上增加consumer.WithConsumerOrder(true)，参考如下示例代码（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
