检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
者消费消息时,可能会出现消费过快导致下游业务来不及处理的情况,进而影响系统的稳定性。本章节介绍在消费端进行限流的示例代码,以保障系统的稳定。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版,推荐使用的客户端版本为4.9.8。 使用Maven方式引入依赖。 <dependency>
系一致的概念、原理以及实施方法。 消息堆积处理建议 本章节介绍出现消息堆积的主要原因和实施方法。 配置消息堆积数监控 本章节介绍RocketMQ通过云监控配置告警规则的具体操作,以便您可以实时监控实例的运行状态和关键的业务指标,并能够及时收到异常的告警通知,实现生产环境的风险预警。
opic,释放资源。 仅在实例的“状态”为“运行中”时,才可以删除实例中的Topic。 前提条件 已购买RocketMQ实例。 已创建Topic。 删除Topic 登录管理控制台。 在管理控制台左上角单击,选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击,选择“应用中间件
验证RocketMQ消息消费 消费验证是将消息重新发送到指定的在线客户端,验证消费者能否收到消息。消费验证会导致消息重复消费。 前提条件 仅在实例的“状态”为“运行中”时,才可以进行消费验证。 确保待进行消费验证的客户端处于在线状态,且消费者已订阅待重新发送的消息所属的Topic。 验证RocketMQ消息消费
云监控对RocketMQ实例的运行状态进行日常监控,可以通过控制台直观的查看RocketMQ实例各项监控指标。 前提条件 已购买RocketMQ实例。 查看RocketMQ监控指标 登录管理控制台。 在管理控制台左上角单击,选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击,选择“应用中间件
开启回收站策略的实例在被删除后,会被临时存入回收站中,此时实例中的数据尚未被彻底删除,在保留天数内支持从回收站中恢复此实例。超过保留天数的实例会被彻底删除,无法恢复。 回收站策略默认是关闭状态。 约束与限制 回收站中的按需实例不会收取实例的费用,但是会收取存储空间的费用。 包年/
本文介绍了分布式消息服务RocketMQ版各特性版本的功能发布和对应的文档动态,欢迎体验。 2024年3月 序号 功能名称 功能描述 阶段 1 计费系统的RocketMQ规格名称优化 在计费系统中优化RocketMQ实例的规格名称,便于用户使用和理解。优化后的规格名称为:分布式消息服务RocketMQ专享规格。
RocketMQ提供基于云监控服务CES的资源和操作监控能力,帮助用户对每个RocketMQ实例进行自动实时监控、告警和通知操作。用户可以实时掌握实例的各类业务请求、资源占用、流量、连接数和消息积压等关键信息。 关于DMS for RocketMQ支持的监控指标,以及如何创建监控告警规则等内容,请参见支持的监控指标。
RocketMQ实例的版本为4.8.0时,才会显示此参数。 Topic的权限,包括发布+订阅、发布和订阅。 关联代理 RocketMQ实例的版本为4.8.0时,才会显示此参数。 修改读队列个数或写队列个数。 读队列个数:Topic读数据可用的总队列数。 写队列个数:Topic写数据可用的总队列数。
在左侧导航栏,单击“消费组管理”,进入消费组列表页面。 选择以下任意一种方法删除消费组。 在待删除的消费组所在行,单击“删除”。 单击待删除的消费组名称,进入消费组详情页面。在页面右上角,单击“删除”。 如需批量删除消费组,勾选待删除的消费组,单击“删除消费组”。 单击“确定”,确认删除消费组。 父主题: 管理消费组
管理页面。 在“后台任务”或“定时任务”页签左上角选择需要查看的时间段,界面显示相应时间段内启动的后台任务或定时任务。 在后台任务管理页面,您还可以执行以下操作: 通过筛选来查询对应的RocketMQ实例。当前支持的筛选条件为任务名、用户名、状态和其他信息。 单击“删除”,弹出“
专享版页面。 单击RocketMQ实例的名称,进入实例详情页面。 在“连接信息”区域,单击“弹性TPS”后的,弹出确认开启提示框。 开启弹性TPS能力后,消息收发允许在一定范围内超过基础规格限制的TPS,且超过基础规格外的部分,需要收取额外的弹性规格费用。 关闭弹性TPS能力后,消息收发将限制在基础规格TPS之内。
List)可以实现对RocketMQ实例中生产者和消费者身份的精确识别,达到权限管理的目的。开启ACL权限控制功能后,生产消息和消费消息时,需要鉴权。 约束与限制 仅2021年8月21号后购买的实例,支持设置ACL访问控制。 开启ACL访问控制会导致没有配置认证信息的客户端连接中断。 前提条件 已购买RocketMQ实例。
Topic名称 选择待重置消费进度的Topic。 时间 选择重置消费进度的时间点,重置完成后,将从此时间点开始消费。 自定义:自定义时间点,即从自定义的时间点重新开始消费消息。 最早:最早偏移量,即从头开始消费所有消息。 最晚:最晚偏移量,即当前时间之前的所有消息全部不消费了,只从当前时间重新开始消费消息。
本文介绍了分布式消息服务RocketMQ版提供的SDK语言版本,列举了最新版本SDK的获取地址。 在线生成SDK代码 API Explorer能根据需要动态生成SDK代码功能,降低您使用SDK的难度,推荐使用。 SDK列表 表1提供了分布式消息服务RocketMQ版支持的SDK列表,您可以在GitH
默认情况下,新建的IAM用户没有任何权限,您需要将其加入用户组,并给用户组授予策略或角色,才能使用户组中的用户获得相应的权限,这一过程称为授权。授权后,用户就可以基于已有权限对云服务进行操作。 权限根据授权的精细程度,分为角色和策略。角色以服务为粒度,是IAM最初提供的一种根据用户的工作职
获取项目ID 操作场景 在调用接口的时候,部分URL中需要填入项目ID,所以需要获取到项目ID。有如下两种获取方式: 调用API获取项目ID 从控制台获取项目ID 调用API获取项目ID 项目ID可以通过调用查询指定条件下的项目信息API获取。 获取项目ID的接口为“GET https:
修改RocketMQ消息保留时间 消息老化时间即消息的最长保留时间,消费者必须在此时间结束前消费消息,否则消息将被删除。删除的消息,无法被消费。 正常消息的保留时间和死信消息的保留时间都是由消息老化时间控制,消息老化时间修改后,正常消息的保留时间和死信消息的保留时间都会被修改。 实例创建后,您可
选择以下任意一种方法删除按需的RocketMQ实例。 在待删除的RocketMQ实例所在行,单击“更多 > 删除”。 单击待删除的RocketMQ实例名称,进入实例详情页面。在页面右上角,单击“更多 > 删除”。 如需批量删除实例,勾选待删除的实例,单击信息栏左上侧的“删除”。 Rock
x时,需要设置此参数。 开启顺序消费后,消费者将按顺序消费消息。 按顺序消费可以保证消息的消费顺序和发送的顺序一致,即先发送的先消费,后发送的后消费。 描述 消费组的描述信息。 取值长度为0~200个字符。 修改完成后,单击“确定”。 父主题: 管理消费组