队列（MessageQueue）
定义 队列是 云消息队列 RocketMQ 版 中消息存储和传输的实际容器，也是 云消息队列 RocketMQ 版 消息的最小存储单元。云消息队列 RocketMQ 版 的所有主题都是由多个队列组成，以此实现队列数量的水平拆分和队列内部的流式存储。队列的主要...
基本概念
消息队列（MessageQueue）队列是 云消息队列 RocketMQ 版 中消息存储和传输的实际容器，也是消息的最小存储单元。云消息队列 RocketMQ 版 的所有主题都是由多个队列组成，以此实现队列数量的水平拆分和队列内部的流式存储。队列通过QueueId...
收发顺序消息
顺序消息分类 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和消费。分区顺序：对于指定的一个Topic，所有消息根据Sharding Key进行区块分区。同一个分区内的...
收发顺序消息
背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和消费。分区顺序：对于指定的一个Topic，所有消息根据Sharding Key进行区块分区。同一个分区内的消息...
收发顺序消息
背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和消费。分区顺序：对于指定的一个Topic，所有消息根据Sharding Key进行区块分区。同一个分区内的消息...
收发顺序消息
背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和消费。分区顺序：对于指定的一个Topic，所有消息根据Sharding Key进行区块分区。同一个分区内的消息...
收发顺序消息
背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和消费。分区顺序：对于指定的一个Topic，所有消息根据Sharding Key进行区块分区。同一个分区内的消息...
收发顺序消息
背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和消费。分区顺序：对于指定的一个Topic，所有消息根据Sharding Key进行区块分区。同一个分区内的消息...
收发顺序消息
背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和消费。分区顺序：对于指定的一个Topic，所有消息根据Sharding Key进行区块分区。同一个分区内的消息...
收发顺序消息
背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和消费。分区顺序：对于指定的一个Topic，所有消息根据Sharding Key进行区块分区。同一个分区内的消息...
收发顺序消息
背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和消费。分区顺序：对于指定的一个Topic，所有消息根据Sharding Key进行区块分区。同一个分区内的消息...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
收发顺序消息
背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和消费。分区顺序：对于指定的一个Topic，所有消息根据Sharding Key进行区块分区。同一个分区内的消息...
配置消息监控告警实现风险预警
云消息队列 RocketMQ 版 支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息 云消息队列 RocketMQ 版 提供全托管的消息服务，对于每个规格...
步骤二：创建资源
一个新的应用接入 云消息队列 RabbitMQ 版 服务端，您需要提前创建 云消息队列 RabbitMQ 版 的相关资源，包括创建 云消息队列 RabbitMQ 版 实例、创建Vhost、创建Exchange、创建Queue、绑定Exchange和Queue、创建用户名密码以及获取实例接...
怎样让Consumer不立即消费消息并使消息重入队列？
您可以通过basicReject或basicNack方法否定应答消息，使消息重入队列，从而是其他Consumer可以消费消息。使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。...
怎样让Consumer不立即消费消息并使消息重入队列？
您可以通过basicReject或basicNack方法否定应答消息，使消息重入队列，从而是其他Consumer可以消费消息。使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。...
步骤二：创建资源
在调用SDK收发消息前，您需要提前创建 云消息队列 RocketMQ 版 的相关资源，包括创建 云消息队列 RocketMQ 版 实例、获取实例的接入点、创建Topic、创建ConsumerGroup。调用SDK时，需要将这些资源信息填写到SDK代码中。前提条件 创建专有...
从自建MySQL同步至云消息队列 Kafka 版
通过数据传输服务DTS（Data Transmission Service），您可以将自建MySQL同步至 云消息队列 Kafka 版，扩展消息处理能力。前提条件 您已完成以下操作：自建MySQL数据库且数据库版本为5.1、5.5、5.6、5.7或8.0版本。购买并部署 云消息队列 ...
MNS是否提供对消息的先入先出（FIFO）访问？
本文介绍 消息服务MNS 能否提供消息先入先出访问的问题。消息服务MNS 消费消息时尽量做到先进先出，正是因为分布式消息队列的一些特性并不能保证您能按照消息的发送顺序消费消息，如果您的业务必须先进先出，建议在消息中加入序号信息以便...
消费进度管理
背景信息 云消息队列 RocketMQ 版 的生产者和消费者在进行消息收发时，必然会涉及以下场景，消息先生产后订阅或先订阅后生产。这两种场景下，消费者客户端启动后从哪里开始消费？如何标记已消费的消息？这些都是由 云消息队列 RocketMQ 版 ...
产品优势
功能增强 延时消息 支持延时消息，实现秒级精准，无先入先出限制。简单易用，在代码上只需要设置一个参数即可完成，解决开源RabbitMQ无延时队列的痛点。高精度支持，最短可精确到秒级，最长可持续1天。高性能，性能与普通消息一致。多副本...
开通服务并授权
在阿里云官方网站开通消息队列服务后方可开始使用 云消息队列 MQTT 版。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的 云消息队列 MQTT 版 资源，并使用SDK收发消息。前提条件 您已注册阿里云账号并完成...
授权信息
访问级别：是指每个操作的访问级别，取值为写入（Write）、读取（Read）或列出（List）。资源类型：是指操作中支持授权的资源类型。具体说明如下：对于必选的资源类型，用背景高亮的方式表示。对于不支持资源级授权的操作，用 全部资源 ...
收发顺序消息
顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和消费。分区顺序：对于指定的一个Topic，所有消息根据Sharding Key进行区块分区。同一个分区内的消息按照严格的...
名词解释
根据MQTT协议，Topic存在多级，定义第一级Topic为父级Topic，使用 云消息队列 MQTT 版 前，需先在控制台创建该父级Topic，可以在 云消息队列 MQTT 版 控制台创建，或者直接在 云消息队列 RocketMQ 版 的控制台创建。子级Topic（Subtopic）...
授权信息
访问级别：是指每个操作的访问级别，取值为写入（Write）、读取（Read）或列出（List）。资源类型：是指操作中支持授权的资源类型。具体说明如下：对于必选的资源类型，用背景高亮的方式表示。对于不支持资源级授权的操作，用 全部资源 ...
直播互动解决方案
根据MQTT协议，Topic存在多级，定义第一级Topic为父级Topic，使用 云消息队列 MQTT 版 前，需先在控制台创建该父级Topic，可以在 云消息队列 MQTT 版 控制台创建，或者直接在 云消息队列 RocketMQ 版 的控制台创建。子级Topic（Subtopic）...
MQTT快速入门
对于非MQTT协议的接入，例如新能源，您必须首先购买 云消息队列 MQTT 版 企业铂金版，并通过专属通道享受对应的文档和技术支持服务。说明 您可观看入门操作视频来快速上手 云消息队列 MQTT 版。视频详细信息，请参见 快速入门视频。注意...
JMS P2P（主账号与RAM账号场景）
在收发消息时，您需要为发布端和订阅端配置该接入点，通过接入点接入 云消息队列 RabbitMQ 版 实例。登录 云消息队列 RabbitMQ 版 控制台，然后在左侧导航栏选择 实例列表。在 实例列表 页面的顶部菜单栏选择地域，然后在实例列表中，单击...
收发顺序消息
背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和消费。分区顺序：对于指定的一个Topic，所有消息根据Sharding Key进行区块分区。同一个分区内的消息...
发布者最佳实践
云消息队列 Kafka 版 Producer客户端在向服务端发送消息时，需要先确认往哪个Topic的哪个分区发送。我们给同一个分区发送多条消息时，Producer客户端将相关消息打包成一个Batch，批量发送到服务端。Producer客户端在处理Batch时，是有额外...
订阅者最佳实践
本文主要介绍 云消息队列 Kafka 版 订阅者的最佳实践，帮助您减少消费消息出错的可能性。消费消息基本流程 云消息队列 Kafka 版 订阅者在订阅消息时的基本流程为：Poll数据→执行消费逻辑→再次Poll数据，详情参见下图。负载均衡 每个 ...
SendMessage-向云消息队列 MQTT 版发送单条消息
从服务端应用向云消息队列 MQTT 版发送单条消息。接口说明 SendMessage 接口为服务端应用调用，与 MQTT 客户端发送消息互补。服务端和客户端的使用场景区别，请参见 开发指南使用指引。调用 SendMessage 接口前，请确认您的云消息队列 MQTT...
快速使用MQTT.fx模拟SDK收发消息
（RAM用户必选）步骤一：为RAM用户授权 若您开通消息队列服务使用的是账号是RAM用户，必须先为RAM用户进行授权，才能访问 云消息队列 MQTT 版 的资源。若您的账号是阿里云账号，默认拥有使用 云消息队列 MQTT 版 资源的权限，您可以跳过该...
主题（Topic）
FIFO：顺序消息，云消息队列 RocketMQ 版 通过消息分组MessageGroup标记一组特定消息的先后顺序，可以保证消息的投递顺序严格按照消息发送时的顺序。Delay：定时/延时消息，通过指定延时时间控制消息生产后不要立即投递，而是在延时间隔后...
定时/延时消息
基于 云消息队列 RocketMQ 版 的定时消息可以封装出多种类型的定时触发器。典型场景二：任务超时处理 以电商交易场景为例，订单下单后暂未支付，此时不可以直接关闭订单，而是需要等待一段时间后才能关闭订单。使用 云消息队列 RocketMQ 版...
JMS概述
云消息队列 RabbitMQ 版 提供JMS库供JMS客户端接入 云消息队列 RabbitMQ 版。本文介绍 云消息队列 RabbitMQ 版 JMS库的相关概念、获取方式、使用限制和使用教程。背景信息 JMS是一种消息传递标准，允许基于Java EE（Java平台企业版）的应用...
RegisterCaCertificate-注册CA证书
云消息队列 MQTT 版支持X.509证书认证，客户端可通过设备证书完成接入认证。CA证书用于为客户端签发设备证书，并验证设备证书的正确性，您需要先将申请的CA证书注册到云消息队列 MQTT 版的服务端上，才能用于认证设备证书。本接口用于将...
QueryMqttTraceMessagePublish-查询消息发送轨迹
调试 授权信息 当前API暂无授权信息透出。请求参数 名称 类型 必填 描述 示例值 MqttRegionId string 是 云消息队列 MQTT 版实例地域（Region）的 ID。请参见 服务接入点。cn-hangzhou InstanceId string 是 云消息队列 MQTT 版实例的 ID，...
- 产品推荐
- 这些文档可能帮助您