消息处理时长自适应
需要这个的原因是，例如消息register的时候已经只剩下0.1秒的超时时间了，注册进来也来不及ChangeVisibility延长生命。所以，MessageMinimalLife是为了确保消息能活到被ChangeVisibility，用户可以自己根据业务压力来设置。TimerInterval是...
配额与限制
云消息队列 RocketMQ 版 对实例的资源配额、实例规格和相关参数进行了约束和规范，您在使用 云消息队列 RocketMQ 版 时不要超过对应的限制值，避免应用出现异常。参数限制 以下参数中各资源的命名及备注等限制值不支持调整，请严格按照规范...
领域模型概述
消息队列RocketMQ版领域模型 如上图所示，云消息队列 RocketMQ 版 中消息的生命周期主要分为消息生产、消息存储、消息消费这三部分。生产者生产消息并发送至 云消息队列 RocketMQ 版 服务端，消息被存储在服务端的主题中，消费者通过订阅...
开源对比
项目 云消息队列 Kafka 版 Apache Kafka 差异原因 Topic 创建方式 云消息队列 Kafka 版 控制台 云消息队列 Kafka 版 OpenAPI 服务端自动创建（默认不开启）Kafka CLI Kafka Manager 服务端自动创建 云消息队列 Kafka 版 默认通过阿里云控制...
基本概念
实例 一个独立的 云消息队列 Kafka 版 资源实体，对应一个集群。VPC实例 仅提供专有网络VPC接入点，只能通过专有网络VPC访问。公网/VPC实例 提供公网接入点和专有网络VPC接入点，可以通过公网访问，也可以通过专有网络VPC访问。升级大版本 ...
配置消息监控告警实现风险预警
背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格的实例都有明确的 SLA保障，您购买实例后即可保证消息收发TPS、消息存储、网络吞吐等指标达到规格规定的能力。您无需担心实例性能问题，但实际生产环境中仍需要关注...
消息服务MNS中删除消息时报“message not exist”的...
本文介绍了当MNS删除消息时返回“message not exist”的问题描述、问题原因和解决方案。问题描述 消息服务MNS中删除消息时报如下错误。message not exist 问题原因 VisibilityTimeout 到期，该消息的ReceiptHandle失效，导致消息删除失败。...
步骤二：创建资源
一个新的应用接入 云消息队列 RabbitMQ 版 服务端，您需要提前创建 云消息队列 RabbitMQ 版 的相关资源，包括创建 云消息队列 RabbitMQ 版 实例、创建Vhost、创建Exchange、创建Queue、绑定Exchange和Queue、创建用户名密码以及获取实例接...
自动创建Topic
云消息队列 Kafka 版 通过阿里云控制台和OpenAPI管理Topic数据，不建议在生产环境中开启自动化创建Topic，主要原因如下：自动化创建Topic不能进行细粒度的权限管控、资源操作审计等，存在安全管控问题。自动化创建Topic会有资源远远超过...
消费者负载均衡
背景信息 了解消费者负载均衡策略，可以帮助您解决以下问题：消息消费处理的容灾策略：您可以根据消费者负载均衡策略，明确当局部节点出现故障时，消息如何进行消费重试和容灾切换。消息消费的顺序性机制：通过消费者负载均衡策略，您可以...
RAM跨云账号授权
背景信息 企业A开通了 云消息队列 Kafka 版，该企业需要企业B代为操作 云消息队列 Kafka 版 的资源，例如实例、Topic、Group。企业A的需求如下：企业A希望能专注于业务系统，仅作为 云消息队列 Kafka 版 所有者。企业A希望可以授权企业B来...
发布者最佳实践
这种策略在短时间内看，会将消息发送到同一个分区，如果拉长整个运行时间，消息还是可以均匀地发布到各个分区上的。这样可以避免消息出现分区倾斜，同时还可以降低延迟，提升服务整体性能。如果您使用的 云消息队列 Kafka 版 Producer客户...
RAM跨云账号授权
背景信息 企业A开通了 云消息队列 RabbitMQ 版，该企业需要企业B代为操作 云消息队列 RabbitMQ 版 的资源，例如实例、Topic、Consumer Group。企业A的需求如下：企业A希望能专注于业务系统，仅作为 云消息队列 RabbitMQ 版 所有者。企业A...
定时/延时消息
定时/延时消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 说明 定时消息和延时消息本质相同，都是服务端根据消息设置的定时时间在某一固定时刻...
集成概述
概念介绍—消息流出（Sink）消息流出的主要能力是将 云消息队列 Kafka 版 的数据流出到各类数据目标，Connector生态集成模块对 云消息队列 Kafka 版 的消息进行可靠分发，同时在分发时对消息数据进行清洗和过滤。概念介绍—数据处理...
如何管理故障
可对故障根因进行原因检查并结构化录入，检查点包括：故障原因、最近活动、注入方式、恢复方式等；关联故障期间的故障变更，新增故障改进措施等操作。故障状态 处理中：处理中仍未恢复的故障；已恢复：故障对处理中的故障做 恢复 操作后是...
队列使用手册
可能因为网络错误，或MessageBody过大等原因造成发送消息失败，这里CatchException并做对应的处理。echo"SendMessage Failed:".$e;return;} 步骤四：接收和删除消息 队列里已经有了一条消息，现在可以尝试接收消息。NextVisibleTime是 消息...
事件分析概述
消息领域：在传统消息领域，消息Schema管理、消息内容检索一直是无法解决的难题，大部分情况下需要增加订阅者来对消息做离线分析。事件总线EventBridge 的事件分析平台提供消息Schema管理与消息内容查询能力，为消息可视化提供更完整的解决...
消费端挂载NFS是否会影响消费速度？
问题现象 消费端在消费消息的主线程里同步将拉取的消息存储在NFS，导致消费端处理消息的速度变慢，阻塞消息处理。可能原因 NFS本身速度就不太理想。NFS是网络共享存储，虽然有多机器共享访问的能力优势，但多台机器访问是争抢的，消费者...
短轮询和长轮询
消息服务MNS 提供短轮询（Short Polling）和长轮询（Long Polling）两种方式来获取队列中的消息。短轮询 创建队列时，长轮询时间设置为0，且发起popMessage请求时 waitSeconds 设置为0。使用短轮询获取队列中的消息，popMessage请求会向...
消息幂等
如果消息重复消费会影响您的业务处理，请对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 在数学与计算机学中，幂等操作的特点是其任意多次执行所产生的影响均与一次执行的影响相同。在消息领域，幂等是...
MNS相对于自主研发、商用或开源的消息队列系统有什么...
本文介绍与自行构建系统来管理消息队列或使用商用、开源...缺省提供消息冗余存储，以便在硬件发生故障时不会丢失消息，相应的系统投入、开发、配置和部署将更为简单。无需为消息服务后期投入部署和维护的资源，只需简单配置即可用于生产环境。
消费进度管理
某消息被指定消费者消费过一次后，如果业务出现异常需要做故障恢复，该消息能否被重新消费？消费进度原理 消息位点（Offset）参考 云消息队列 RocketMQ 版 主题 和 队列 的定义，消息是按到达服务端的先后顺序存储在指定主题的多个队列中，...
消息查询
在使用Kafka的过程中遇到无法正确消费消息、消息丢失、消息延迟等消费问题时，您可通过消息查询功能查看指定消息的详细内容和相关属性，帮助您排查异常原因。若确定消息所在Topic的分区ID以及消息位点，可采用按位点查询消息；若不确定消息...
消费幂等
为了防止消息重复消费导致业务处理异常，消息队列RocketMQ版 的消费者在接收到消息后，有必要根据业务上的唯一Key对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的情况...
API概览
本产品（微消息队列 MQTT/2020-04-20）的OpenAPI采用 RPC 签名风格，签名细节参见 签名机制说明。我们已经为开发者封装了常见编程语言的SDK，开发者可通过 下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用需求...
日志管理概述
Notify 有 有 有 有 有 无 有 有 NotifyStatus NotifyStatus是推送消息日志特有的字段，该可以协助您调查 消息服务MNS 推送消息到Endpoint失败的原因。根据不同的NotifyStatus，您可以按照下表建议的处理方法进行处理。错误码 描述 建议...
步骤七：故障切换
该模式适用于生产站点确实发生短时无法恢复的故障，需立即切换至容灾站点的场景。故障恢复类型 数据同步后切换 该故障恢复会停止保护组中被保护的实例，并且一直等到所有被保护的实例停止，再进行最后一轮数据同步，并等待数据同步完成后再...
步骤七：故障切换
该模式适用于生产站点确实发生短时无法恢复的故障，需立即切换至容灾站点的场景。故障恢复类型 数据同步后切换 该故障恢复会停止保护组中被保护的实例，并且一直等到所有被保护的实例停止，再进行最后一轮数据同步，并等待数据同步完成后再...
基本概念
消息堆积 Producer已经将消息发送到 云消息队列 RocketMQ 版 的服务端，但由于Consumer消费能力有限，未能在短时间内将所有消息正确消费掉，此时在 云消息队列 RocketMQ 版 的服务端保存着未被消费的消息，该状态即消息堆积。消息堆积量=...
消息过滤
场景示例 以下图电商交易场景为例，从客户下单到收到商品这一过程会生产一系列消息，按照类型将消息分为订单消息和物流消息，其中给物流消息定义地域属性，按照地域分为杭州和上海：订单消息 物流消息 物流消息且地域为杭州 物流消息且地域...
实例管理
实例是一个独立的 云消息队列 RabbitMQ 版 资源实体，可以被视为一个隔离的服务器或服务环境，执行消息的接收、存储和转发操作。实例包含Vhost、Exchange、Queue等基本的资源要素。本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建实例、...
Filebeat发送失败问题
可能原因 Filebeat向Topic发送消息时，会自动将Topic名称中的大写字母转换成小写字母。例如，您使用Filebeat向名称为AAA的Topic发送消息时，Filebeat会自动转换成向名称为aaa的Topic发送消息。由于发送消息的请求无法找到订阅的Topic，所以...
发送普通消息（三种方式）
云消息队列 RocketMQ 版 提供三种方式来发送普通消息：同步（Sync）发送、异步（Async）发送和单向（Oneway）发送。本文介绍了每种发送方式的原理、应用场景、示例代码，以及三种发送方式的对比。前提条件 安装Java SDK。更多信息，请参见 ...
收发普通消息（三种方式）
阿里云 云消息队列 RocketMQ 版 提供三种方式来发送普通消息：同步发送、异步发送和单向（Oneway）发送。本文介绍了每种发送方式的原理、使用场景、示例代码，以及三种发送方式的对比；此外还提供了订阅普通消息的示例代码。前提条件 您已...
控制台使用相关问题
本文介绍 云消息队列 MQTT 版 控制台使用时的常见问题。云监控的最大查询范围是多少？云消息队列 MQTT 版 云监控支持...可能原因：服务端推送消息时，客户端刚好不在线，且未设置离线消息，因此当客户端重新上线时这部分消息也消费不到了。
常见问题
消息发送失败会有多种原因，您可以参考 API错误码 页面定位错误。除代码问题外，除代码问题外，某些通道类型对个别国家或地区也存在发送限制。目前以下国家手机号码无法发送、接收WhatsApp消息：朝鲜、叙利亚、伊朗、古巴、苏丹、土耳其。...
死信队列
对于消费失败且重试后依然失败的消息，云消息队列 RocketMQ 版 不会立丢弃，而是将消息转发至指定的队列中，即死信队列，这些消息即为死信消息。当消费失败的原因排查并解决后，您可以重发这些死信消息，让消费者重新消费；若您暂时无法...
OnsMessageTrace-查看消息消费结果
本接口一般在消费异常，需要判断消息消费状态，初步排查原因时使用。本接口的实现基于云消息队列 RocketMQ 版的内部位点机制，在大部分场景下判断结果可信，但如果应用方进行过重置位点已经清除消息等操作，则判断结果可能有误。调试 您...
名词解释
基本概念 实例（Instance）创建购买 云消息队列 MQTT 版 服务的实体单元，每个 云消息队列 MQTT 版 实例都对应一个全局唯一的服务接入点URL。使用 云消息队列 MQTT 版 前都需要在对应的地域（Region）创建一个实例，并使用对应的接入点来...
- 产品推荐
- 这些文档可能帮助您