检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
者消费消息时，可能会出现消费过快导致下游业务来不及处理的情况，进而影响系统的稳定性。本章节介绍在消费端进行限流的示例代码，以保障系统的稳定。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为4.9.8。 使用Maven方式引入依赖。 <dependency>
华为云：负责云服务自身的安全，提供安全的云。华为云的安全责任在于保障其所提供的IaaS、PaaS和SaaS类云服务自身的安全，涵盖华为云数据中心的物理环境设施和运行其上的基础服务、平台服务、应用服务等。这不仅包括华为云基础设施和各项云服务技术的安全功能和性能本身，也包括运维运营安全，以及更广义的安全合规遵从。
默认情况下，新建的IAM用户没有任何权限，您需要将其加入用户组，并给用户组授予策略或角色，才能使用户组中的用户获得相应的权限，这一过程称为授权。授权后，用户就可以基于已有权限对云服务进行操作。 权限根据授权的精细程度，分为角色和策略。角色以服务为粒度，是IAM最初提供的一种根据用户的工作职
磁盘类型对RocketMQ实例性能有什么影响？ 对生产RocketMQ实例消息的影响 RocketMQ会将收到的消息进行持久化，因此，消息生产的吞吐量会一定程度上受到磁盘规格的影响。在其它条件相同的情况下，磁盘吞吐量越高，生产消息的性能越好。当磁盘性能达到瓶颈时，磁盘访问时延会增加，进而导致生产
修改RocketMQ消息保留时间 消息老化时间即消息的最长保留时间，消费者必须在此时间结束前消费消息，否则消息将被删除。删除的消息，无法被消费。 正常消息的保留时间和死信消息的保留时间都是由消息老化时间控制，消息老化时间修改后，正常消息的保留时间和死信消息的保留时间都会被修改。 实例创建后，您可
验证RocketMQ消息消费 消费验证是将消息重新发送到指定的在线客户端，验证消费者能否收到消息。消费验证会导致消息重复消费。 前提条件 仅在实例的“状态”为“运行中”时，才可以进行消费验证。 确保待进行消费验证的客户端处于在线状态，且消费者已订阅待重新发送的消息所属的Topic。 验证RocketMQ消息消费
顺序消息是分布式消息服务RocketMQ版提供的一种严格按照顺序来发布和消费的消息类型。 顺序消息分为全局顺序消息和分区顺序消息： 全局顺序消息：对于指定的一个Topic，将队列数量设置为1，这个队列内所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和订阅。 分
顺序消息是分布式消息服务RocketMQ版提供的一种严格按照顺序来发布和消费的消息类型。 顺序消息分为全局顺序消息和分区顺序消息： 全局顺序消息：对于指定的一个Topic，将队列数量设置为1，这个队列内所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和订阅。 分
云监控对RocketMQ实例的运行状态进行日常监控，可以通过控制台直观的查看RocketMQ实例各项监控指标。 前提条件 已购买RocketMQ实例。 查看RocketMQ监控指标 登录管理控制台。 在管理控制台左上角单击，选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击，选择“应用中间件
RocketMQ提供基于云监控服务CES的资源和操作监控能力，帮助用户对每个RocketMQ实例进行自动实时监控、告警和通知操作。用户可以实时掌握实例的各类业务请求、资源占用、流量、连接数和消息积压等关键信息。 关于DMS for RocketMQ支持的监控指标，以及如何创建监控告警规则等内容，请参见支持的监控指标。
管理页面。 在“后台任务”或“定时任务”页签左上角选择需要查看的时间段，界面显示相应时间段内启动的后台任务或定时任务。 在后台任务管理页面，您还可以执行以下操作： 通过筛选来查询对应的RocketMQ实例。当前支持的筛选条件为任务名、用户名、状态和其他信息。 单击“删除”，弹出“
据自身的业务需求使用分布式消息服务RocketMQ版提供的一系列常用实践。 表1 常用最佳实践 实践 描述 RocketMQ业务迁移 介绍将其他厂商或者自建的RocketMQ迁移到华为云分布式消息服务RocketMQ版。 迁移RabbitMQ的元数据 迁移RabbitMQ的元数据到云上RocketMQ实例。
暂无计划 EOM：End of Marketing，停止该版本的销售。 EOS：End of Service & support，停止该版本的服务，建议您在执行作业时选择最新版本的引擎。在该日期之后，不再提供该软件版本的任何技术服务支持。 父主题： 版本公告
Topic名称 选择待重置消费进度的Topic。 时间 选择重置消费进度的时间点，重置完成后，将从此时间点开始消费。 自定义：自定义时间点，即从自定义的时间点重新开始消费消息。 最早：最早偏移量，即从头开始消费所有消息。 最晚：最晚偏移量，即当前时间之前的所有消息全部不消费了，只从当前时间重新开始消费消息。
本文介绍了分布式消息服务RocketMQ版提供的SDK语言版本，列举了最新版本SDK的获取地址。 在线生成SDK代码 API Explorer能根据需要动态生成SDK代码功能，降低您使用SDK的难度，推荐使用。 SDK列表 表1提供了分布式消息服务RocketMQ版支持的SDK列表，您可以在GitH
List）可以实现对RocketMQ实例中生产者和消费者身份的精确识别，达到权限管理的目的。开启ACL权限控制功能后，生产消息和消费消息时，需要鉴权。 约束与限制 仅2021年8月21号后购买的实例，支持设置ACL访问控制。 开启ACL访问控制会导致没有配置认证信息的客户端连接中断。 前提条件 已购买RocketMQ实例。
x基础版产品规格由以下六个维度定义： 资源规格：定义使用的弹性云服务器的规格类型。 磁盘类型：定义存储空间的磁盘类型，包含高I/O、超高I/O、通用型SSD和极速型SSD。 存储容量：定义实例可以保存的存储容量。 实例TPS：定义实例的TPS性能。 实例Topic数上限：定义实例可以创建的Topic数量。 实例消
获取项目ID 操作场景 在调用接口的时候，部分URL中需要填入项目ID，所以需要获取到项目ID。有如下两种获取方式： 调用API获取项目ID 从控制台获取项目ID 调用API获取项目ID 项目ID可以通过调用查询指定条件下的项目信息API获取。 获取项目ID的接口为“GET https:
c和消费组生产消息、消费消息的记录。当您需要使用相同的Topic和消费组时，可通过元数据迁移操作将已有的Topic和消费组信息迁移到指定的RocketMQ实例中，无需再手动创建。 RocketMQ业务迁移主要涉及以下场景： 迁移其他RocketMQ的元数据到华为云上RocketM
务中，建议按照以下告警策略，配置监控指标的告警规则。 是否接近性能上限，表示当前资源支撑的性能为告警策略中设置的告警阈值，如果继续上升，业务可能出现问题。 表1 RocketMQ实例配置告警的指标 指标名称 正常范围 告警策略 是否接近性能上限 指标说明和告警处理建议 磁盘容量使用率
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
