当配置审计发现资源配置有变更且不合规时，以事件通知的形式将告警推送到您指定的轻量消息队列（原 MNS）主题。当您收到不合规告警时，通过函数计算2.0实现不合规资源的自动修复。前提条件 请确保您已使用规则模板创建规则。具体操作，请...
本文为您介绍 云消息队列 RocketMQ 版 中消息的存储机制，包括消息的存储粒度、判断依据及后续处理策略等。背景信息 参考 云消息队列 RocketMQ 版 中 队列 的定义，消息按照达到服务器的先后顺序被存储到队列中，理论上每个队列都支持无限...
为了简化离线消息获取机制，云消息队列 MQTT 版 系统在客户端成功建立连接并通过权限校验后，会自动加载离线消息并下发到客户端。注意事项 客户端建立连接后，需要通过权限校验才能自动加载离线消息。例如，若您使用的是Token验证的方式，...
本文介绍 云消息队列 Kafka 版 支持机制，包括版本发布与支持情况、版本生命周期说明以及版本支持策略等内容。版本发布 云消息队列 Kafka 版 实例支持的版本详细信息如下所示。内部版本 状态 停止维护时间 3.3.1 已发布 长期维护 2.6.2 已...
云消息队列 MQTT 版 支持基于X.509证书的双向认证，分别通过服务器证书和设备证书完成服务端和客户端的认证，本文介绍如何在 云消息队列 MQTT 版 控制台管理证书。注意事项 仅铂金版、专业版 实例支持双向认证能力，基础版 和Serverless版 ...
本文介绍 轻量消息队列（原 MNS）如何处理较长时间没有任何消息的队列。在您正常使用服务期间，阿里云 轻量消息队列（原 MNS）不会对不可见的队列或主题进行删除操作。但是，如果您的 轻量消息队列（原 MNS）使用权限因为欠费或其他原因被...
云消息队列 MQTT 版 通过Token鉴权模式向MQTT客户端提供临时访问权限。您可通过MQTT Token服务来给本地账号系统管理的用户颁发临时的访问凭证，并限制访问权限，以实现对单一客户端、单一资源的细粒度权限控制。本文介绍使用流程以及相关...
轻量消息队列（原 MNS）处于欠费状态超过7天将停止服务。轻量消息队列（原 MNS）的欠费说明如下：轻量消息队列（原 MNS）服务费用的计费周期为小时，即阿里云将在下一小时对您上一小时的服务使用进行计量、出具账单并从您的阿里云账户中按...
云消息队列 Kafka 版 集成了HouseKeeping（健康巡检组件），定时对集群进行全面扫描诊断，并能针对不健康的状态进行告警。本文将为您详细介绍 云消息队列 Kafka 版 的巡检功能。巡检说明 为了进一步提升集群的稳定性和服务的可靠性，云消息...
问题现象 您发送的消息在服务端...磁盘容量充足，使用率低于75%，云消息队列 Kafka 版 设置的集中清理消息的时间还未到，消息不会被删除。说明 磁盘使用率低于75%时，在每天凌晨4点，云消息队列 Kafka 版 集中删除超过 消息保留时长 的消息。
本文介绍阿里云如何确保 轻量消息队列（原 MNS）中数据可靠性。轻量消息队列（原 MNS）将所有队列和消息存储在阿里云高可靠、高可用的数据中心组成的网络中。所有消息冗余地存储在多台服务器上，当某台服务器出现问题时，冗余数据将会被...
轻量消息队列（原 MNS）提供短轮询（Short Polling）和长轮询（Long Polling）两种方式来获取队列中的消息。短轮询 创建队列时，长轮询时间设置为0，且发起popMessage请求时 waitSeconds 设置为0。使用短轮询获取队列中的消息，popMessage...
云消息队列 RabbitMQ 版 的死信Exchange适用于处理被消费者否定应答或重试失败的消息。本文介绍死信Exchange的核心概念、路由流程、配置方式、注意事项和更多信息。核心概念 死信Exchange 用于路由死信消息的Exchange。死信Exchange会根据...
消息流控机制 消息流控基本概念 消息流控指的是系统容量或水位过高，云消息队列 RocketMQ 版 服务端会通过快速失败返回流控错误来避免底层资源承受过高压力。触发条件 云消息队列 RocketMQ 版 的消息流控触发条件如下：存储压力大：参考 ...
云消息队列 RabbitMQ 版 会对单实例的TPS流量峰值进行限流，本文介绍 云消息队列 RabbitMQ 版 实例的限流规则、限流后的行为以及限流最佳实践等。限流阈值 实例总TPS限流阈值 实例系列 Serverless系列实例 预付费系列实例 规格 共享 独享 ...
本文介绍 轻量消息队列（原 MNS）如何保证多个消费者访问同一消息队列，不会丢失消息或者重复消费消息的问题。轻量消息队列（原 MNS）中每个队列都具有可配置的不可见时间段属性（即队列的取出消息隐藏时长属性）。当队列中的某条消息被...
请求签名机制 签名机制介绍 轻量消息队列（原 MNS）服务会对每个访问的请求进行验证，每个请求向 轻量消息队列（原 MNS）提交时，都需要在该请求的Header中包含签名。轻量消息队列（原 MNS）SDK已实现自动完成签名，建议您采用SDK的方式...
您在创建订阅时设置推送类型为HTTP，轻量消息队列（原 MNS）会将消息推送到您设置的HTTP接收端地址。HTTP接收端需要在5s内返回2xx，否则 轻量消息队列（原 MNS）会认为推送请求超时并进行重试。重试策略相关说明，请参见 NotifyStrategy。
当往Kafka Topic中写入数据提示磁盘空间已满或 Queue full 时，为避免因磁盘容量不足而导致机器宕机，进而影响服务可用性，云消息队列 Kafka 版 会根据磁盘使用率的多少，执行不同的消息清理策略。清理策略 不同版本实例、不同类型Topic的...
消费者出现异常，云消息队列 RocketMQ 版 会根据消费重试策略重新投递该消息进行故障恢复。本文介绍消费重试的应用场景、原理机制、版本兼容性和使用建议。应用场景 云消息队列 RocketMQ 版 的消费重试主要解决的是业务处理逻辑失败导致的...
本文介绍消息集成默认支持的重试和死信策略。重试策略 重试策略即任务处理过程中出现失败时的重试方式，当前重试策略支持...说明 当前支持将死信发送至 云消息队列 RocketMQ 版、轻量消息队列（原 MNS）、云消息队列 Kafka 版 和 事件总线。
https:// Endpoint /? SignatureVersion =1.0& SignatureMethod =HMAC-SHA1&Signature=CT9X0VtwR86fNWSnsc6v8YGOjuE%3D& SignatureNonce =3ee8c1b8-83d3-44af-a94f-4e0ad82fd6cf Endpoint ： 云消息队列 MQTT 版 的API的服务接入地址为 ...
本文介绍消息集成默认支持的重试和死信策略。重试策略 重试策略即任务处理过程中出现失败时的重试方式，当前重试策略支持...说明 当前支持将死信发送至 云消息队列 RocketMQ 版、轻量消息队列（原 MNS）、云消息队列 Kafka 版 和 事件总线。
本文介绍阿里云如何保证消息队列中的消息是安全的。轻量消息队列（原 MNS）提供了安全可靠的身份验证机制，确保您的队列受到保护，防止遭到未经授权的访问。只有阿里云账户拥有者才能访问其创建的队列。
本文介绍消息集成默认支持的重试和死信策略。重试策略 重试策略即任务处理过程中出现失败时的重试方式，当前重试策略支持...说明 当前支持将死信发送至 云消息队列 RocketMQ 版、轻量消息队列（原 MNS）、云消息队列 Kafka 版 和 事件总线。
使用 云消息队列 RabbitMQ 版 时，为了保障系统的安全性与权限管理的精细化，系统设计了两环鉴权校验机制：基于AccessKey ID/AccessKey Secret的身份验证和基于RAM的行为权限验证，分别从用户身份验证和操作权限控制两个维度保证服务的安全...
MQVersion：表示 云消息队列 RocketMQ 版 接口的版本号，当前版本即为2015-06-06。CanonicalizedResource：表示HTTP所请求资源的URI（统一资源标识符），如消费请求的URI/topics/abc/messages?consumer=GID_abc。说明 用来签名的字符串为...
本文以Java SDK为例介绍如何在公网环境下使用SDK接入 云消息队列 Kafka 版 的SSL接入点并使用PLAIN机制收发消息。前提条件 步骤三：创建资源 安装1.8或以上版本JDK 安装2.5或以上版本Maven 安装Java依赖库 在 pom.xml 中添加以下依赖。...
云消息队列 RocketMQ 版 支持优雅下线的能力，能够有效避免因客户端连接突发中断引发的消息丢失等问题，从而确保业务的持续可用性。能力概述 优雅下线是 云消息队列 RocketMQ 版 为提升服务端运维场景下的可靠性而推出的核心特性。该能力...
事务超时机制 云消息队列 RocketMQ 版 事务消息的生命周期存在超时机制，即半事务消息被生产者发送服务端后，如果在指定时间内服务端无法确认提交或者回滚状态，则消息默认会被回滚。事务超时时间，请参见 参数限制。不支持多个sendReceipt...
消息队列 Kafka 版优化了 PLAIN 机制，支持不重启实例的情况下动态增加 SASL 用户。scram：一种用户名密码校验机制，安全性比 PLAIN 更高。消息队列 Kafka 版使用 SCRAM-SHA-256。LDAP：仅适应于删除 Confluent 实例用户。默认值为 plain。...
消息队列 Kafka 版优化了 PLAIN 机制，支持不重启实例的情况下动态增加 SASL 用户。scram：一种用户名密码校验机制，安全性比 PLAIN 更高。消息队列 Kafka 版使用 SCRAM-SHA-256。LDAP：仅适应于删除 Confluent 实例用户。默认值为 plain。...
轻量消息队列（原 MNS）对超过限流阈值的请求执行限流策略，从而避免底层资源承受过高压力。限流行为 当流量接近或达到限流阈值时，服务端会根据实时资源水位自动弹性调整限流阈值，在多数场景下，可动态支撑更高并发请求且用户无感知。若...
背景信息 企业A购买了 云消息队列 Kafka 版，企业A希望用户A只能从 云消息队列 Kafka 版 的所有Topic中消费消息，而不能向 云消息队列 Kafka 版 的任何Topic生产消息。注意事项 Kafka为公网/VPC类型实例提供默认SASL用户，默认SASL用户仅...
SASL接入点：在VPC环境下通过SASL接入点接入 云消息队列 Kafka 版 并使用PLAIN机制或者SCRAM机制收发消息。SASL支持两种机制验证身份：PLAIN机制：一种简单的用户名密码校验机制。云消息队列 Kafka 版 的PLAIN机制，支持不重启实例的情况下...
消费者分组管理尽量避免自动化机制 在 云消息队列 RocketMQ 版 架构中，消费分组属于状态管理类的逻辑资源，每个消费分组都会涉及关联的消费状态、堆积信息、可观测指标和监控采集数据。因此，生产环境需要严格管理消费者分组资源，请勿...
高可用性机制：云消息队列 RabbitMQ 版 支持多个消费者与多个计算节点的连接，实现高可用性。当任一消费者或计算节点发生故障时，系统能够快速切换至其他节点提供服务。启用方式 要启用顺序消费，必须将队列配置为Single Active Consumer...
主题管理尽量避免自动化机制 在 云消息队列 RocketMQ 版 架构中，主题属于顶层资源和容器，拥有独立的权限管理、可观测性指标采集和监控等能力，创建和管理主题会占用一定的系统资源。因此，生产环境需要严格管理主题资源，请勿随意进行增...
云消息队列 Kafka 版 提供默认接入点、SSL接入点和SASL接入点以适用不同的连接及安全需求。默认接入点适用于在保密性较高的VPC环境收发消息；SASL接入点适用于无需对传输链路加密但需对消息收发鉴权；需要链路加密和消息鉴权，建议使用SSL...
Batch机制，云消息队列 Kafka 版 Producer端主要通过两个参数进行控制：batch.size:发往每个分区（Partition）的消息缓存量（消息内容的字节数之和，不是条数）。达到设置的数值时，就会触发一次网络请求，然后Producer客户端把消息批量发...