检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
收发普通消息 本章节介绍普通消息的收发方法和示例代码。其中，普通消息发送方式分为同步发送和异步发送。RocketMQ提供PushConsumer和SimpleConsumer类型的消费者，PushConsumer消费者订阅普通消息时，代码不区分同步订阅和异步订阅。SimpleCo
分布式消息服务RocketMQ版提供了REST（Representational State Transfer）风格API，支持您通过HTTP/HTTPS请求调用，实现创建、修改、删除实例等操作。 支持区域： 全部 API概览
理个数）。 扩容存储空间不会影响业务。 可用存储空间=实际存储空间-用于存储日志的存储空间-格式化磁盘的损耗。 例如，实际扩容存储空间到700GB，用于存储日志的存储空间为100GB，格式化磁盘损耗7GB，那么扩容后的可用存储空间为593GB。 扩容代理个数。 在“变更类型”中，
使用AK/SK认证时该字段必选。 code.test.com or code.test.com:443 Content-Type 消息体的类型（格式）。推荐用户使用默认值application/json，有其他取值时会在具体接口中说明。 是 application/json Content-Length
收发顺序消息 顺序消息是分布式消息服务RocketMQ版提供的一种严格按照顺序来发布和消费的消息类型。 顺序消息分为全局顺序消息和分区顺序消息： 全局顺序消息：对于指定的一个Topic，将队列数量设置为1，这个队列内所有消息按照严格的先入先出FIFO（First In First
task_ids 是 Array of strings 需要删除的任务列表。 响应参数 无 请求示例 删除元数据迁移任务。 DELETE https://{endpoint}/v2/{project_id}/instances/{instance_id}/metadata 响应示例 无
参数类型 描述 key String 标签键。 values Array of strings 标签值。 请求示例 查询项目标签。 GET https://{endpoint}/v2/{project_id}/rocketmq/tags 响应示例 状态码： 200 查询项目标签成功。 {
响应Body参数 参数 参数类型 描述 groups Array of strings 消费组列表。 请求示例 查询指定主题的消费组列表。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics/{topic}/groups
收发事务消息 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证，通过两阶段的方式提供对事务消息的支持，事务消息交互流程如图1所示。 图1 事务消息交互流程 事务消息生产者首先发送半消息，然后执行本地事务。如果执行成功，则发送事务提交，否则发送事务
String 应用名称。 permissions Array of strings 权限。 请求示例 查询指定消费组的详细信息。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/groups/{group}
发送定时消息 分布式消息服务RocketMQ版支持任意时间的定时消息，最大推迟时间可达到1年。 定时消息即生产者生产消息到分布式消息服务RocketMQ版后，消息不会立即被消费，而是延迟到设定的时间点后才会发送给消费者进行消费。 发送定时消息前，请参考收集连接信息收集RocketMQ所需的连接信息。
与Kafka、RabbitMQ的差异 表1 功能差异 功能项 RocketMQ Kafka RabbitMQ 优先级队列 不支持 不支持 3.8.35版本：支持。建议优先级大小设置在0-10之间。 AMQP-0-9-1版本：支持。优先级大小设置在1-9之间。 延迟队列 支持 不支持
IP白名单。 admin Boolean 是否为管理员。 perm String 权限。 请求示例 查询主题的授权用户列表。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics/{topic}/accesspolicy
remain_time Long 剩余时间。 ipv6_enable Boolean 是否支持IPv6。 请求示例 查询可用区信息。 GET https://{endpoint}/v2/available-zones?engine=reliability 响应示例 状态码： 200 查询可用区信息成功。
expression String 订阅tag字符。 请求示例 查询指定消费组的消费者列表，查询数量为10，从offset=0开始查询。 GET https://{endpoint}/v2/rocketmq/{project_id}/instances/{instance_id}/groups/{group}/clients
创建实例 功能介绍 创建实例。 调用方法 请参见如何调用API。 URI POST /v1.0/{project_id}/instances 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID，获取方式请参见获取项目ID。 请求参数 无
响应参数 状态码： 200 表3 响应Body参数 参数 参数类型 描述 job_id String 规格变更任务ID。 请求示例 POST https://{endpoint}/v2/rocketmq/{project_id}/instances/{instance_id}/extend
write_queue_num Number 写队列个数。 请求示例 查询指定RocketMQ实例的主题列表，查询数量为10，从offset=0开始查询。 GET https://{endpoint}/v2/{project_id}/instances/{instance_id}/topics?offset=0&limit=10
error_code String 错误码。 error_message String 错误信息。 请求示例 重发死信消息。 POST https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/messa
from_transaction_check Boolean 是否为事务回查的响应。 请求示例 查询RocketMQ实例的消息轨迹。 GET https://{endpoint}/v2/{engine}/{project_id}/instances/{instance_id}/trace
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
