使用限制
云消息队列 RocketMQ 版 对某些具体指标进行了约束和规范，您在使用 云消息队列 RocketMQ 版 时不要超过对应的限制值，避免程序出现异常。云消息队列 RocketMQ 版5.x系列 5.x系列使用限制 云消息队列 RocketMQ 版4.x系列 4.x系列使用限制
无法ping通云消息队列 Kafka 版的接入点
当使用接入点连接Kafka连接不通或连接超时（Connection timed out），请检查您...相关文档 客户端首次接入时的常见问题，请参见 客户端首次接入云消息队列 Kafka 版时出现异常的排查方法。VPC实例可以通过 升级实例配置 升配为公网/VPC实例。
客户端首次接入云消息队列 Kafka 版时出现异常的排查...
概述 本文主要介绍客户端首次接入云消息队列 Kafka 版时，出现异常的排查方法。详细信息 客户端首次接入云消息队列 Kafka 版时如果出现异常，您可以通过以下三个方面进行排查：网络连通问题：通常有如下几种情况可能会导致网络不通，客户端...
常见问题
使用云消息队列 Kafka 版时客户端的报错及解决方案 无法ping通云消息队列 Kafka 版的接入点 客户端消费问题 订阅者最佳实践 客户端首次接入云消息队列 Kafka 版时出现异常的排查方法 使用云消息队列 Kafka 版时出现消息堆积 为什么消费客户...
CREATE QUEUE
支持以下值：TYPE：指定 normal_queue 以表示队列为正常队列，或指定 exception_queue 以表示队列为异常队列。异常队列只接受出队操作。RETRIES：INTEGER 值，指定尝试从队列中删除消息的最大次数。RETRYDELAY：DOUBLE PRECISION 值，指定...
消费重试
消费者出现异常，云消息队列 RocketMQ 版 会根据消费重试策略重新投递该消息进行故障恢复。本文介绍消费重试的应用场景、原理机制、版本兼容性和使用建议。应用场景 云消息队列 RocketMQ 版 的消费重试主要解决的是业务处理逻辑失败导致的...
消费进度管理
云消息队列 RocketMQ 版 通过消费位点管理消费进度，本文为您介绍 云消息队列 RocketMQ 版 的消费进度管理机制。背景信息 云消息队列 RocketMQ 版 的生产者和消费者在进行消息收发时，必然会涉及以下场景，消息先生产后订阅或先订阅后生产...
使用限制
云消息队列 Kafka 版 对某些具体指标进行了约束和规范，您在使用 云消息队列 Kafka 版 时注意不要超过相应的限制值，以免程序出现异常。重要 若由于您的实例配置超出使用限制导致的任何不稳定情况，不在SLA承诺和赔偿范围内。云消息队列 ...
查看消费者状态
如果消息消费出现异常，您可以在 云消息队列 RocketMQ 版 控制台查看指定Group ID的消费状态，包括消费者在线状态、订阅关系一致性结果、消费堆积相关指标、消费者客户端信息等，帮助您快速定位异常原因。应用场景 消费者状态信息包括在线...
企业铂金版生命周期管理
升降配影响 云消息队列 RocketMQ 版 控制台和实例中每个服务节点可能出现秒级闪断，客户端有自动重试机制，一般不会影响业务，但会有异常日志产生，可能会有消息延迟的现象。消息可能会有重复，建议做好消息幂等处理。具体操作，请参见 ...
实例升降配
升配操作：将实例从标准版变更为专业版 降配操作：将实例从专业版变更为标准版 生效时间 云消息队列 RocketMQ 版 控制台和实例中每个服务节点可能出现秒级闪断，客户端有自动重试机制，一般不会影响业务，但会有异常日志产生，可能会有消息...
API概览
当设备的状态出现异常时，您可以通过该接口查询指定设备的连接历史，帮助您快速定位异常原因。QueryMqttTraceMessageOfClient 查询消息轨迹 查询指定设备在一定时间段内的消息列表。当消息的收发不符合预期时，您可以通过该接口查看消息的...
通过可观测性能力进行故障处理最佳实践
设计思路 核心问题 运维场景下，故障处理的核心问题如下：服务出现异常如何预警并上报 出现异常问题如何快速定位 解决方案 云消息队列 RocketMQ 版 定义的Metrics、Tracing指标覆盖消息收发各阶段的状态信息、云消息队列 RocketMQ 版 服务...
消息存储和清理机制
本文为您介绍 云消息队列 RocketMQ 版 中消息的存储机制，包括消息的存储粒度、判断依据及后续处理策略等。背景信息 参考 云消息队列 RocketMQ 版 中 队列 的定义，消息按照达到服务器的先后顺序被存储到队列中，理论上每个队列都支持无限...
消息发送重试和流控机制
背景信息 消息发送重试 云消息队列 RocketMQ 版 的消息发送重试机制主要为您解答如下问题：部分节点异常是否影响消息发送？请求重试是否会阻塞业务调用？请求重试会带来什么不足？消息流控 云消息队列 RocketMQ 版 的流控机制主要为您解答...
生产者负载均衡
极大增加了服务端的存储压力，导致出现队列热点，不利于主题处理能力的水平扩展。因此，建议您在设计消息组时，尽量将消息分散开。例如，采用较离散的订单ID、用户名作为消息组的关键字，既能保证消息被分散到多个消息组中，又能保证同一...
事务消息
事务超时机制 云消息队列 RocketMQ 版 事务消息的生命周期存在超时机制，即半事务消息被生产者发送服务端后，如果在指定时间内服务端无法确认提交或者回滚状态，则消息默认会被回滚。事务超时时间，请参见 参数限制。不支持多个sendReceipt...
定时/延时消息
若存储系统异常重启，可能会导致定时消息投递出现一定延迟。使用示例 和普通消息相比，定时消费发送时，必须设置定时触发的目标时间戳。以Java语言为例，使用定时消息示例参考如下：完整的消息收发示例代码请参见 RocketMQ 5.x系列SDK...
顺序消息
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下，异构系统间需要维持强一致的状态同步，...
新功能发布记录
新增 开服地域 计费规则（包年包月计费）计费规则（按量计费）服务接入点 2022-04-02 功能名称 功能描述 功能类型 相关文档 实例风险 云消息队列 Kafka 版 实例定期检测功能支持异常指标项风险报警、提供风险修复建议并发送报警通知给相关...
消费者分类
云消息队列 RocketMQ 版 支持PushConsumer和SimpleConsumer这两种类型的消费者，本文分别从使用方式、实现原理、可靠性重试和适用场景等方面为您介绍这两种类型的消费者。背景信息 云消息队列 RocketMQ 版 面向不同的业务场景提供了不同...
消息过滤
消费者订阅了某个主题后，云消息队列 RocketMQ 版 会将该主题中的所有消息投递给消费者。若消费者只需要关注部分消息，可通过设置过滤条件在 云消息队列 RocketMQ 版 服务端进行过滤，只获取到需要关注的消息子集，避免接收到大量无效的...
什么是消息队列RabbitMQ版？
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构...使用限制 云消息队列 RabbitMQ 版 对集群、接口调用以及字符进行了限制，您在 云消息队列 RabbitMQ 版 时注意不要超过相应的限制值，以免程序出现异常。更多信息，请参见 使用限制。
生产者（Producer）
事务检查器 定义：云消息队列 RocketMQ 版 的事务消息机制中，为保证异常场景下事务的最终一致性，生产者需要主动实现事务检查器的接口。具体信息，请参见 事务消息。发送事务消息时，事务检查器必须设置，且需要和预绑定主题列表一起配合...
使用限制
云消息队列 RocketMQ 版 对某些具体指标进行了约束和规范，您在使用 云消息队列 RocketMQ 版 时注意不要超过相应的限制值，以免程序出现异常。限制项 限制值 说明 Topic名称长度 64个字符 Topic名称长度不得超过该限制，否则会导致无法发送...
使用Canal和RocketMQ实现数据库变更订阅处理
false 链路轨迹追踪设置 使用Canal发送变更事件到 云消息队列 RocketMQ 版 时，可以选择开启 云消息队列 RocketMQ 版 的云上消息轨迹功能，以便出现异常时可以快速定位链路问题。开启链路轨迹追踪功能，需要设置如下参数：rocketmq.enable....
使用Canal和RocketMQ实现数据库变更订阅处理
false 链路轨迹追踪设置 使用Canal发送变更事件到 云消息队列 RocketMQ 版 时，可以选择开启 云消息队列 RocketMQ 版 的云上消息轨迹功能，以便出现异常时可以快速定位链路问题。开启链路轨迹追踪功能，需要设置如下参数：rocketmq.enable....
配额与限制
云消息队列 RocketMQ 版 对实例的资源配额、实例规格和相关参数进行了约束和规范，您在使用 云消息队列 RocketMQ 版 时不要超过对应的限制值，避免应用出现异常。参数限制 以下参数中各资源的命名及备注等限制值不支持调整，请严格按照规范...
QueryMqttTraceDevice-查询设备轨迹
当设备的状态出现异常时，您可以通过该接口查询指定设备的连接历史，帮助您快速定位异常原因。接口说明 每成功调用一次 QueryMqttTraceDevice 接口，都会计算为一次消息 TPS，从而影响您的计费。计费详情，请参见 计费说明。本接口的单用户...
使用限制
本文为您介绍 云消息队列 MQTT 版 对某些具体指标的约束和规范，您在使用 云消息队列 MQTT 版 时请不要超过相应的限制值，以免程序出现异常。具体的限制项和限制值请参见下表。如果您购买了铂金版的 云消息队列 MQTT 版 实例，则可按需定制...
MQTT和RocketMQ进行数据互通（跨产品数据流入）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...
MQTT和RocketMQ进行数据互通（跨产品数据流出）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
能否通过公网访问云消息队列 Kafka 版实例？
网络类型为公网/VPC的 云消息队列 Kafka 版 实例支持通过公网访问。云消息队列 Kafka 版 提供VPC和公网/VPC两种网络类型的实例。如需通过公网访问，请购买公网/VPC实例。...说明 中国内地与非中国内地通过公网连接可能会出现异常。
轨迹查询
当设备的状态出现异常时，您可以使用设备轨迹查询功能，查询设备的连接历史；当消息的收发不符合预期时，您可以使用消息轨迹查询功能，查询消息的收发轨迹。查询设备轨迹 登录 云消息队列 MQTT 版 控制台，在顶部菜单栏选择地域（Region）...
配置消息日志
当消息的发送、消费、确认出现异常时，您可在日志服务查询并分析消息的操作日志，进行异常诊断。前提条件 创建 云消息队列 RabbitMQ 版 实例。具体操作，请参见 实例管理。开通日志服务并创建Project和Logstore。具体操作，请参见 资源管理...
迁移上云操作
注意事项 执行切流操作时，每切换一次Topic状态，请及时观察消息收发是否符合预期，若无异常再执行下一步切换操作，若消息收发出现异常可直接回滚操作，待异常原因排查后继续进行切流操作。请确保此次迁移任务范围内的Topic均完成切流操作...
重置消费位点
当消费出现异常或者当前消费位点不符合您的预期时，您可以通过重置消费位点调整您的消费进度。云消息队列 RocketMQ 版 支持以下方式重置消费位点：从最新位点开始消费 消费者消费指定Topic中的消息时，会跳过当前堆积（未被消费）的所有...
设备轨迹查询
当设备的状态出现异常时，您可以使用设备查询功能查询设备的连接历史，快速排查设备离线问题，定位异常原因。操作步骤 登录 云消息队列 MQTT 版 控制台，并在左侧导航栏单击 实例列表。在顶部菜单栏选择目标地域，然后在实例列表中单击实例...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
消费者负载均衡
队列分配运维更方便 传统基于绑定队列的负载均衡策略，必须保证队列数量大于等于消费者数量，以免产生部分消费者获取不到队列出现空转的情况，而消息粒度负载均衡策略则无需关注队列数。适用场景 消息粒度消费负载均衡策略下，同一队列内的...
- 产品推荐
- 这些文档可能帮助您