检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
ACL_ACCESS_KEY为用户名，ACL_SECRET_KEY为用户的密钥。创建用户的步骤，请参见创建用户。为了确保用户名和密钥的安全性，建议对用户名和密钥进行加密处理。 消费者增加用户认证信息 消费者初始化时需要增加“rpcHook”参数。无论是普通消息、顺序消息、定时消息，还是事务消息，都增加如下代码。
项”、“到期不续费项”页签查询全部待续费资源，对资源进行手动续费的操作。 所有需手动续费的资源都可归置到“手动续费项”页签，具体操作请参见如何恢复为手动续费。 手动续费资源。 单个续费：在资源页面找到需要续费的资源，单击操作列的“续费”。 图2 单个续费 批量续费：在资源页面勾选
// 使用线程池处理接收消息回调 ExecutorService receiveCallbackExecutor = Executors.newCachedThreadPool(); // 使用线程池处理提交消息回调 ExecutorService
会被彻底删除，不会进入回收站。 图1 按需计费RocketMQ实例生命周期 华为云根据客户等级定义了不同客户的宽限期和保留期时长。 避免和处理欠费 欠费后需要及时充值，详细操作请参见账户充值。 若不再使用RocketMQ实例，您可以将他们删除，以免继续扣费。 您可以在“费用中心 >
单击“查看报告”，进入“实例诊断”页面，查看诊断结果。 您可以查看到消费组状态是否在线、消费者数量、订阅关系是否一致和消息堆积量，并根据结果分析处理生产和消费消息时所遇到的问题。 图1 诊断结果 消费组不在线时，可以诊断成功，但是会显示1项异常。 删除诊断记录 登录管理控制台。 在管理控制台左上角单击，选择区域。
实现订阅关系一致 方案概述 订阅关系一致指的是同一个消费组下所有消费者所订阅的Topic、Tag必须完全一致。如果订阅关系不一致，消息消费的逻辑就会混乱，甚至导致消息丢失。 消费原理 RocketMQ为每个Topic划分了消息队列（Queue），队列数越大消费的并发度越大。一个消
节点生产请求P99处理时长 节点所有生产请求处理时长从小到大排列，顺序处于99%位置的时长 单位：ms 说明： 2022年5月16号及以后购买的实例，支持此监控项。 >=0 RocketMQ实例节点 1分钟 broker_produce_p999 节点生产请求P99.9处理时长 节点所
分布式消息服务RocketMQ版提供了REST（Representational State Transfer）风格API，支持您通过HTTPS请求调用，调用方法请参见如何调用API。 终端节点 终端节点（Endpoint）即调用API的请求地址，不同服务不同区域的终端节点不同，您可以从地区和终端节点中查询所有服务的终端节点。
如果本地事务提交成功，则提交消息事务。 * 2. 如果本地事务提交失败，则回滚消息事务。 * 3. 如果本地事务未知异常，则不处理，等待事务消息回查。 * */ err = transaction.Commit()
如果本地事务提交成功，则提交消息事务。 * 2. 如果本地事务提交失败，则回滚消息事务。 * 3. 如果本地事务未知异常，则不处理，等待事务消息回查。 * */ transaction.commit();
试环境使用的RocketMQ实例，推荐选择高I/O磁盘。对于生产环境使用的RocketMQ实例，推荐选择通用型SSD及以上的磁盘规格。具体如何选择磁盘类型可以参考磁盘类型及性能介绍和磁盘类型对RocketMQ实例性能有什么影响？。 图1 综合推荐 规格测算：系统根据您输入的参数（
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
