检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
创建用户并授权使用DMS for RocketMQ 如果您需要对您所拥有的DMS for RocketMQ进行精细的权限管理，您可以使用统一身份认证服务（Identity and Access Management，简称IAM），通过IAM，您可以： 根据企业的业务组织，在您的华
IP白名单可以配置为具体的IP地址，也可以配置为网段。 多个IP时使用英文逗号隔开，如：192.168.1.2,192.168.2.3。 IP网段值如192.*.*.*。 在“华东二”区域使用IPv6方式连接RocketMQ实例时，IP白名单功能不可用。 默认Topic权限 指定用户的默认Topic权限。
查看RocketMQ消费者连接地址 消费者连接地址即消费消息的客户端地址，当客户端连接RocketMQ消费消息时，可通过控制台查看客户端的连接地址。 约束与限制 消费者处于连接RocketMQ实例时，才可以查看消费者连接地址。 前提条件 已创建消费组，且消费组中已存在消费者。 已创建Topic。
时，需要鉴权。 约束与限制 仅2021年8月21号后购买的实例，支持设置ACL访问控制。 开启ACL访问控制会导致没有配置认证信息的客户端连接中断。 前提条件 已购买RocketMQ实例。 开启RocketMQ ACL访问 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择RocketMQ实例所在的区域。
仅2021年8月21号后购买的实例，支持设置此参数。 表3 连接信息（分布式消息服务RocketMQ版5.x） 参数 说明 内网连接地址 未开启公网访问，并且使用TCP协议连接实例时，连接实例的地址。 grpc连接地址 未开启公网访问，并且使用gRPC协议连接实例时，连接实例的地址。 公网访问 公网访问状
购买RocketMQ实例 分布式消息服务RocketMQ版 介绍怎样连接RocketMQ实例 06:08 连接未开启SSL的RocketMQ实例 分布式消息服务RocketMQ版 介绍如何连接已开启SSL的RocketMQ实例 03:30 连接开启SSL的RocketMQ实例 分布式消息服务RocketMQ版
String 公网元数据域名。 public_broker_address String 公网业务数据地址。 grpc_address String grpc连接地址（仅RocketMQ 5.x版本会显示此字段）。 grpc_domain_name String grpc连接域名（仅RocketMQ
String 公网元数据域名。 public_broker_address String 公网业务数据地址。 grpc_address String grpc连接地址（仅RocketMQ 5.x版本会显示此字段）。 grpc_domain_name String grpc连接域名（仅RocketMQ
String 公网元数据域名。 public_broker_address String 公网业务数据地址。 grpc_address String grpc连接地址（仅RocketMQ 5.x版本会显示此字段）。 grpc_domain_name String grpc连接域名（仅RocketMQ
稳定性。本章节介绍在消费端进行限流的示例代码，以保障系统的稳定。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为4.9.8。 使用Maven方式引入依赖。 <dependency> <groupId>org.apache.rocketmq</groupId>
为什么查询到的消费组不在控制台中？ 使用Admin Tool连接RocketMQ实例查询消费组信息时，会查出一些控制台中没有配置的消费组，如CID_ONSAPI_OWNER、SELF_TEST_C_GROUP、TOOLS_CONSUMER、CID_ONSAPI_PULL、CID_
将在第7天被删除。 定时消息将占用普通消息约3倍的存储空间，大量使用定时消息时需要注意存储空间占用。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为5.0.5。 使用Maven方式引入依赖。 <dependency> <groupId>org
将在第7天被删除。 定时消息将占用普通消息约3倍的存储空间，大量使用定时消息时需要注意存储空间占用。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为5.0.5。 使用Maven方式引入依赖。 <dependency> <groupId>org
时间点后才会发送给消费者进行消费。 发送定时消息前，请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 2022年3月30日及以后购买的实例支持定时消息功能，在此之前购买的实例不支持此功能。 客户端连接RocketMQ实例5.x版本收发定时消息前，需要确保Topic的消息类型为“定时”。
定时消息将占用普通消息约3倍的存储空间，大量使用定时消息时需要注意存储空间占用。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为4.9.8。 通过以下任意一种方式引入依赖： 使用Maven方式引入依赖。 <dependency>
String 公网元数据域名。 public_broker_address String 公网业务数据地址。 grpc_address String grpc连接地址（仅RocketMQ 5.x版本会显示此字段）。 grpc_domain_name String grpc连接域名（仅RocketMQ
第二章介绍如何获取RocketMQ实例连接信息。 第三章~第七章介绍Java、Go和Python客户端访问分布式消息服务RocketMQ版的示例代码，具体如表1所示。 表1 示例代码 客户端语言 示例代码 Java（TCP协议） 收发普通消息 收发顺序消息 收发事务消息 发送定时消息 使用ACL权限访问
异步发送：消息发送方发出一条消息后，不等服务端返回响应，接着发送下一条消息。 收发消息前，请参考收集连接信息收集RocketMQ所需的连接信息。 约束与限制 仅RocketMQ实例5.x版本支持gRPC协议，4.8.0版本不支持。 客户端连接RocketMQ实例5.x版本收发普通消息前，需要确保Topic的消息类型为“普通”。
RocketMQ版后，消息不会立即被消费，而是延迟到设定的时间点后才会发送给消费者进行消费。 发送定时消息前，请参考收集连接信息收集RocketMQ所需的连接信息。 适用场景 定时消息适用于以下场景： 消息对应的业务逻辑有时间窗口要求，如电商交易中超时未支付关闭订单的场景。在订单
String 公网元数据域名。 public_broker_address String 公网业务数据地址。 grpc_address String grpc连接地址（仅RocketMQ 5.x版本会显示此字段）。 grpc_domain_name String grpc连接域名（仅RocketMQ
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
