检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
定时消息将占用普通消息约3倍的存储空间，大量使用定时消息时需要注意存储空间占用。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为5.0.5。 使用Maven方式引入依赖。
在“存储信息 > 消息老化时间”后，单击，修改老化时间。 老化时间的取值范围为1~720小时，须为整数。 单击，页面右上角直接提示修改结果。 父主题： 管理消息
按Topic查询：“Topic”选择待查询消息的Topic名称，“队列”选择待查询消息的队列（仅RocketMQ实例4.8.0版本需要选择），“存储时间”选择待查询消息的时间段，单击“查询”。
)), producer.WithRetry(2), producer.WithCredentials(primitive.Credentials{ AccessKey: os.Getenv("ROCKETMQ_AK"), //用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险
表5 RocketMQExtendProductIosEntity 参数 参数类型 描述 io_spec String 存储IO规格。 available_zones Array of strings 有可用资源的可用区列表。 type String IO类型。
store_size Number 存储大小。 property_list Array of property_list objects 消息属性列表。 born_host String 产生消息的主机IP。 store_host String 存储消息的主机IP。
产品架构 图1 产品架构示意图 示意图说明： Broker：负责接收和存储Producer发送的消息，或者转发消息到Consumer。一个Broker由一个主节点和两个备节点组成。 NameServer：负责接收和存储Broker中的元数据。
定时消息将占用普通消息约3倍的存储空间，大量使用定时消息时需要注意存储空间占用。 准备环境 执行以下命令，检查是否已安装Go。 go version 返回如下回显时，说明Go已经安装。
定时消息将占用普通消息约3倍的存储空间，大量使用定时消息时需要注意存储空间占用。 准备环境 在命令行输入python，检查是否已安装Python。得到如下回显，说明Python已安装。
变更规格 扩容存储空间 扩容代理数量 扩容代理规格 批量删除消费组 选择多个消费组，进行批量删除。 批量删除Topic 选择多个Topic，进行批量删除。 消息轨迹变更 消息轨迹发生变化。 重启节点 重启Broker节点。 元数据迁移 迁移元数据。
= "topic01" GroupName = "groupname" Endpoint = "192.168.xx.xx:8080" AccessKey = os.Getenv("ROCKETMQ_AK") //用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险
store_size Number 存储大小。 property_list Array of property_list objects 消息属性列表。 born_host String 产生消息的主机IP。 store_host String 存储消息的主机IP。
造成消息堆积的原因有以下两个： 消息没有及时被消费，生产者生产消息的速度快于消费者消费消息的速度，从而产生消息积压且无法自行恢复。 业务系统本身逻辑耗费时间较长，导致消息消费效率较低。
定时消息将占用普通消息约3倍的存储空间，大量使用定时消息时需要注意存储空间占用。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为4.9.8。 通过以下任意一种方式引入依赖： 使用Maven方式引入依赖。
按Topic查询：“Topic”选择待查询消息的Topic名称，“队列”选择待查询消息的队列（仅RocketMQ实例4.8.0版本需要选择），“存储时间”选择待查询消息的时间段，单击“查询”。
topic = "yourNormalTopics"; // 填入grpc连接地址/grpc公网连接地址 String endpoints = "yourEndpoints"; // 填入用户名/密钥，用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险
credentials" ) const ( Topic = "topic01" Endpoint = "192.168.xx.xx:8080" AccessKey = os.Getenv("ROCKETMQ_AK") //用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险
处理建议：出现该告警时，说明当前实例规格已不足以承载业务，需要扩容存储空间。具体操作，请参考变更实例规格。 CPU核均负载 0~2 告警阈值：原始值>1.5 连续触发次数：3 告警级别：重要 是 指标说明：该指标为从RocketMQ节点虚拟机层面采集的CPU每个核的平均负载。
我是有问必答知识渊博的智能问答机器人，有问题欢迎随时求助哦！ 社区求助 华为云社区是华为云用户的聚集地。这里有来自容器服务的技术牛人，为您解决技术难题。
topic = "yourNormalTopics"; // 填入grpc连接地址/grpc公网连接地址 String endpoints = "yourEndpoints"; // 填入用户名/密钥，用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
