检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
配置RocketMQ实例的公网访问 您需要通过公网地址访问RocketMQ实例时，开启实例的公网访问功能，并设置弹性IP地址。当业务不再使用公网访问功能时，关闭实例的公网访问功能。 约束与限制 RocketMQ实例只支持绑定IPv4弹性IP地址。 前提条件 只有处于“运行中”状态
示例代码中的参数说明如下，请参考收集连接信息获取参数值。 192.168.0.1:8100：表示实例连接地址和端口。 AccessKey：表示用户名。创建用户的步骤，请参见创建用户。 SecretKey：表示用户的密钥。 test：表示Topic名称。 事务消息，参考如下代码。以下加粗内容需要替换为实例自有信息，请根据实际情况替换。
示例代码中的参数说明如下，请参考收集连接信息获取参数值。 consumer_group：表示消费组名称。 192.168.0.1:8100：表示实例连接地址和端口。 ACL_ACCESS_KEY：表示用户名。创建用户的步骤，请参见创建用户。 ACL_SECRET_KEY：表示用户的密钥。 TopicTest：表示Topic名称。
me", rpcHook); ACL_ACCESS_KEY为用户名，ACL_SECRET_KEY为用户的密钥。创建用户的步骤，请参见创建用户。为了确保用户名和密钥的安全性，建议对用户名和密钥进行加密处理。 消费者增加用户认证信息 消费者初始化时需要增加“rpcHook”参数。无论
种身份认证方式：用户名密码、访问密钥、临时访问密钥。同时还提供登录保护及登录验证策略。 访问控制 对企业中的员工设置不同的DMS for RocketMQ访问权限，以达到不同员工之间的权限隔离，使用IAM进行精细的权限管理。该服务提供用户身份认证、权限分配、访问控制等功能，可以帮助您安全的控制华为云资源的访问。DMS
配置RocketMQ访问控制 开启RocketMQ ACL访问 配置RocketMQ ACL用户 父主题： 连接实例
单击RocketMQ实例的名称，进入实例详情页面。 在“连接信息”区域，单击“ACL访问控制”后的，开启ACL访问控制。 开启ACL访问控制后，左侧导航会出现“用户管理”节点，您可以配置ACL用户，具体请参考配置RocketMQ ACL用户。 父主题： 配置RocketMQ访问控制
前提条件 已创建RocketMQ实例，并记录实例详情中的“连接地址”（内网访问）/“公网连接地址”（公网访问）。内网访问的连接端口为8100，公网环境下访问的连接端口为8200。 客户端和RocketMQ实例之间网络已互通，具体网络要求参见连接RocketMQ网络要求页面。 已配置安全组。
对于管理员创建IAM用户接口，您可以从接口的请求部分看到所需的请求参数及参数说明，将消息体加入后的请求如下所示，其中加粗的字段需要根据实际值填写。 accountid为IAM用户所属的账号ID。 username为要创建的IAM用户名。 email为IAM用户的邮箱。 **********为IAM用户的登录密码。
单击RocketMQ实例的名称，进入实例详情页面。 在左侧导航栏，单击“用户管理”，进入“用户管理”页面。 在待修改的用户所在行，单击“编辑”，弹出“编辑用户”对话框。 根据业务需要修改用户信息。 用户名称不可修改，其他参数配置说明请参见表1。 单击“确定”，完成用户的修改。 导出用户 登录管理控制台。
息头，从而通过身份认证。 AK(Access Key ID)：访问密钥ID。与私有访问密钥关联的唯一标识符；访问密钥ID和私有访问密钥一起使用，对请求进行加密签名。 SK(Secret Access Key)：与访问密钥ID结合使用的密钥，对请求进行加密签名，可标识发送方，并防止请求被修改。
创建实例 功能介绍 创建实例。 调用方法 请参见如何调用API。 URI POST /v1.0/{project_id}/instances 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方式请参见获取项目ID。 请求参数 无
查询实例 功能介绍 查询实例。 调用方法 请参见如何调用API。 URI GET /v1.0/{project_id}/instances/{instance_id} 表1 路径参数 参数 是否必选 参数类型 描述 instance_id 是 String 实例ID。 project_id
安全组是一组对RocketMQ实例的访问规则的集合。您可以单击右侧的“管理安全组”，跳转到网络控制台的“安全组”页面，查看或创建安全组。 客户端连接RocketMQ实例前，请根据不同的连接方式配置对应的安全组规则，否则会连接失败。具体的安全组规则请参考表3。 设置实例访问方式。 表6 实例访问方式参数说明
实例状态说明 表1 实例状态说明 状态 说明 CREATING 申请实例后，在实例状态进入运行中之前的状态。 RUNNING 实例正常运行状态。在这个状态的实例可以运行您的业务。 ERROR 实例处于故障的状态。 RESTARTING 实例正在进行重启操作。 STARTING 实例从已冻结到运行中的中间状态。
进行测试前，您需要先构建如下的测试环境： 购买如表1所示实例，购买步骤请参考购买实例。 表1 实例参数 名称 规格 代理数量 存储空间 ACL访问 公网访问 rocketmq-01 rocketmq.4u8g.cluster.small 1 高I/O 300GB 关闭 关闭 rocketmq-02 rocketmq
VPCAccess DMS KMSAccess 创建实例 √ × × × × 修改实例 √ × × × × 删除实例 √ × × × × 变更实例规格 √ × × × × 查询实例信息 √ √ √ × × 相关链接 IAM产品介绍 创建用户组、用户并授予DMS for RocketMQ权限
x基础版本RocketMQ实例性能 本章节主要测试RocketMQ实例5.x基础版本不同产品规格在发送1KB大小的消息时，实例的生产速率、消费速率和平均生产时延。 测试环境 进行测试前，您需要先构建如下的测试环境： 购买如表1所示实例，购买步骤请参考购买实例。 表1 实例参数 名称 规格 存储空间
表3 连接信息（分布式消息服务RocketMQ版5.x） 参数 说明 内网连接地址 未开启公网访问，并且使用TCP协议连接实例时，连接实例的地址。 grpc连接地址 未开启公网访问，并且使用gRPC协议连接实例时，连接实例的地址。 公网访问 公网访问状态。单击“公网访问”后的，开启/关闭公网访问。
概述 第二章介绍如何获取RocketMQ实例连接信息。 第三章~第七章介绍Java、Go和Python客户端访问分布式消息服务RocketMQ版的示例代码，具体如表1所示。 表1 示例代码 客户端语言 示例代码 Java（TCP协议） 收发普通消息 收发顺序消息 收发事务消息 发送定时消息
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
