检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
单线程发送、单线程消费并且不采用延迟队列、优先级队列等一些高级功能时，才能实现消息有序。 安全机制 支持SSL认证。 支持SSL、SASL身份认证和读写权限控制。 3.8.35版本：支持SSL认证。 AMQP-0-9-1版本：支持ACL访问控制。 事务性消息 支持 支持 支持
消息和消费消息前，需要先连接RocketMQ实例。 购买RocketMQ实例时，加密方式支持配置为SSL。 支持区域： 全部 连接未开启SSL的RocketMQ实例 连接已开启SSL的RocketMQ实例 Topic管理 Topic，即消息主题，消息发送与接收的基本单元。购买Ro
product_id String 产品标识。 security_group_id String 安全组ID。 security_group_name String 租户安全组名称。 subnet_id String 子网ID。 subnet_name String 子网名称。
product_id String 产品标识。 security_group_id String 安全组ID。 security_group_name String 租户安全组名称。 subnet_id String 子网ID。 subnet_name String 子网名称。
RocketMQ实例分内网地址以及公网地址两种网络连接方式。如果使用公网地址，则消息生产与消费客户端需要有公网访问权限，并配置如下安全组。 表1 安全组规则（RocketMQ实例4.8.0版本） 方向 协议 端口 源地址 说明 入方向 TCP 8200 RocketMQ客户端所在的IP地址或地址段。
cketMQ能力。 除了提供基础版能力外，还提供业务高可用、数据安全、信道加密等企业级特性。 产品功能 支持基础的消息收发能力 支持常见的消息类型（如普通消息、顺序消息、事务消息、定时消息） 支持消息轨迹 支持SSL 支持ACL 支持基础的消息收发能力 支持常见的消息类型（如普通消息、顺序消息、事务消息、定时消息）
product_id String 产品标识。 security_group_id String 安全组ID。 security_group_name String 租户安全组名称。 subnet_id String 子网ID。 subnet_name String 子网名称。
product_id String 产品标识。 security_group_id String 安全组ID。 security_group_name String 租户安全组名称。 subnet_id String 子网ID。 subnet_name String 子网名称。
cluster：单个代理最大Topic数16000，单个代理最大消费组数16000 ssl_enable 否 Boolean 是否打开SSL加密访问。 true：打开SSL加密访问。 false：不打开SSL加密访问。 storage_spec_code 是 String 存储IO规格。
准请参考计费说明。 安全组 选择已经创建好的安全组。 安全组是一组对RocketMQ实例的访问规则的集合。您可以单击右侧的“管理安全组”，跳转到网络控制台的“安全组”页面，查看或创建安全组。 客户端连接RocketMQ实例前，请根据不同的连接方式配置对应的安全组规则，否则会连接失败。具体的安全组规则请参考表3。
连接实例 配置RocketMQ网络连接 配置RocketMQ访问控制 使用客户端连接RocketMQ（关闭SSL） 使用客户端连接RocketMQ（开启SSL） 使用控制台连接RocketMQ
<artifactId>rocketmq-acl</artifactId> <version>4.9.8</version> </dependency> 下载依赖JAR包。 生产者增加用户认证信息 生产者初始化时需要增加“rpcHook”参数。 普通消息、顺序消息和定时消息，增加如下代码。 RPCHook
户对精细化授权的要求，无法完全达到企业对权限最小化的安全管控要求。 策略：IAM最新提供的一种细粒度授权的能力，可以精确到具体服务的操作、资源以及请求条件等。基于策略的授权是一种更加灵活的授权方式，能够满足企业对权限最小化的安全管控要求。例如：针对DMS for RocketMQ
<artifactId>rocketmq-client</artifactId> <version>4.9.8</version> </dependency> 下载依赖JAR包。 发送顺序消息 参考如下示例代码，或者通过Producer.java获取更多示例代码。 import java.nio.charset
<artifactId>rocketmq-client</artifactId> <version>4.9.8</version> </dependency> 下载依赖JAR包。 同步发送 同步发送是指消息发送方发出一条消息到服务端，服务端接收并处理消息，然后返回响应给发送方，发送方收到响应后才会发送下一条消息的通讯方式。
迁移元数据。 前提条件 已购买RocketMQ实例。 查看RocketMQ实例后台任务 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击，选择“应用中间件 > 分布式消息服务RocketMQ版”，进入分布式消息服务RocketMQ专享版页面。
AK/SK认证：通过AK（Access Key ID）/SK（Secret Access Key）加密调用请求。推荐使用AK/SK认证，其安全性比Token认证要高。 Token认证：通过Token认证调用请求。 AK/SK认证 AK/SK签名认证方式仅支持消息体大小12M以内，12M以上的请求请使用Token认证。
<artifactId>rocketmq-client</artifactId> <version>4.9.8</version> </dependency> 下载依赖JAR包。 发送事务消息 参考如下示例代码，或者通过TransactionProducer.java获取更多示例代码。 import org
诊断RocketMQ实例 重启RocketMQ实例的Broker节点 删除RocketMQ实例 配置RocketMQ实例回收站策略 修改RocketMQ实例的SSL配置 开启RocketMQ实例弹性TPS功能
product_id String 产品标识。 security_group_id String 安全组ID。 security_group_name String 租户安全组名称。 subnet_id String 子网ID。 subnet_name String 子网名称。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
