生产者负载均衡
异常处理 当发送某条消息发送失败时，云消息队列 RocketMQ 版 会根据失败原因决定在接下来一段时间内，选择队列目标时跳过本地失败队列所在的节点，快速实现自适应的故障隔离。策略特点 RoundRobin模式的生产者负载均衡策略仅适用于无顺序...
消息存储和清理机制
消息在队列中的存储情况如下：消息存储管理粒度说明 云消息队列 RocketMQ 版 按照服务端节点粒度管理存储时长而非队列或主题，原因如下：消息存储优势权衡：云消息队列 RocketMQ 版 基于统一的物理日志队列和轻量化逻辑队列的二级组织方式...
QueryMqttTraceDevice-查询设备轨迹
当设备的状态出现异常时，您可以通过该接口查询指定设备的连接历史，帮助您快速定位异常原因。接口说明 每成功调用一次 QueryMqttTraceDevice 接口，都会计算为一次消息 TPS，从而影响您的计费。计费详情，请参见 计费说明。本接口的单用户...
消费者负载均衡
消费者从 云消息队列 RocketMQ 版 获取消息消费时，通过消费者负载均衡策略，可将主题内的消息分配给指定消费者分组中的多个消费者共同分担，提高消费并发能力和消费者的水平扩展能力。本文介绍 云消息队列 RocketMQ 版 消费者的负载均衡...
QueryMqttTraceMessageOfClient-查询消息轨迹
查询指定设备在一定时间段内的消息列表。当消息的收发不符合预期时，您可以通过该接口查看消息的收发状态等轨迹信息，帮助您快速定位异常原因。接口说明 每成功调用一次 QueryMqttTraceMessageOfClient 接口，都会计算为一次消息 TPS，从而...
消息堆积和延迟问题
通过了解 云消息队列 RocketMQ 版 客户端的消费原理和消息堆积的主要原因，帮助您可以在业务部署前更好的规划资源和配置，或在运维过程中及时调整业务逻辑，避免因消息堆积和延迟影响业务运行。背景信息 消息处理流程中，如果客户端的消费...
消费重试
消费者出现异常，云消息队列 RocketMQ 版 会根据消费重试策略重新投递该消息进行故障恢复。本文介绍消费重试的应用场景、原理机制、版本兼容性和使用建议。应用场景 云消息队列 RocketMQ 版 的消费重试主要解决的是业务处理逻辑失败导致的...
队列（MessageQueue）
队列的主要作用如下：存储顺序性 队列天然具备顺序性，即消息按照进入队列的顺序写入存储，同一队列间的消息天然存在顺序关系，队列头部为最早写入的消息，队列尾部为最新写入的消息。消息在队列中的位置和消息之间的顺序通过位点（Offset...
设备轨迹查询
当设备的状态出现异常时，您可以使用设备查询功能查询设备的连接历史，快速排查设备离线问题，定位异常原因。操作步骤 登录 云消息队列 MQTT 版 控制台，并在左侧导航栏单击 实例列表。在顶部菜单栏选择目标地域，然后在实例列表中单击实例...
顺序消息
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下，异构系统间需要维持强一致的状态同步，...
消息发送重试和流控机制
消息发送重试机制 重试基本概念 云消息队列 RocketMQ 版 客户端连接服务端发起消息发送请求时，可能会因为网络故障、服务异常等原因导致调用失败。为保证消息的可靠性，云消息队列 RocketMQ 版 在客户端SDK中内置请求重试逻辑，尝试通过重...
API概览
当设备与云消息队列 MQTT 版建立连接时，需要将设备访问凭证中的信息按照约定的形式设置到Username和Password中，向云消息队列 MQTT 版发起认证请求，云消息队列 MQTT 版认证通过后激活设备，设备与云消息队列 MQTT 版间才可传输数据。...
消息（Message）
消息持久化 云消息队列 RocketMQ 版 会默认对消息进行持久化，即将接收到的消息存储到 云消息队列 RocketMQ 版 服务端的存储文件中，保证消息的可回溯性和系统故障场景下的可恢复性。模型关系 在整个 云消息队列 RocketMQ 版 的领域模型中...
MQTT快速入门
说明 如果需要使用 云消息队列 MQTT 版 客户端发送顺序消息，则此处需要选用顺序Topic，但 云消息队列 MQTT 版 客户端的消费场景暂时还不支持强顺序。创建Group ID。云消息队列 MQTT 版 的Group ID用于指定一组逻辑功能完全一致的节点共用...
设备状态查询
当设备异常或消息收发不符合预期时，您可以使用设备状态查询功能查询指定设备的在线状态、订阅关系及设备轨迹和该设备的消息列表，获取MQTT客户端的状态信息，帮助您快速定位异常原因。操作步骤 登录 云消息队列 MQTT 版 控制台，并在左侧...
设备证书管理
云消息队列 MQTT 版 支持使用设备证书进行客户端的接入认证。本文介绍如何使用CA证书签发设备证书，并在 云消息队列 MQTT 版 控制台管理设备证书，包括查询证书、下载证书、激活或注销证书以及删除证书。背景信息 设备证书是由CA根证书签发...
消费进度管理
消费进度原理 消息位点（Offset）参考 云消息队列 RocketMQ 版 主题 和 队列 的定义，消息是按到达服务端的先后顺序存储在指定主题的多个队列中，每条消息在队列中都有一个唯一的Long类型坐标，这个坐标被定义为消息位点。任意一个消息队列...
通过可观测性能力进行故障处理最佳实践
本文为您介绍如何将 云消息队列 RocketMQ 版 可观测性功能应用于 云消息队列 RocketMQ 版 的故障管理场景中，为您的日常运维和故障处理提供实践方案。设计思路 核心问题 运维场景下，故障处理的核心问题如下：服务出现异常如何预警并上报 ...
顺序消息
顺序消息可以保证消息的消费顺序和发送的顺序一致，即先发送的先消费，后发送的后消费，常用于金融证券、电商业务等对消息指令顺序有严格要求的场景。本文介绍 云消息队列 RocketMQ 版 顺序消息的概念、适用场景、实现原理以及使用过程中的...
客户端连接常见问题
可能原因：设备关机、网络不通导致客户端连接断开。若您使用的是Token鉴权方式，Token到期后连接会断开，重新建立连接时客户端未获取新的Token也会导致连接失败。客户端心跳时间在哪里设置？调用 MqttConnectOptions 类。说明 在使用示例...
主题（Topic）
FIFO：顺序消息，云消息队列 RocketMQ 版 通过消息分组MessageGroup标记一组特定消息的先后顺序，可以保证消息的投递顺序严格按照消息发送时的顺序。Delay：定时/延时消息，通过指定延时时间控制消息生产后不要立即投递，而是在延时间隔后...
生产者（Producer）
消息按照到达 云消息队列 RocketMQ 版 服务端的顺序存储到主题的指定队列中。消费者按照指定的订阅关系从 云消息队列 RocketMQ 版 服务端中获取消息并消费。内部属性 客户端ID 定义：生产者客户端的标识，用于区分不同的生产者。集群内全局...
功能与特性概述
您可以将应用部署在阿里云ECS、企业自建云，或者嵌入到移动端、物联网设备中与 云消息队列 RocketMQ 版 建立连接进行消息收发；同时，本地开发者也可以通过公网接入 云消息队列 RocketMQ 版 服务进行消息收发。多协议接入 TCP协议：区别于...
消费者分类
顺序性保障 基于 云消息队列 RocketMQ 版 顺序消息 的定义，如果消费者分组设置了顺序消费模式，则PushConsumer在触发消费监听器时，严格遵循消息的先后顺序。业务处理逻辑无感知即可保证消息的消费顺序。说明 消息消费按照顺序处理的前提...
计费常见问题
本文汇总了 云消息队列 RocketMQ 版 计费的常见问题。每天扣除2元，这是什么费用？我昨天删除了Topic，为什么今天会收到账单并被扣费？我没有使用 云消息队列 RocketMQ 版 服务，为什么会扣费？我在控制台上看到没有开通 云消息队列 ...
消息轨迹
在分布式应用中，云消息队列 RocketMQ 版 作为全链路中异步解耦的关键服务，提供的消息轨迹数据可有效将业务上下游信息串联起来，帮助您更好地排查异常信息，定位问题。本文介绍消息轨迹的使用场景、云消息队列 RocketMQ 版 定义的轨迹参数...
基本概念
本文说明 云消息队列 Kafka 版 涉及的专有名词和术语，帮助您更好地理解相关概念并使用该产品。Apache Kafka 一款开源的分布式数据流处理平台，可以实时发布、订阅、存储和处理数据流。更多信息，请参见 Apache Kafka。云消息队列 Kafka 版...
查看消费者状态
如果消息消费出现异常，您可以在 云消息队列 RocketMQ 版 控制台查看指定Group ID的消费状态，包括消费者在线状态、订阅关系一致性结果、消费堆积相关指标、消费者客户端信息等，帮助您快速定位异常原因。应用场景 消费者状态信息包括在线...
死信队列
对于消费失败且重试后依然失败的消息，云消息队列 RocketMQ 版 不会立丢弃，而是将消息转发至指定的队列中，即死信队列，这些消息即为死信消息。当消费失败的原因排查并解决后，您可以重发这些死信消息，让消费者重新消费；若您暂时无法...
控制台使用相关问题
本文介绍 云消息队列 MQTT 版 控制台使用时的常见问题。云监控的最大查询范围是多少？云消息队列 MQTT 版 云监控支持查询3天以内的指标数据。为什么设备都断电了，控制台还显示设备在线？云消息队列 MQTT 版 会定时检查客户端心跳，当系统...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
订阅者最佳实践
本文主要介绍 云消息队列 Kafka 版 订阅者的最佳实践，帮助您减少消费消息出错的可能性。消费消息基本流程 云消息队列 Kafka 版 订阅者在订阅消息时的基本流程为：Poll数据→执行消费逻辑→再次Poll数据，详情参见下图。负载均衡 每个 ...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
开源对比
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品，能够兼容开源RabbitMQ客户端，与开源RabbitMQ相比，能够解决各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等...
VPC接入
如果仅需要在VPC网络接入 云消息队列 Kafka 版，您可以购买并部署VPC实例。前提条件 已授予 云消息队列 Kafka 版 访问其他云服务资源的权限。具体信息，请参见 步骤一：获取访问授权。已搭建VPC网络。具体操作，请参见 创建和管理专有网络...
公网和VPC接入
如果需要同时在VPC网络和公网接入 云消息队列 Kafka 版，您需要购买并部署公网/VPC实例。前提条件 已授予 云消息队列 Kafka 版 访问其他云服务资源的权限。具体信息，请参见 获取访问授权。已搭建VPC网络。具体操作，请参见 创建和管理专有...
为什么消息已经过期还未被删除？
磁盘容量不足（即磁盘水位达到85%）时，无论消息是否超过 消息保留时长，都将根据服务端存储消息的时间先后顺序提前删除旧的消息，以确保服务可用性。可能原因 消息所保存的Segment片段大小未超过1 GB，消息不会被删除。说明 为了减少存储...
云消息队列 Kafka 版何时删除旧消息？
当往Kafka Topic中写入数据提示磁盘空间已满或 Queue full 时，为避免因磁盘容量不足而导致机器宕机，进而影响服务可用性，云消息队列 Kafka 版 会根据磁盘使用率的多少，执行不同的消息清理策略。清理策略 磁盘使用率每天凌晨4:00集中删除...
迁移上云操作
和开源Apache RocketMQ相比，阿里云 云消息队列 RocketMQ 版 具有更高的稳定性、安全性及更完善的运维体系。您可以将开源RocketMQ集群迁移到 云消息队列 RocketMQ 版 上以获得更好的业务体验。本文为您介绍如何使用 云消息队列 RocketMQ 版...
领域模型概述
云消息队列 RocketMQ 版 通过流式特性的无限队列结构来存储消息，消息在队列内具备顺序性存储特征。消息（Message）：云消息队列 RocketMQ 版 的最小传输单元。消息具备不可变性，在初始化发送和完成存储后即不可变。消息消费 消费者分组...
- 产品推荐
- 这些文档可能帮助您