本文介绍如何在 Serverless 应用引擎 SAE（Serverless App Engine）上基于阿里云 云消息队列 RocketMQ 版 实现环境隔离，您可以在不修改任何业务代码的情况下，实现异步场景下的流量控制。背景信息 支持RocketMQ版本：4.2.0及以上版本。...
本文为您介绍 SOFAStack 消息队列的适用场景，以便您更好地判断如何在业务中使用消息队列。在互联网金融场景里，其业务涉及广泛，如支付交易、收费计息、商户结算、业务营销、会员积分、风险核查等；同时，也会涉及许多业务峰值时刻，如双 ...
消息收发为 云消息队列 MQTT 版 最基本的功能，云消息队列 MQTT 版 支持终端和云端服务接入 云消息队列 MQTT 版 服务器，实现终端和终端、终端和云端的消息通信。本文介绍消息收发功能的基本场景和示例代码。背景信息 云消息队列 MQTT 版 ...
本文介绍如何针对资讯聚合类业务场景搭建基于 云消息队列 Kafka 版 和实时计算Flink的实时数仓。场景描述 本文首先介绍什么是实时数仓以及相关技术架构，接着介绍资讯聚合类业务的典型场景及其业务目标，并据此设计了相应的技术架构。然后...
什么是消费幂等 在消息队列场景中，消费幂等处理是指即使因为某些原因（如网络问题、系统故障等）导致同一条消息被多次发送给消费者，通过幂等性设计也能保证最终的业务逻辑只被执行一次，避免因为重复消费而导致数据错误或业务结果不一致...
应用场景 指令下发场景 部署在云端的后台管控服务发送指令到 云消息队列 RocketMQ 版，云消息队列 MQTT 版 产品根据配置的数据流入规则，将 云消息队列 RocketMQ 版 的Topic映射到MQTT的Topic，然后将对应的数据推送到目标的MQTT设备端。...
本文介绍 云消息队列 MQTT 版 提供的云端SDK和管控SDK的使用场景。使用说明 使用 云消息队列 MQTT 版 的云端SDK收发消息时，需要和终端SDK搭配使用。例如，使用云端SDK发送消息，终端SDK接收消息；或使用终端SDK发送消息，云端SDK接收消息...
本文为您介绍 云消息队列 RabbitMQ 版 的应用场景，以便您更好地判断如何在业务中使用 云消息队列 RabbitMQ 版。异步解耦 云消息队列 RabbitMQ 版 可用于单体应用被拆解为微服务后不同微服务间的通信。应用解耦的好处是不同应用的迭代不再...
本文介绍 云消息队列 Kafka 版 的典型应用场景，包括网站活动跟踪、日志聚合、数据处理、数据中转枢纽。网站活动跟踪 成功的网站运营需要对站点的用户行为进行分析。通过 云消息队列 Kafka 版 的发布/订阅模型，您可以实时收集网站活动数据...
本文介绍 轻量消息队列（原 MNS）是否可以与其他阿里云产品协作使用的问题。轻量消息队列（原 MNS）可以与ECS、OSS和OTS等阿里云服务一起使用，从而让应用程序具有更好的灵活性和可扩展性。常见的使用案例如：创建需要互相通信却又不能同时...
本文介绍在 云消息队列 MQTT 版 中常见的授权策略示例。注意事项 在阅读本文前，建议您可先查看在访问控制RAM中支持的 云消息队列 MQTT 版 相关的 权限策略。关于Resource的格式及格式说明，请参见 资源（Resource）。如需直接复制示例代码...
本文介绍 轻量消息队列（原 MNS）的典型使用场景。典型的使用场景如下：将 轻量消息队列（原 MNS）与其他阿里云产品集成，让应用程序更加可靠、灵活。将 轻量消息队列（原 MNS）用作工作队列，其中每条消息代表一项任务，需要通过一个流程...
场景一：通过队列订阅云产品事件、异步任务执行结果等数据进行后续的业务操作 场景案例 说明 对象存储OSS 将 OSS 事件推送到 轻量消息队列（原 MNS）的队列或主题中，开发者的服务通过消费消息进行后续的业务处理。智能媒体管理IMM 当 智能...
支持进行数据清洗的产品包含 云消息队列 RocketMQ 版、云消息队列 Kafka 版、云消息队列 MQTT 版、云消息队列 RabbitMQ 版 轻量消息队列（原 MNS）。数据清洗任务创建完成后，您可以登录 函数计算控制台，进行代码自定义及相应函数配置的...
方案架构 因为 云消息队列 RocketMQ 版 具有重试功能且能保证消息不丢失，所以推出此方案来确保DB和缓存数据的强一致性，即在DB和缓存间使用 云消息队列 RocketMQ 版，架构如下图所示。方案优势 云消息队列 RocketMQ 版 有以下优势：巨大的...
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品。云消息队列 RabbitMQ 版 兼容开源RabbitMQ客户端，解决开源各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等云...
本文介绍 云消息队列 MQTT 版 的消息收发模型、产品优势和应用场景。前置概念 阅读本文前，您可能需要了解如下概念：什么是消息队列？什么是SDK？三分钟了解云消息队列MQTT版 核心概念 Topic：消息主题，一级消息类型，生产者向其发送消息...
场景描述 适用于在线教育的视频直播场景，通过阿里云视频直播服务实现移动端的推拉流能力，同时移动端利用 云消息队列 MQTT 版 实现发送和接收消息，在消息转发时利用内容安全服务对消息内容进行审核。发送的消息可以存储在表格存储中。...
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台，面向互联网分布式应用场景提供微服务异步解耦、流式数据处理、事件驱动处理等核心能力。前置概念 阅读...
自动创建Topic是指当 云消息队列 Kafka 版 实例发送请求以获取不存在的Topic元数据时，例如向不存在的Topic发送生产请求，云消息队列 Kafka 版 可以自动创建Topic。自动创建Topic适用于迁移上云场景或测试场景，无需手动重复创建Topic，...
云消息队列 Kafka 版 服务端支持收发压缩消息。如需使用压缩消息，您需要在 云消息队列 Kafka 版 的客户端进行设置。在 云消息队列 Kafka 版 客户端进行消息压缩的说明如下：压缩格式：支持Snappy、LZ4、GZIP等压缩格式。其中，GZIP对CPU的...
本文介绍消息轨迹的使用场景、云消息队列 RocketMQ 版 定义的轨迹参数以及如何查看消息轨迹。使用场景 云消息队列 RocketMQ 版 将消息收发流程中的关键数据定义为轨迹参数，并支持可视化查询，通过查看轨迹信息可快速获取当前业务处理的...
云消息队列 RocketMQ 版 提供三种方式来发送普通消息：同步（Sync）发送、异步（Async）发送和单向（Oneway）发送。本文介绍了每种发送方式的原理、应用场景、示例代码，以及三种发送方式的对比。前提条件 安装Java SDK。更多信息，请参见 ...
应用场景 云消息队列 MQTT 版 需结合后端存储消息队列产品，如 云消息队列 RocketMQ 版 等使用，来和部署在云端服务器上的应用（下文简称为业务应用）完成业务流程。获取客户端在线状态主要的应用场景如下：主业务流程中需要根据客户端是否...
应用场景 云消息队列 RocketMQ 版 作为发布订阅模型的消息中间件广泛应用于上下游业务集成场景。在实际业务场景中，同一个主题下的消息往往会被多个不同的下游业务方处理，各下游的处理逻辑不同，只关注自身逻辑需要的消息子集。使用 云...
应用场景 云消息队列 RocketMQ 版 的消费重试主要解决的是业务处理逻辑失败导致的消费完整性问题，是一种为业务兜底的策略，不应该被用作业务流程控制。以下场景建议使用消息重试 业务处理失败，且失败原因跟当前的消息内容相关，比如该...
背景信息 在直播互动的场景下，您需创建相应的数据互通规则实现 云消息队列 MQTT 版 与 云消息队列 RocketMQ 版 的数据互通，包含 数据流入规则、数据流出规则 以及 客户端上下线通知规则。使用 云消息队列 MQTT 版 的客户端收发消息时，...
允许用户根据具体应用场景定制消息的元数据，不仅增加了消息传输的灵活性和适用性，还使得MQTT能够更加高效地处理复杂的业务逻辑和需求。使用限制 用户属性序列化后大小不能超过8K字节。序列化后的用户属性如下：[{"key":"mQ","value":...
云消息队列 RabbitMQ 版 SDK（RAM角色跨账号授权场景）如果您是RAM STS角色授权的使用场景，需要通过 云消息队列 RabbitMQ 版 SDK收发消息，该SDK只比开源SDK多一个加签依赖。云消息队列 RabbitMQ 版 支持的多语言或框架SDK如 云消息队列 ...
本文介绍 云消息队列 RocketMQ 版 中消费者分组（ConsumerGroup）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 消费者分组是 云消息队列 RocketMQ 版 系统中承载多个消费行为一致的消费者的负载均衡分组。和消费者...
轻量消息队列（原 MNS）客户端内置了Base64编码与不使用Base64编码两种选项，本文介绍在不同的生产消费场景中是否需要使用Base64编码。背景知识 Base64编码是一种用于将二进制数据转换为ASCII字符串的编码方案，广泛应用于需要通过文本处理...
本文主要对 云消息队列 RabbitMQ 版 涉及的专有名词及术语进行定义和解析，方便您更好地理解相关概念并使用 云消息队列 RabbitMQ 版。A Alternate Exchange 备份Exchange，简称AE，用于接收配置了备份Exchange的Exchange路由失败的消息。...
适用场景及风险点 场景 风险 云消息队列 Kafka 版 非Serverless实例的磁盘使用率偏高，即将影响正常业务进行，需要扩容磁盘。升级后会引发集群逐台重启。云消息队列 Kafka 版 非Serverless实例的流量规格持续超过已购买的规格，无法满足...
如需追踪和识别消息，您可以在 云消息队列 RabbitMQ 版 的Producer客户端设置Message ID属性，为每条消息设置唯一标识符。本文介绍Message ID的相关概念和设置方法。什么是Message ID Message ID（消息标识符）是消息的可选属性，类型为...
本文为您介绍MQTT 5.0的新特性会话过期。功能介绍 会话过期（Session Expiry Interval）是指在客户端和服务端...此时，如果IoT设备再次连接，它需要像首次连接一样重新建立新的会话，包括重新订阅所需的主题，并且先前队列中的消息则会丢失。
适用场景及风险点 场景 风险 云消息队列 Kafka 版 非Serverless实例的流量使用量持续低于购买时的流量规格，需要降低实例的流量规格。当前业务可能会被限速，请参见上文注意事项中的限速风险。较大规格的实例降低配置可能会自动进行Topic...
使用场景 轻量消息队列（原 MNS）的消息轨迹功能可以帮助您解决以下问题：查看消息是否发送成功：当您怀疑消息没有收到时，可以通过消息轨迹确认消息是否成功发送到队列或主题，以及消息是否被消费。排查消息重复消费问题：当您发现同一条...
云消息队列 MQTT 版 升级后实现了自身数据存储的能力，同时还去除了对 云消息队列 RocketMQ 版 的消息依赖，因此，云消息队列 MQTT 版 的实例和Topic使用有变更。资源 旧版本 使用说明 新版本 使用说明 云消息队列 MQTT 版 实例 旧版本 云...
云消息队列 RabbitMQ 版是阿里云消息队列（MQ）团队基于AMQP 0-9-1协议研发的分布式、高吞吐、低延迟、高可扩展的云消息队列服务。消息队列RabbitMQ版完全兼容开源RabbitMQ社区、开箱即用、无需部署、免运维，帮助您快速上云。
映射关系如下：轻量消息队列（原 MNS）默认入参 目标端类型 模式 值 云消息队列 Kafka 版 部分事件$.data.value 云消息队列 RocketMQ 版 部分事件$.data.body 云消息队列 RabbitMQ 版 部分事件$.data.body 云消息队列 MQTT 版 部分事件$....