配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
收发顺序消息
消息消费处理失败或者处理出现异常，返回OrderAction.Suspend。2.消息处理成功，返回OrderAction.Success。Override public OrderAction consume(Message message,ConsumeOrderContext context){ System.out.println(message);return ...
企业铂金版生命周期管理
升降配影响 云消息队列 RocketMQ 版 控制台和实例中每个服务节点可能出现秒级闪断，客户端有自动重试机制，一般不会影响业务，但会有异常日志产生，可能会有消息延迟的现象。消息可能会有重复，建议做好消息幂等处理。具体操作，请参见 ...
实例升降配
升配操作：将实例从标准版变更为专业版 降配操作：将实例从专业版变更为标准版 生效时间 云消息队列 RocketMQ 版 控制台和实例中每个服务节点可能出现秒级闪断，客户端有自动重试机制，一般不会影响业务，但会有异常日志产生，可能会有消息...
消费幂等
为了防止消息重复消费导致业务处理异常，消息队列RocketMQ版 的消费者在接收到消息后，有必要根据业务上的唯一Key对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的情况...
集成概述
系统自动或手动创建任务位点Topic、任务配置Topic、任务状态Topic、死信队列Topic、异常数据Topic等资源。跨账号传输 暂不支持。如有需求 请 提交工单 申请。支持。消费线程并发数 可自定义配置32以内的消费线程并发数。仅支持配置以下选项...
查看消费状态
当Kafka出现消费堆积、倾斜、流量被限流等异常时，您可以查看Group和Topic之间的订阅关系，获取Topic各个分区的消费进度，了解消息的堆积总量，及时调整业务、预防风险。注意事项 建议一个消费组不要订阅超过三个Topic，避免消息堆积。当您...
订阅关系（Subscription）
行为约束 订阅关系一致 云消息队列 RocketMQ 版 是按照消费者分组粒度管理订阅关系，因此，同一消费者分组内的消费者在消费逻辑上必须保持一致，否则会出现消费冲突，导致部分消息消费异常。正确示例/Consumer c1 Consumer c1=...
TCP协议客户端大版本发布
云消息队列 RocketMQ 版 于2021年10月18日发布新版本Java SDK和C++ SDK客户端，本次发布对客户端大版本进行了升级。本文介绍发布的SDK版本信息、支持升级的地域以及主要的功能差异。SDK版本信息 本次发布的SDK客户端版本信息如下：协议 ...
生产者负载均衡
生产者发送消息到 云消息队列 RocketMQ 版 服务端时，云消息队列 RocketMQ 版 将根据生产者负载均衡策略将消息均匀的存储在多个队列中，避免产生热点队列和性能瓶颈。本文介绍 云消息队列 RocketMQ 版 生产者的负载均衡策略。背景信息 了解...
查看分区状态
当Kafka集群出现消息堆积、磁盘水位过高等异常情况时，可查看分区状态了解服务端的消息量及各个分区的消费进度，定位异常原因。前提条件 已创建Topic 操作步骤 登录 云消息队列 Kafka 版 控制台。在 概览 页面的 资源分布 区域，选择地域。...
消息检索
名称格式如下：任务位点Topic：connect-offset-{任务名称} 任务配置Topic：connect-config-{任务名称} 任务状态Topic：connect-status-{任务名称} 死信队列Topic/异常数据Topic：connect-error-{任务名称} Connector消费组：connect-{任务...
定时/延时消息
若存储系统异常重启，可能会导致定时消息投递出现一定延迟。使用示例 和普通消息相比，定时消费发送时，必须设置定时触发的目标时间戳。以Java语言为例，使用定时消息示例参考如下：完整的消息收发示例代码请参见 RocketMQ 5.x系列SDK...
常见问题
消息发送时出现有关消息不合法的异常信息 消息消费常见问题 客户端首次接入连接不上服务端，收不到消息如何排查？订阅关系不一致如何处理？如何处理消息堆积？消费者消费不到消息如何处理？若某个消费组下的机器宕机，机器重启期间，消息...
常见问题
消息发送时出现有关消息不合法的异常信息 消息消费常见问题 客户端首次接入连接不上服务端，收不到消息如何排查？订阅关系不一致如何处理？如何处理消息堆积？消费者消费不到消息如何处理？若某个消费组下的机器宕机，机器重启期间，消息...
消息存储和清理机制
当消费者不在线或消息消费异常时，会造成队列中大量消息堆积，且该现象暂时无法有效控制。若此时按照消费状态考虑将未消费的消息全部保留，则很容易导致存储空间不足，进而影响到新消息的读写速度。根据统一地存储时长管理消息，可以帮助...
消息发送重试和流控机制
背景信息 消息发送重试 云消息队列 RocketMQ 版 的消息发送重试机制主要为您解答如下问题：部分节点异常是否影响消息发送？请求重试是否会阻塞业务调用？请求重试会带来什么不足？消息流控 云消息队列 RocketMQ 版 的流控机制主要为您解答...
重试和死信
容错策略 容错策略即在错误发生时的处理方式，目前支持两类容错方式：允许容错（推荐）：允许异常容错，当异常发生时不会阻塞执行，超过最大重试次数后会根据配置将消息投递至死信队列或直接丢弃。禁止容错：不允许容错，当异常发生并超过...
重试和死信
容错策略 容错策略即在错误发生时的处理方式，目前支持两类容错方式：允许容错（推荐）：允许异常容错，当异常发生时不会阻塞执行，超过最大重试次数后会根据配置将消息投递至死信队列或直接丢弃。禁止容错：不允许容错，当异常发生并超过...
重试和死信
容错策略 容错策略即在错误发生时的处理方式，目前支持两类容错方式：允许容错（推荐）：允许异常容错，当异常发生时不会阻塞执行，超过最大重试次数后会根据配置将消息投递至死信队列或直接丢弃。禁止容错：不允许容错，当异常发生并超过...
计费概述
因此，您的 阿里云产品消费汇总 中，会出现 云消息队列 RocketMQ 版 的产品消费明细。实例类型和计费模式 云消息队列 MQTT 版 提供的实例类型及其计费方式如下，如需了解实例类型间的功能差异，请参见 实例类型。实例类型 计费模式 说明 ...
新功能发布记录
新增 开服地域 计费规则（包年包月计费）计费规则（按量计费）服务接入点 2022-04-02 功能名称 功能描述 功能类型 相关文档 实例风险 云消息队列 Kafka 版 实例定期检测功能支持异常指标项风险报警、提供风险修复建议并发送报警通知给相关...
RocketMQ全链路追踪解决方案
在分布式应用系统中，多个服务间的交互涉及复杂的网络通信和数据传输，往往一次请求需要多个内部服务间的相互调用才能完成，任何一个环节出现问题都可能导致外部服务任务执行失败或延时，且很难快速定位问题根源。链路追踪功能可在多个服务...
重试和死信
容错策略 容错策略即在错误发生时的处理方式，目前支持两类容错方式：允许容错（推荐）：允许异常容错，当异常发生时不会阻塞执行，超过最大重试次数后会根据配置将消息投递至死信队列或直接丢弃。禁止容错：不允许容错，当异常发生并超过...
事务消息
事务消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 分布式事务的诉求 分布式系统调用的特点为一个核心业务逻辑的执行，同时需要调用多个下游业务...
使用云消息队列 Kafka 版时客户端的报错及解决方案
报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端鉴权（sasl.mechanisms）失败 说明 该报错仅出现在 云消息队列 Kafka 版 的公网实例中。确保servers配置正确。通过 telnet 命令排除网络问题。如果网络...
顺序消息
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下，异构系统间需要维持强一致的状态同步，...
发布者最佳实践
在消息没有指定Key的情况下，云消息队列 Kafka 版 2.4版本之前的默认策略是循环使用主题的所有分区，将消息以轮询的方式发送到每一个分区上。但是，这种默认策略Batch的效果会比较差，在实际使用中，可能会产生大量的小Batch，从而使得实际...
如何处理消息堆积
问题现象 在使用 云消息队列 RocketMQ 版 实例时收到消息堆积告警，登录 云消息队列 RocketMQ 版 控制台 后发现了下列现象：在 Group 详情 页面，看到Group ID的 实时消息堆积量 的值高于预期。导航栏中选择 消息轨迹，单击 创建查询任务，...
查看实例风险
云消息队列 Kafka 版 实例的实时诊断功能能够定期对实例进行检测，支持查看诊断发现的问题、提供修复建议，并将异常的检查项上报告警给相关联系人，帮助您及时处理异常。实现方案 检测项 说明 若检测出实例存在风险，请参考控制台上提示的...
消费者分类
云消息队列 RocketMQ 版 支持PushConsumer和SimpleConsumer这两种类型的消费者，本文分别从使用方式、实现原理、可靠性重试和适用场景等方面为您介绍这两种类型的消费者。背景信息 云消息队列 RocketMQ 版 面向不同的业务场景提供了不同...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的Java SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装Java SDK。更多信息，请参见 准备...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的Java SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格...
快速使用MQTT的Java SDK收发消息（终端和终端消息收发...
在以下使用情况中出现的问题 云消息队列 MQTT 版 产品方概不负责：终端或云端不使用域名接入而是使用IP地址接入，产品方更新了域名解析导致原有IP地址失效。终端或云端网络侧对IP地址设置网络防火墙策略，产品方更新了域名解析后新IP地址被...
收发定时消息和延时消息
背景信息 延时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时消息。定时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端...
客户端连接常见问题
本文介绍 云消息队列 MQTT 版 客户端连接服务端时的常见问题。使用安卓的Demo，返回连接失败报错。问题描述 资源填写正确，且网络可以连通。AK（AccessKey ID）、SK（AccessKey Secret）填写正确且已授权。可能原因 接入点格式不正确，正确...
查看实例风险
云消息队列 Kafka 版 实例的实时诊断功能能够定期对实例进行检测，支持查看诊断发现的问题、提供修复建议，并将异常的检查项上报告警给相关联系人。实现方案 报警通知说明 仅紧急且不健康的报警会发送报警通知。如果未添加报警联系人，则...
快速使用MQTT的Java SDK收发消息（终端和云端消息收发...
在以下使用情况中出现的问题 云消息队列 MQTT 版 产品方概不负责：终端或云端不使用域名接入而是使用IP地址接入，产品方更新了域名解析导致原有IP地址失效。终端或云端网络侧对IP地址设置网络防火墙策略，产品方更新了域名解析后新IP地址被...
步骤三：调用SDK收发消息
云消息队列 RocketMQ 版 提供多种语言的SDK用于收发不同类型的消息，本文以Java SDK为例，说明如何调用SDK连接 云消息队列 RocketMQ 版 服务端，完成普通消息的收发流程。前提条件 步骤二：创建资源 安装IDEA 您可以使用IntelliJ IDEA或者...
消息过滤
消费者订阅了某个主题后，云消息队列 RocketMQ 版 会将该主题中的所有消息投递给消费者。若消费者只需要关注部分消息，可通过设置过滤条件在 云消息队列 RocketMQ 版 服务端进行过滤，只获取到需要关注的消息子集，避免接收到大量无效的...
- 产品推荐
- 这些文档可能帮助您