日志配置
重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...
通过元数据文件迁移上云
无 evaluate 是否获取当前机器规格、近期存储情况、流量、Kafka集群配置信息，在迁移时根据获取的信息进行评估，推荐您购买规格更合适的 云消息队列 Kafka 版 实例。默认为true，即默认获取以进行规格评估，如果不需要评估，则需设置为...
日志配置
推荐您使用最新版本的日志。重要 应用中同时依赖Log4j和Logback的日志实现会造成日志冲突导致客户端日志打印混乱。请确保应用只依赖其中一个日志实现，您可以通过 mvn clean dependency:tree|grep log 命令进行排查。客户端日志配置项 客户...
消息轨迹
取值如下：成功 失败 消息基础信息 消息类型 普通消息 顺序消息 定时/延时消息 事务消息 消息ID 消息的全局唯一标识，由 云消息队列 RocketMQ 版 系统自动生成。Topic 消息所属的主题名称。消息Keys MessageKey，消息的业务标识，由消息...
使用云消息队列 Kafka 版时客户端的报错及解决方案
在使用云消息队列 Kafka 版时，客户端可能报错，您可以根据报错消息匹配对应的解决方案。详细信息 报错信息对应的详细信息如下。报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端鉴权（sasl.mechanisms）...
查询消息轨迹
云消息队列 RocketMQ 版 将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数，例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等，并支持可视化查询。当消息收发结果不符合预期...
集群消费和广播消费
广播模式下，每条消息都会被大量的客户端重复处理，因此推荐尽可能使用集群模式。请保持消费模式一致性，即一个Group下的所有消费者都设置相同的消费模式，如果消费模式混用则全部以广播消费为准。例如，同一个Group下有5个Consumer，其中2...
Topic分区倾斜怎么办？
可能原因 创建Topic时没有按照推荐的倍数设置分区数。解决方案 登录 云消息队列 Kafka 版 控制台，在左侧导航栏，单击 实例列表。在顶部菜单栏，选择地域，然后在 实例列表 页面单击目标实例名称。在左侧导航栏，单击 Topic管理，然后单击...
广播拉取消息模型
说明 本文以Java SDK为例介绍广播拉取消息流程，其他语言SDK请参见 新版SDK参考（推荐）。前提条件 安装IDEA 您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。安装1.8或以上版本JDK 安装2.5或以上版本Maven 背景信息 消息...
事务消息
以Java语言为例，使用事务消息示例参考如下：完整的消息收发示例代码请参见 RocketMQ 5.x系列SDK（推荐）。演示demo，模拟订单表查询服务，用来确认订单事务是否提交成功。private static boolean checkOrderById(String orderId){ return ...
基本概念
消息堆积量=处理中消息量+已就绪消息量，具体的指标含义，可参考以下说明：上图表示指定主题的某一队列中各消息的状态，云消息队列 RocketMQ 版 将处于不同处理阶段的消息数量和耗时进行统计，这些指标可直接反映队列中消息的处理速率和...
顺序消息
顺序消息可以保证消息的消费顺序和发送的顺序一致，即先发送的先消费，后发送的后消费，常用于金融证券、电商业务等对消息指令顺序有严格要求的场景。本文介绍 云消息队列 RocketMQ 版 顺序消息的概念、适用场景、实现原理以及使用过程中的...
基本概念
消息堆积 生产者已经将消息发送到 云消息队列 RocketMQ 版 的服务端，但由于消费者的消费能力有限，未能在短时间内将所有消息正确消费掉，此时在 云消息队列 RocketMQ 版 的服务端保存着未被消费的消息，该状态即消息堆积。事务消息 事务...
定时和延时消息
概念介绍 定时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是推迟到在当前时间点之后的某一个时间投递到Consumer进行消费，该消息即定时消息。延时消息：Producer将消息发送到 云消息队列 ...
消息轨迹
消息轨迹是指一条消息从生产者发送到 云消息队列 RabbitMQ 版 服务端，再到消费者消费，整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整链路信息。如果消息收发不符合预期，您可以通过查询消息轨迹，快速分析和定位问题，及时...
死信队列
对于消费失败且重试后依然失败的消息，云消息队列 RocketMQ 版 不会立丢弃，而是将消息转发至指定的队列中，即死信队列，这些消息即为死信消息。当消费失败的原因排查并解决后，您可以重发这些死信消息，让消费者重新消费；若您暂时无法...
消息（Message）
消息持久化 云消息队列 RocketMQ 版 会默认对消息进行持久化，即将接收到的消息存储到 云消息队列 RocketMQ 版 服务端的存储文件中，保证消息的可回溯性和系统故障场景下的可恢复性。模型关系 在整个 云消息队列 RocketMQ 版 的领域模型中...
功能与特性概述
消息类型对比 消息类型 是否支持可靠同步发送 是否支持可靠异步发送 是否支持Oneway发送 是否支持多线程发送 性能 普通消息 是 是 是 是 最高 事务消息 定时和延时消息 分区顺序消息 是 否 否 否 高 全局顺序消息 一般 消息特性 消息重试：...
消息查询
在使用Kafka的过程中遇到无法正确消费消息、消息丢失、消息延迟等消费问题时，您可通过消息查询功能查看指定消息的详细内容和相关属性，帮助您排查异常原因。若确定消息所在Topic的分区ID以及消息位点，可采用按位点查询消息；若不确定消息...
回执消息简介与配置流程
当您使用 ChatApp 消息服务 API接口发送消息后，可以通过MNS消息队列消费模式或HTTP批量推送模式来接收消息发送状态的结果和用户回复的消息内容。背景信息 如果出现网络异常、响应超时等情况，可能会导致回执消息推送重复、回执消息获取...
死信消息
消息消费异常时会自动进行消费重试，达到最大重试次数后还未成功，则消息会转为死信状态。云消息队列 RocketMQ 版 支持将这些死信消息保存至指定Topic，方便后续进行业务恢复或回溯。本文介绍死信消息的应用场景、死信策略、使用限制、配置...
仪表盘
处理中消息量＋已就绪消息量 消息耗时指标 已就绪消息的就绪时间（ready time）普通消息、顺序消息：消息存储到服务端的时间。定时/延时消息：消息定时或延时结束的时间。事务消息：事务提交的时间。不涉及 已就绪消息的排队时间（ready ...
主题（Topic）
单一消息主题混用 例如，创建主题时消息类型定义为普通消息，发送消息时同时发送普通消息和顺序消息到该主题中，则顺序消息的发送请求会被拒绝，并返回类型不匹配异常。版本兼容性 消息类型的强制校验，仅针对 云消息队列 RocketMQ 版 服务...
消息过滤
消息服务MNS 的消息过滤功能是指将一个主题的消息通过不同的标签推送到不同的订阅渠道。本文介绍消息过滤的功能以及如何设置消息过滤标签。背景信息 通常情况下，在主题中创建订阅可以将消息推送至已订阅的推送目标。即消息没有设置消息...
事务消息
半事务消息：暂不能投递的消息，生产者已经成功地将消息发送到了 云消息队列 RocketMQ 版 服务端，但是 云消息队列 RocketMQ 版 服务端未收到生产者对该消息的二次确认，此时该消息被标记成“暂不能投递”状态，处于该种状态下的消息即半...
消息存储和清理机制
本文为您介绍 云消息队列 RocketMQ 版 中消息的存储机制，包括消息的存储粒度、判断依据及后续处理策略等。背景信息 参考 云消息队列 RocketMQ 版 中 队列 的定义，消息按照达到服务器的先后顺序被存储到队列中，理论上每个队列都支持无限...
消息检索
当 云消息队列 Kafka 版 控制台提供的按位点查询和按时间查询消息的功能无法满足您搜索消息的需求时，您可以使用 云消息队列 Kafka 版 消息检索功能。消息检索支持按Topic分区、位点范围、时间范围以及消息Key和Value关键字检索。本文介绍...
消息收发流程变更
云消息队列 MQTT 版 V2.x.x版本强依赖 云消息队列 RocketMQ 版 作为消息存储，因此 云消息队列 MQTT 版 消息和 云消息队列 RocketMQ 版 天然打通，创建了Topic后即可天然使用 云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 的SDK相互通信...
名词解释
如需实现消息幂等，即如果消息重试多次，消费端对该重复消息消费多次与消费一次的结果是相同的，并且多次消费没有对系统产生副作用，在为每条消息设置唯一Message ID的基础上，您还需要在 云消息队列 RabbitMQ 版 的Consumer客户端对消息...
消息过滤
场景示例 以下图电商交易场景为例，从客户下单到收到商品这一过程会生产一系列消息，按照类型将消息分为订单消息和物流消息，其中给物流消息定义地域属性，按照地域分为杭州和上海：订单消息 物流消息 物流消息且地域为杭州 物流消息且地域...
队列模型基本概念
本文对 消息服务MNS 的队列模型涉及的专有名词及术语进行定义和解析，方便您更好地理解相关概念并使用队列模型。Account 用户的阿里云账号ID。队列（Queue）消息存储的目的地，分成普通队列和延时队列两类。消息包含数据和属性，可以分成...
生产者负载均衡
生产者发送消息到 云消息队列 RocketMQ 版 服务端时，云消息队列 RocketMQ 版 将根据生产者负载均衡策略将消息均匀的存储在多个队列中，避免产生热点队列和性能瓶颈。本文介绍 云消息队列 RocketMQ 版 生产者的负载均衡策略。背景信息 了解...
普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。说明 您在调用SDK收发消息时需注意，云消息队列 RocketMQ 版 提供的四种消息类型所对应的Topic不能混用，例如，您创建的普通消息...
QueueMessage
发送消息时可以指定消息体、消息延时时长、消息优先级。本文介绍队列消息的消息属性、消息类型、消息状态。消息属性 MessageId 消息编号。（batch）send message、receive message和peek message操作返回该属性。一个队列中每个消息都有...
消息存活时间
什么是消息存活时间 在 云消息队列 RabbitMQ 版 中，消息存活时间用于限制消息在Queue中可以存在的时间，如果消息在Queue中存在的时间超过了设置的消息存活时间，消息将会被进行如下处理：若您未给Queue设置死信Exchange，消息将被Queue...
全球消息路由定价详情
说明 云消息队列 RocketMQ 版 有4种消息类型：普通消息、定时和延时消息、事务消息以及顺序消息，其中，定时和延时消息、事务消息以及顺序消息为高级特性消息。更多信息，请参见 消息类型列表。消息体大小最大限制为4 MB，大小以4 KB为计量...
消费重试
消费者出现异常，云消息队列 RocketMQ 版 会根据消费重试策略重新投递该消息进行故障恢复。本文介绍消费重试的应用场景、原理机制、版本兼容性和使用建议。应用场景 云消息队列 RocketMQ 版 的消费重试主要解决的是业务处理逻辑失败导致的...
什么是消息服务MNS
消息投递 消息服务MNS 支持消息推送到队列：推送到队列 广播拉取消息模型 消息投递保障 在消息有效期内，保证发布到主题中的消息会按照指定的策略和格式推送给用户端程序。推送策略包括：退避重试（BACKOFF_RETRY）重试3次。每次重试的间隔...
消息服务MNS
本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建消息流入任务，将 消息服务MNS 中的数据快速导入至 云消息队列 RabbitMQ 版。前提条件 您已创建 消息服务MNS 队列。具体步骤，请参见 开通消息服务MNS并授权。您已购买 云消息队列 ...
推送到队列
消息服务MNS 支持把发布到主题的消息推送到队列。本文介绍如何将消息推送到队列。步骤一：创建队列 登录 消息服务MNS控制台。在左侧导航栏，单击 队列列表。在顶部菜单栏，选择地域。在 队列列表 页面，单击 创建队列。在 创建队列 面板...
- 产品推荐
- 这些文档可能帮助您