更新时间:2025-10-21 GMT+08:00
分享

产品功能

本页面介绍了分布式消息服务RocketMQ版支持的主要功能。关于各功能支持的地域(Region)信息,可通过控制台查询详情。

购买RocketMQ实例

您在使用分布式消息服务RocketMQ版前,需要先购买RocketMQ实例。RocketMQ实例采用物理隔离的方式部署,租户独占RocketMQ实例。详情请参见购买RocketMQ实例

连接RocketMQ实例

开源RocketMQ客户端向RocketMQ实例生产消息和消费消息前,需要先连接RocketMQ实例。

购买RocketMQ实例时,加密方式支持配置为SSL。详情请参见连接实例

Topic管理

Topic,即消息主题,消息发送与接收的基本单元。购买RocketMQ实例成功后,需要手动创建Topic,然后才能进行生产消息和消费消息。详情请参见创建RocketMQ Topic

变更实例规格

RocketMQ实例创建成功后,您可以根据业务需要,扩容存储空间、代理/实例规格和代理个数。不支持同时扩容,如果需要可以分别进行扩容。详情请参见变更RocketMQ实例规格

公网访问

您需要通过公网地址访问RocketMQ实例时,开启实例的公网访问功能,并设置弹性IP地址。

只有处于“运行中”状态的RocketMQ实例支持修改公网访问配置。详情请参见配置RocketMQ实例的公网访问

消息查询

通过查询消息功能查看具体的消息内容,以及确定消息是否生产/消费成功。

分布式消息服务RocketMQ版提供了三种消息查询的方式,分别是按Topic、Message ID以及Message Key查询。详情请参见查看RocketMQ消息

消费组管理

消费组,即一组具有相同行为的消费者集合,用于管理和维护消息的消费状态。详情请参见管理消费组

用户管理

RocketMQ实例支持ACL权限控制功能,通过创建多个用户并为其赋予不同的Topic和消费组权限,以达到用户之间的权限隔离。详情请参见配置RocketMQ ACL用户

死信队列

死信队列用于处理无法被正常消费的消息。

一条消息初次消费失败会被重试消费,若重试次数达到最大值(默认16次,在客户端可配置)时,依然消费失败,则其将被投递到该消费者对应的特殊队列(即死信队列)中,这种消息被称为死信消息。

分布式消息服务RocketMQ版支持查询、导出和重新投递死信消息。详情请参见管理RocketMQ死信消息

实例诊断

使用分布式消息服务RocketMQ版消费消息时,如果遇到消息消费缓慢或者消费不到消息等消费异常的场景,借助实例诊断功能可以帮助您快速定位问题。详情请参见诊断RocketMQ实例

收发消息

您可以使用RocketMQ开源客户端访问分布式消息服务RocketMQ版来收发消息。详情请参见概述

定时消息

分布式消息服务RocketMQ版支持任意时间的定时消息,4.8.0版本的最大推迟时间为1年,5.x版本的最大推迟时间为7天。同时也支持定时消息的取消。

定时消息即生产者生产消息到分布式消息服务RocketMQ版后,消息不会立即被消费,而是延迟到设定的时间点后才会发送给消费者进行消费。详情请参见发送定时消息

标签

标签是RocketMQ实例的标识,为RocketMQ实例添加标签,可以方便用户识别和管理拥有的RocketMQ实例资源。

您可以在创建RocketMQ实例时添加标签,也可以在RocketMQ实例创建完成后,在实例的详情页添加标签。详情请参见配置RocketMQ实例标签

监控

云监控对RocketMQ实例的运行状态进行日常监控,可以通过控制台直观地查看RocketMQ实例各项监控指标。详情请参见查看监控指标与配置告警

审计

云审计服务(Cloud Trace Service,CTS),是华为云安全解决方案中专业的日志审计服务,您可以通过CTS对RocketMQ实例的操作记录进行收集、存储和查询,用于安全分析、合规审计、资源跟踪和问题定位等。详情请参见查看RocketMQ审计日志

API

分布式消息服务RocketMQ版提供了REST(Representational State Transfer)风格API,支持您通过HTTP/HTTPS请求调用,实现创建、修改、删除实例等操作。详情请参见API概览

相关文档