检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
在“连接信息”区域，单击“ACL访问控制”后的，开启ACL访问控制。 开启ACL访问控制后，左侧导航会出现“用户管理”节点，您可以配置ACL用户，具体请参考配置RocketMQ ACL用户。 仅2021年8月21号后购买的实例，支持设置ACL访问控制。 开启ACL访问控制会导致没有配置认证信息的客户端连接中断。
配置RocketMQ实例的公网访问 您需要通过公网地址访问RocketMQ实例时，开启实例的公网访问功能，并设置弹性IP地址。当业务不再使用公网访问功能时，关闭实例的公网访问功能。 前提条件 只有处于“运行中”状态的RocketMQ实例支持修改公网访问配置。 开启公网访问 登录管理控制台。
示例代码中的参数说明如下，请参考收集连接信息获取参数值。 topic：表示Topic名称。 gid：表示生产者组名称，请根据业务实际情况输入生产者组名称。 name_srv：表示实例连接地址和端口。 ROCKETMQ_AK：表示用户名。创建用户的步骤，请参见创建用户。 ROCKETMQ_SK：表示用户的密钥。
示例代码中的参数说明如下，请参考收集连接信息获取参数值。 192.168.0.1:8100：表示实例连接地址和端口。 AccessKey：表示用户名。创建用户的步骤，请参见创建用户。 SecretKey：表示用户的密钥。 test：表示Topic名称。 事务消息，参考如下代码。以下加粗内容需要替换为实例自有信息，请根据实际情况替换。
me", rpcHook); ACL_ACCESS_KEY为用户名，ACL_SECRET_KEY为用户的密钥。创建用户的步骤，请参见创建用户。为了确保用户名和密钥的安全性，建议对用户名和密钥进行加密处理。 消费者增加用户认证信息 消费者初始化时需要增加“rpcHook”参数。无论
图1 用户详情页面 通过用户访问服务端 实例开启ACL访问控制后，消息生产者和消费者都需要增加用户认证信息，具体操作如下： Java代码示例 Go代码示例 Python代码示例 编辑用户 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择RocketMQ实例所在的区域。
配置RocketMQ访问控制 开启RocketMQ ACL访问 配置RocketMQ ACL用户 父主题： 连接实例
种身份认证方式：用户名密码、访问密钥、临时访问密钥。同时还提供登录保护及登录验证策略。 访问控制 对企业中的员工设置不同的DMS for RocketMQ访问权限，以达到不同员工之间的权限隔离，使用IAM进行精细的权限管理。该服务提供用户身份认证、权限分配、访问控制等功能，可以帮助您安全的控制华为云资源的访问。DMS
实例的SSL状态，支持根据实际情况修改。 公网访问 公网访问状态。单击“公网访问”后的，开启/关闭公网访问。 公网连接地址 仅开启公网访问后可见。 开启公网访问，并且使用TCP协议连接实例时，连接实例的地址。 grpc公网连接地址 仅开启公网访问后可见。 开启公网访问，并且使用gRPC协议连接实例时，连接实例的地址。
了因消息重复而对业务产生影响。 例如在支付场景下，用户购买商品后进行支付，由于网络不稳定导致用户收到多次扣款请求，导致重复扣款。但实际上扣款业务只应进行一次，商家也只应产生一条订单流水。这时候使用消息幂等就可以避免这个问题。 在实际应用中，导致消息重复的原因有网络闪断、客户端故障
前提条件 已创建RocketMQ实例，并记录实例详情中的“连接地址”（内网访问）/“公网连接地址”（公网访问）。内网访问的连接端口为8100，公网环境下访问的连接端口为8200。 客户端和RocketMQ实例之间网络已互通，具体网络要求参见连接RocketMQ网络要求页面。 已配置安全组。
在实际业务中，通过合理使用Topic和Tag，可以使业务结构更清晰，提高效率。可以根据如下几方面判断Topic和Tag的具体使用场景： 根据消息类型判断：RocketMQ的消息可分为普通消息、顺序消息、定时/延迟消息、事务消息，不同类型的消息需要用不同的Topic来区分，无法通过Tag区分。
次请求的结果，供您查询、审计和回溯使用。 弹性云服务器（Elastic Cloud Server） 弹性云服务器是由CPU、内存、操作系统、云硬盘组成的基础的计算组件。RocketMQ实例运行在弹性云服务器上，一个代理对应三台弹性云服务器。 云硬盘（Elastic Volume Service）
（通过密文传输），即为已开启SSL。 操作视频 本视频演示使用客户端连接RocketMQ实例的操作。 前提条件 已创建RocketMQ实例，并记录实例详情中的“连接地址”（内网访问）/“公网连接地址”（公网访问）。内网访问的连接端口为8100，公网环境下访问的连接端口为8200。
创建实例大约需要3到15分钟，此时实例的“状态”为“创建中”。 当实例的“状态”变为“运行中”时，说明实例创建成功。 当实例的“状态”变为“创建失败”，请删除创建失败的实例，然后重新创建。如果重新创建仍然失败，请联系客服。 实例创建成功后，单击实例名称，进入实例基本信息页面。 记录实例的连接地址，便于生产和消费消息时使用。
息不可见。 收发事务消息前，请参考收集连接信息收集RocketMQ所需的连接信息。 客户端连接RocketMQ实例5.x版本收发事务消息前，需要确保Topic的消息类型为“事务”。 发送事务消息 参考如下示例代码（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。 import
05 实践 您可以通过消息幂等实现消息去重。 实践场景 通过消息幂等实现消息去重 02 购买 您可以根据实际需求在控制台购买不同规格的RocketMQ实例。 购买方式 购买RocketMQ实例 价格详情 04 使用 根据业务发展需要，您可以修改实例安全组、开启公网访问。除此之外，您还
请求什么类型的操作。 GET：请求服务器返回指定资源。 PUT：请求服务器更新指定资源。 POST：请求服务器新增资源或执行特殊操作。 DELETE：请求服务器删除指定资源，如删除对象等。 HEAD：请求服务器资源头部。 PATCH：请求服务器更新资源的部分内容。当资源不存在的时
示例代码中的参数说明如下，请参考收集连接信息获取参数值。 Topic：输入Topic名称。 Endpoint：输入grpc连接地址/grpc公网连接地址。 AccessKey：创建实例时，如果开启了ACL，需要输入用户名。 SecretKey：创建实例时，如果开启了ACL，需要输入用户密钥。 SetKeys：输入消息的Key。
收集连接信息 获取实例连接信息 实例连接地址和端口 实例创建后，从RocketMQ实例控制台的“基本信息”页面获取，在客户端配置时，可将地址都配上。 使用TCP协议通过内网连接RocketMQ实例时，获取“连接地址”。 使用gRPC协议通过内网连接RocketMQ实例时，获取“grpc连接地址”。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
