死信队列
排查可疑因素并解决问题后，您可以在 云消息队列 RocketMQ 版 控制台重新发送该消息，让消费者重新消费一次。重要 对于顺序消息消费产生的死信消息，不支持从死信队列重新发送，您需要将消息从死信队列导出后自行处理。死信消息被重新发送...
基于Flink的资讯场景实时数仓
解决的问题 通过 云消息队列 Kafka 版 和实时计算Flink实现实时数据处理和数据流。通过 云消息队列 Kafka 版 和实时计算Flink实现实时数据分析。通过 云消息队列 Kafka 版 和实时计算Flink实现事件触发。部署架构图 选用的产品 云消息队列 ...
消息过滤
云消息队列 RocketMQ 版 主要解决的单个业务域即同一个主题内不同消息子集的过滤问题，一般是基于同一业务下更具体的分类进行过滤匹配。如果是需要对不同业务域的消息进行拆分，建议使用不同主题处理不同业务域的消息。功能概述 消息过滤...
生产者负载均衡
背景信息 了解生产者负载均衡策略，可以帮助您解决如下问题：消息发送的容灾策略：您可以根据生产者负载均衡策略，明确当局部节点出现故障时，消息发送如何进行容灾切换。消息发送的顺序性机制：通过生产者负载均衡策略，您可以进一步了解...
应用场景
为解决这些问题，可在应用和下游通知系统之间加入 云消息队列 RocketMQ 版。秒杀处理流程如下所述：用户发起海量秒杀请求到秒杀业务处理系统。秒杀处理系统按照秒杀处理逻辑将满足秒杀条件的请求发送至 云消息队列 RocketMQ 版。下游的通知...
消费者负载均衡
背景信息 了解消费者负载均衡策略，可以帮助您解决以下问题：消息消费处理的容灾策略：您可以根据消费者负载均衡策略，明确当局部节点出现故障时，消息如何进行消费重试和容灾切换。消息消费的顺序性机制：通过消费者负载均衡策略，您可以...
消息堆积和延迟问题
此时仅通过调整 云消息队列 RocketMQ 版 SDK的消费并发度并不能解决问题，需要对数据库容量进行升配才能从根本上提高客户端消费能力。消费并发度 云消息队列 RocketMQ 版 消费消息的并发度计算方法如下表所示。消息类型 消费并发度 普通...
查看Rebalance详情
当消费客户端出现Rebalance时，您可以查看Rebalance的详情，包括Rebalance的时间、耗时、次数、原因以及...后续步骤 当客户端频繁出现Rebalance时，您可以参考以下文档解决此问题：使用云消息队列 Kafka 版时消费客户端频繁出现Rebalance。
环境准备（v2.x.x）
changelog 新版本发布解决的问题和引入的新特性列表。Linux C++ SDK动态库方案 自2019年6月28日起，新版本的SDK将只提供动态库方案。云消息队列 RocketMQ 版 的库文件在 lib/目录下，需要业务方生成可执行文件时链接 librocketmq_client_...
环境准备（v2.x.x）
changelog 新版本发布解决的问题和引入的新特性列表。Linux C++ SDK动态库方案 自2019年6月28日起，新版本的SDK将只提供动态库方案。云消息队列 RocketMQ 版 的库文件在 lib/目录下，需要业务方生成可执行文件时链接 librocketmq_client_...
开源对比
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品，能够兼容开源RabbitMQ客户端，与开源RabbitMQ相比，能够解决各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等...
消费者分类
顺序性保障 基于 云消息队列 RocketMQ 版 顺序消息 的定义，如果消费者分组设置了顺序消费模式，则PushConsumer在触发消费监听器时，严格遵循消息的先后顺序。业务处理逻辑无感知即可保证消息的消费顺序。说明 消息消费按照顺序处理的前提...
环境准备
64/ONSClient4CPP.lib ONSClient4CPP.dll ONSClient4CPP.pdb vc_redist.x64.exe demo/包含了普通消息发送、Oneway消息发送、顺序消息发送、普通消息消费、顺序消息消费等代码示例。interface/封装PINVOKE调用的代码，需要包含到您的项目...
环境准备
changelog 新版本发布解决的问题和引入的新特性列表。Visual Studio 2015使用.NET SDK配置说明 使用Visual Studio 2015创建自己的项目。右键单击项目选择 添加>现存在项，将下载的SDK中的 interface 目录下的所有文件都添加进去。右键单击...
环境准备（v1.x.x）
changelog 新版本发布解决的问题和引入的新特性列表。Linux C++ SDK 自2016年12月02日开始，Linux CPP版本依赖了高性能boost库（1.62.0版本），不仅降低了CPU资源占用率，而且提高了运行效率。目前主要依赖了 boost_system、boost_thread、...
环境准备（v1.x.x）
changelog 新版本发布解决的问题和引入的新特性列表。Linux C++ SDK 自2016年12月02日开始，Linux CPP版本依赖了高性能boost库（1.62.0版本），不仅降低了CPU资源占用率，而且提高了运行效率。目前主要依赖了 boost_system、boost_thread、...
版本说明
解决共享库稳定性问题。aliyun-mq-windows-net-sdk.zip aliyun-mq-darwin-net-sdk.tar.gz 1.1.4 发布时间 发布内容 Windows版下载 2019-11-06 功能优化 支持查询顺序消息的消费轨迹。优化消息拉取流程，避免特殊情况下拉取异常造成的消息...
RocketMQ全链路追踪解决方案
链路追踪功能可在多个服务进行交互时记录请求在系统的传输过程，并提供详细的日志和性能数据，云消息队列 RocketMQ 版 支持将符合OpenTelemetry标准的Trace数据集成至阿里云的链路追踪服务中，帮助您快速诊断异常问题。Trace定义 云消息...
发布者最佳实践
黏性分区策略主要解决无Key消息分散到不同分区，造成小Batch问题。其主要策略是如果一个分区的Batch完成后，就随机选择另一个分区，然后后续的消息尽可能地使用该分区。这种策略在短时间内看，会将消息发送到同一个分区，如果拉长整个运行...
订阅者最佳实践
本文主要介绍 云消息队列 Kafka 版 订阅者的最佳实践，帮助您减少消费消息出错的可能性。消费消息基本流程 云消息队列 Kafka 版 订阅者在订阅消息时的基本流程为：Poll数据→执行消费逻辑→再次Poll数据，详情参见下图。负载均衡 每个 ...
通过可观测性能力进行故障处理最佳实践
设计思路 核心问题 运维场景下，故障处理的核心问题如下：服务出现异常如何预警并上报 出现异常问题如何快速定位 解决方案 云消息队列 RocketMQ 版 定义的Metrics、Tracing指标覆盖消息收发各阶段的状态信息、云消息队列 RocketMQ 版 服务...
消费重试
应用场景 云消息队列 RocketMQ 版 的消费重试主要解决的是业务处理逻辑失败导致的消费完整性问题，是一种为业务兜底的策略，不应该被用作业务流程控制。以下场景建议使用消息重试 业务处理失败，且失败原因跟当前的消息内容相关，比如该...
YARN调度器
还要能协调好大量应用在集群的运行，基于多租户（队列）公平性、应用优先级等策略解决好资源竞争等问题；也要能满足个别应用在节点依赖、放置策略等方面的特殊需求。YARN调度器是可拔插的插件，主要有FIFOScheduler、FairScheduler和...
自动化创建Topic相关问题
本文汇总了 云消息队列 Kafka 版 关于自动创建Topic的相关问题。是否可以自动化创建Topic？可以，但不建议。云消息队列 Kafka 版 通过阿里云控制台和OpenAPI管理Topic数据，目前不支持也不建议自动化创建Topic，主要原因如下：自动化创建...
权益分发
针对该问题，阿里云 云消息队列 RocketMQ 版 推出了权益分发解决方案。本文将以电商场景为例说明权益分发解决方案的背景信息、方案架构、以及方案优势等内容。背景信息 在电商平台运营决定对特定用户进行营销活动时，会针对不同的用户群...
可观测性体系概述
作为一款典型的分布式中间件产品，云消息队列 RocketMQ 版 被广泛应用于业务核心链路中，每条消息都关联着核心业务数据的变化，通过可观测能力及时发现问题、定位问题、解决问题对于业务运行是一项重要的保障能力。本文介绍 云消息队列 ...
Exactly-Once投递语义
云消息队列 RocketMQ 版 的Exactly-Once语义就是解决业务中最常见的一条消息的消费结果（消息在消费端计算处理的结果）在数据库系统中有且仅生效一次的问题。典型使用场景 在电商系统中，上游实时计算模块发布商品价格变更的信息，异步通知...
顺序消息
顺序消息可以保证消息的消费顺序和发送的顺序一致，即先发送的先消费，后发送的后消费，常用于金融证券、电商业务等对消息指令顺序有严格要求的场景。本文介绍 云消息队列 RocketMQ 版 顺序消息的概念、适用场景、实现原理以及使用过程中的...
实例化支持
资源隔离优化（实例化支持）云消息队列 RocketMQ 版 开放实例化功能，解决多租户之间的隔离问题，您可以在同一个地域（Region）内购买多个实例，每个实例之间逻辑隔离或者物理隔离。云消息队列 RocketMQ 版 实例分为以下两种类型：标准版：...
常见问题
客户端报错 使用云消息队列 Kafka 版时客户端的报错及解决方案 使用云消息队列 Kafka 版时出现“Not authorized to access group”的错误信息 网络问题 无法ping通云消息队列 Kafka 版的接入点 不在同一可用区内的ECS实例如何访问云消息...
队列（MessageQueue）
队列的主要作用如下：存储顺序性 队列天然具备顺序性，即消息按照进入队列的顺序写入存储，同一队列间的消息天然存在顺序关系，队列头部为最早写入的消息，队列尾部为最新写入的消息。消息在队列中的位置和消息之间的顺序通过位点（Offset...
在线教育视频直播
解决的问题 解决视频直播中手机端的推拉流问题。解决直播中手机端互发消息和消息内容的安全审核问题，同时低成本保存消息。部署架构图 选用的产品 云消息队列 RocketMQ 版 云消息队列 RocketMQ 版 是由阿里巴巴自研并捐赠给Apache基金会，...
查看消费明细
本文主要为您介绍如何查看 云消息队列 RocketMQ 版 4.x系列标准版实例的费用明细，帮助您解决如下问题：如何查看每个Topic每天的费用明细和使用量？如何查看每个Topic计费项的资源包抵扣明细？如何查看每个Topic每小时的用量明细？为什么...
如何处理消息堆积
问题现象 在使用 云消息队列 RocketMQ 版 实例时收到消息堆积告警，登录 云消息队列 RocketMQ 版 控制台 后发现了下列现象：在 Group 详情 页面，看到Group ID的 实时消息堆积量 的值高于预期。导航栏中选择 消息轨迹，单击 创建查询任务，...
版本说明
问题修复 修复顺序消息的问题。日志优化，只在ReBalance结果变化时输出日志。修复One-way请求system flag没有正常序列化到请求头的问题。aliyun-mq-windows-cpp-sdk.zip aliyun-mq-linux-cpp-sdk.tar.gz 更多历史版本 1.1.0 发布时间 发布...
顺序消息
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下，异构系统间需要维持强一致的状态同步，...
版本说明
问题修复 修复顺序消息退出的时候导致coredump的问题。无 无 1.0.7 发布时间 发布内容 Windows版下载 Linux版下载 2016-11-15 新特性 消费端消费限流，默认拉取1000条消息后放在内存里面，然后一条条回调用户的回调函数。增加顺序消息。...
什么是消息队列RabbitMQ版？
云消息队列 RabbitMQ 版 兼容开源RabbitMQ客户端，解决开源各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等云消息服务优势。核心概念 云消息队列 RabbitMQ 版 的核心概念如下：生产者：发送消息的应用...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 联合 阿里云云监控 提供了开箱即用且免费的监控报警服务，可帮助您解决如下问题：实例规格水位监控预警 若您实际使用的指标值超过实例的规格限制，云消息队列 RocketMQ 版 会进行强制限流。提前配置实例规格水位告...
使用云消息队列 Kafka 版时客户端的报错及解决方案
报错信息 客户端语言类型 报错原因 解决方案 TimeoutException Java 网络问题 客户端鉴权（sasl.mechanisms）失败 说明 该报错仅出现在 云消息队列 Kafka 版 的公网实例中。确保servers配置正确。通过 telnet 命令排除网络问题。如果网络...
- 产品推荐
- 这些文档可能帮助您