检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
查询消费列表或详情 功能介绍 查询消费列表或详情。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/groups/{group}/topics 表1 路径参数 参数 是否必选 参数类型 描述 project_id
查询主题列表 功能介绍 该接口用于查询指定RocketMQ实例的Topic列表。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/topics 表1 路径参数 参数 是否必选 参数类型 描述 project_id
版本支持公告 版本号说明 分布式消息服务RocketMQ版的版本号格式为:消息引擎类型 x.y.z,其中消息引擎类型为RocketMQ,版本号具体含义如图1所示。 图1 版本号示例 版本支持情况 分布式消息服务RocketMQ版支持的版本:4.8.0、5.x 版本生命周期 分布式
收发普通消息 本章节介绍普通消息的收发方法和示例代码。其中,普通消息发送方式分为同步发送和异步发送。RocketMQ提供PushConsumer和SimpleConsumer类型的消费者,PushConsumer消费者订阅普通消息时,代码不区分同步订阅和异步订阅。SimpleCo
发送定时消息 分布式消息服务RocketMQ版支持任意时间的定时消息,最大推迟时间可达到1年。 定时消息即生产者生产消息到分布式消息服务RocketMQ版后,消息不会立即被消费,而是延迟到设定的时间点后才会发送给消费者进行消费。 发送定时消息前,请参考收集连接信息收集RocketMQ所需的连接信息。
服务韧性 DMS for RocketMQ提供了3级可靠性架构,通过跨AZ容灾、AZ内实例容灾、实例数据多副本技术方案,保障服务的持久性和可靠性。 表1 DMS for RocketMQ可靠性架构 可靠性方案 简要说明 跨AZ容灾 DMS for RocketMQ提供跨AZ类型实
收发事务消息 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证,通过两阶段的方式提供对事务消息的支持,事务消息交互流程如图1所示。 图1 事务消息交互流程 事务消息生产者首先发送半消息,然后执行本地事务。如果执行成功,则发送事务提交,否则发送事务
功能总览 功能总览 全部 购买RocketMQ实例 连接RocketMQ实例 Topic管理 变更实例规格 公网访问 消息查询 消费组管理 用户管理 死信队列 实例诊断 收发消息 定时消息 监控 审计 API 购买RocketMQ实例 您在使用分布式消息服务RocketMQ版前,
查看RocketMQ消息 本章节指导您通过查询消息功能查看具体的消息内容,以及确定消息是否生产/消费成功。 分布式消息服务RocketMQ版提供三种消息查询的方法:按Topic查询、按Message ID查询和按Message Key查询。 按Topic查询:查询某时间段内指定T
收发普通消息 本章节介绍普通消息的收发方法和示例代码。普通消息发送方式分为同步发送和异步发送。 同步发送:消息发送方发出一条消息到服务端,服务端接收并处理消息,然后返回响应给发送方,发送方收到响应后才会发送下一条消息。 异步发送:消息发送方发出一条消息后,不等服务端返回响应,接着发送下一条消息。
变更RocketMQ实例规格 RocketMQ实例创建成功后,您可以根据业务需要,进行扩容,4.8.0版本的RocketMQ实例支持的变更配置如表1所示,5.x版本的RocketMQ实例支持的变更配置如表2所示。 表1 变更配置列表(RocketMQ实例4.8.0版本) 变更配置类型
DMS for RocketMQ安全使用建议 安全性是华为云与您的共同责任。华为云负责云服务自身的安全,提供安全的云;作为租户,您需要合理使用云服务提供的安全能力对数据进行保护,安全地使用云。详情请参见责任共担。 本文提供了如何安全使用DMS for RocketMQ的最佳实践,
收发事务消息 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证,通过两阶段的方式提供对事务消息的支持,事务消息交互流程如图1所示。 图1 事务消息交互流程 事务消息生产者首先发送半消息,然后执行本地事务。如果执行成功,则发送事务提交,否则发送事务
收发事务消息 分布式消息服务RocketMQ版的事务消息支持在业务逻辑与发送消息之间提供事务保证,通过两阶段的方式提供对事务消息的支持,事务消息交互流程如图1所示。 图1 事务消息交互流程 事务消息生产者首先发送半消息,然后执行本地事务。如果执行成功,则发送事务提交,否则发送事务
批量创建Topic RocketMQ未提供批量创建Topic接口,用户想批量创建Topic时只能手动多次调用接口一个个创建,效率低下。现通过代码实现接口循环调用,可实现批量创建Topic的效果。 前提条件 已获取IAM和RocketMQ服务所在区域的Endpoint地址。 已获取