检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
操作耗时来说几乎可以忽略，因此应关注外部I/O操作型代码的消息处理效率。 外部IO操作型代码主要有以下业务操作： 读写外部数据库，例如对远程MySQL数据库读写。 读写外部缓存系统，例如对远程Redis读写。 下游系统调用，例如Dubbo的RPC远程调用，Spring Cloud对下游系统的HTTP接口调用。
RocketMQ资源，给企业中的员工设置不同的访问权限，以达到不同员工之间的权限隔离，您可以使用统一身份认证服务（Identity and Access Management，简称IAM）进行精细的权限管理。该服务提供用户身份认证、权限分配、访问控制等功能，可以帮助您安全的控制华为云资源的访问。 通过IAM，
ketmq/5.1.4/rocketmq-all-5.1.4-bin-release.zip 解压测试工具。 unzip rocketmq-all-5.1.4-bin-release.zip 测试命令 生产命令： sh producer.sh -n "${连接地址}" -t ${Topic名称}
final SendReceipt sendReceipt = producer.send(message); log.info("Send message successfully, messageId={}", sendReceipt.getMessageId());
据业务需要，进行扩容，4.8.0版本的RocketMQ实例支持的变更配置如表1所示，5.x版本的RocketMQ实例支持的变更配置如表2所示。 表1 变更配置列表（RocketMQ实例4.8.0版本） 变更配置类型 是否支持扩容 是否支持缩容 代理个数 √ × 存储空间 √ × 代理规格
支持区域： 全部 扩容存储空间或代理个数 公网访问 您需要通过公网地址访问RocketMQ实例时，开启实例的公网访问功能，并设置弹性IP地址。 只有处于“运行中”状态的RocketMQ实例支持修改公网访问配置。 支持区域： 全部 设置实例公网访问 消息查询 通过查询消息功能查看具体的消
执行以下命令，检查是否已安装Go。 go version 返回如下回显时，说明Go已经安装。 [root@ecs-test sarama]# go version go version go1.16.5 linux/amd64 如果未安装Go，请下载并安装。 进入Go脚本所在的bin目录下。
使用TCP协议，访问业务节点的端口。 5.x 入方向 TCP 8080 使用gRPC协议，通过内网访问实例的端口。 5.x 入方向 TCP 8081 使用gRPC协议，通过公网访问实例的端口。 建议将访问DMS for RocketMQ实例方式设置为密码访问（即开启ACL访问控制），防止未经认证的客户端误操作实例。
需要注意存储空间占用。 准备环境 执行以下命令，检查是否已安装Go。 go version 返回如下回显时，说明Go已经安装。 go version go1.16.5 linux/amd64 如果未安装Go，请下载并安装。 进入Go脚本所在的bin目录下。 执行“touch go
enable_publicip Boolean 是否开启公网。 publicip_id String 实例绑定的弹性IP地址的ID。以英文逗号隔开多个弹性IP地址的ID。如果开启了公网访问功能（即enable_publicip为true），该字段为必选。 publicip_address String
enable_publicip Boolean 是否开启公网。 publicip_id String 实例绑定的弹性IP地址的ID。以英文逗号隔开多个弹性IP地址的ID。如果开启了公网访问功能（即enable_publicip为true），该字段为必选。 publicip_address String
enable_publicip Boolean 是否开启公网。 publicip_id String 实例绑定的弹性IP地址的ID。以英文逗号隔开多个弹性IP地址的ID。如果开启了公网访问功能（即enable_publicip为true），该字段为必选。 publicip_address String
Boolean 是否开启访问控制列表。 ipv6_enable Boolean 是否支持IPv6。 true：支持 false：不支持 enable_publicip Boolean 是否开启公网访问功能。默认不开启公网。 true：开启 false：不开启 publicip_id String
Boolean ACL访问控制。 enable_publicip 否 Boolean 是否开启公网。 publicip_id 否 String 实例绑定的弹性IP地址的ID。 以英文逗号隔开多个弹性IP地址的ID。 如果开启了公网访问功能（即enable_publicip为true），该字段为必选。
enable_publicip Boolean 是否开启公网。 publicip_id String 实例绑定的弹性IP地址的ID。以英文逗号隔开多个弹性IP地址的ID。如果开启了公网访问功能（即enable_publicip为true），该字段为必选。 publicip_address String
enable_publicip Boolean 是否开启公网。 publicip_id String 实例绑定的弹性IP地址的ID。以英文逗号隔开多个弹性IP地址的ID。如果开启了公网访问功能（即enable_publicip为true），该字段为必选。 publicip_address String
"credits" or "license" for more information. >>> 如果未安装Python，请使用以下命令安装： yum install python 安装librocketmq库和rocketmq-client-python，具体操作请参考rocketmq-client-python。
创建一个RocketMQ实例。 重启实例 重启RocketMQ实例。 修改是否开启SSL 修改SSL的配置。 开启公网访问 修改“公网访问”为开启。 关闭公网访问 修改“公网访问”为关闭。 变更规格 扩容存储空间 扩容代理数量 扩容代理规格 批量删除消费组 选择多个消费组，进行批量删除。
Boolean 是否开启访问控制列表。 ipv6_enable 否 Boolean 是否支持IPv6。 true：支持 false：不支持 enable_publicip 否 Boolean 是否开启公网访问功能。默认不开启公网。 true：开启 false：不开启 publicip_id 否
通过suspendTimeMillis设置重试时间间隔。 默认值为1000ms，即1s。 通过消费者的setMaxReconsumeTimes函数配置最大重试次数。若未设置参数值，默认为无限重试。 普通消费 重试时间间隔根据重试次数阶梯变化，如表2所示。 创建消费组时设置。 取值范围：1-16。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
