收发事务消息
云消息队列 RocketMQ 版 发送事务消息时需要实现 LocalTransactionChecker 接口，用来处理Broker主动发起的本地事务状态回查请求，因此在事务消息的Check方法中，需要完成两件事情：检查该半事务消息对应的本地事务的状态（committed or ...
收发事务消息
云消息队列 RocketMQ 版 发送事务消息时需要实现 LocalTransactionChecker 接口，用来处理Broker主动发起的本地事务状态回查请求，因此在事务消息的Check方法中，需要完成两件事情：检查该半事务消息对应的本地事务的状态（committed or ...
收发事务消息
云消息队列 RocketMQ 版 发送事务消息时需要实现 LocalTransactionChecker 接口，用来处理Broker主动发起的本地事务状态回查请求；因此在事务消息的Check方法中，需要完成两件事情：检查该半事务消息对应的本地事务的状态（committed or ...
收发事务消息
云消息队列 RocketMQ 版 发送事务消息时需要实现 LocalTransactionChecker 接口，用来处理Broker主动发起的本地事务状态回查请求；因此在事务消息的Check方法中，需要完成两件事情：检查该半事务消息对应的本地事务的状态（committed or ...
新功能发布记录
本文介绍 云消息队列 Kafka 版 的产品功能动态及对应的文档。2024-04-15 功能名称 功能描述 功能类型 相关文档 V3.0 Serverless系列实例在华东2（上海）地域开服 云消息队列 Kafka 版 V3.0 Serverless系列实例支持在华东2（上海）地域选购...
MQTT和RocketMQ进行数据互通（跨产品数据流入）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 RocketMQ...
MQTT和RocketMQ进行数据互通（跨产品数据流出）
如果您的云端应用需要使用 云消息队列 RocketMQ 版 产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 数据进行流转。本文介绍如何将 云消息队列 MQTT 版 ...
查看实例风险
消费流量 Group与Topic的订阅关系 服务端小版本升级 消费位点提交频率 存在Rebalance的Group 消费客户端主动离开队列 使用Sarama Go客户端 操作步骤 登录 云消息队列 Kafka 版 控制台，在 概览 页面的 资源分布 区域，选择地域。...
MQTT快速入门
注意事项 云消息队列 MQTT 版 需搭配后端消息存储队列一起使用，具体说明如下：云消息队列 MQTT 版 实例是一个无状态网关类型实例，用来完成IoT移动场景下的客户端连接维持和消息转发，本身并不提供消息数据持久化功能，具体的消息存储和...
OnsDLQMessageResendById-重发指定的死信消息
当前消息队列 RocketMQ 版不管理死信重发的状态，重发后消费成功的消息不会从死信队列中移除。需自行管理、判断消息是否需要重发。避免多次无意义地重发，从而造成重复消费。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算...
开通服务并授权
在阿里云官方网站开通消息队列服务后方可开始使用 云消息队列 MQTT 版。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的 云消息队列 MQTT 版 资源，并使用SDK收发消息。前提条件 您已注册阿里云账号并完成...
基本概念
本文主要对 云消息队列 RocketMQ 版 涉及的专有名词及术语进行定义和解析，方便您更好地理解相关概念并使用 云消息队列 RocketMQ 版。Topic 消息主题，一级消息类型，通过Topic对消息进行分类。更多信息，请参见 Topic与Tag最佳实践。消息...
云消息队列 RabbitMQ 版系统权限策略参考
本文描述云消息队列 RabbitMQ 版支持的所有系统权限策略及其对应的权限描述，供您授权 RAM 身份时参考。什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制...
云消息队列 RocketMQ 版4.x系统权限策略参考
本文描述云消息队列 RocketMQ 版4.x支持的所有系统权限策略及其对应的权限描述，供您授权 RAM 身份时参考。什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问...
消息队列Kafka版系统权限策略参考
本文描述消息队列Kafka版支持的所有系统权限策略及其对应的权限描述，供您授权 RAM 身份时参考。什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）...
开发参考
OpenAPI是阿里云产品提供的开放应用程序接口，是除控制台之外，云消息队列 RocketMQ 版 管理资源的主要方式之一。API参考汇总了 云消息队列 RocketMQ 版 所有对外公开的API接口。云消息队列 RocketMQ 版5.x系列 5.x系列SDK参考 5.x系列API...
新零售电子价签解决方案（MQTT）
新零售电子价签解决方案由阿里云 云消息队列 MQTT 版 推出，通过MQTT以实现商场超市、公共场所电子标签、多媒体屏幕的数据更新管理。本文将以电子价签为例详细描述该解决方案的系统架构、数据流设计以及注意事项，其他类似行业可参考该方案...
出账与欠费说明
云消息队列 RocketMQ 版 的计费出账和欠费释放根据支付方式有所不同，本文介绍标准版实例（按量付费）与企业铂金版实例（包年包月）的出账与欠费说明。标准版实例（按量付费）的出账与欠费说明 说明 以下说明同样适用于资源包。云消息队列 ...
新功能发布记录
本文介绍 云消息队列 RabbitMQ 版 的产品功能动态及对应的文档。2024-03-14 功能名称 功能描述 功能类型 相关文档 新增开服地域 马来西亚（吉隆坡）和美国（硅谷）地域新增支持创建Serverless实例和企业版实例。新增 开服地域 预付费实例...
服务器证书管理
服务器证书用于客户端认证服务端，服务器证书需要由您自行购买或自行签发并托管至阿里云数字证书管理服务。本文为您介绍如何生成并使用服务器证书。服务器证书使用流程 使用限制 仅铂金版实例和专业版实例支持服务器证书管理功能。前提条件...
OnsInstanceCreate-创建实例
实例是用于云消息队列 RocketMQ 版服务的虚拟机资源，用来存储 Topic 和 Group 信息。该接口一般在新业务发布需要创建新的服务资源的情况下使用。该接口只支持创建标准版实例，不支持创建铂金版实例。云消息队列 RocketMQ 版控制台同时支持...
名词解释
在使用 云消息队列 MQTT 版 前，需理解该产品和MQTT协议所涉及的基本概念和术语。基本概念 实例（Instance）创建购买 云消息队列 MQTT 版 服务的实体单元，每个 云消息队列 MQTT 版 实例都对应一个全局唯一的服务接入点URL。使用 云消息...
云消息队列 RocketMQ 版5.x系统权限策略参考
本文描述云消息队列 RocketMQ 版5.x支持的所有系统权限策略及其对应的权限描述，供您授权 RAM 身份时参考。什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问...
接口和参数说明
云消息队列 RocketMQ 版 提供Java SDK实现消息发送与订阅，订阅方可通过Push或Pull的方式从 云消息队列 RocketMQ 版 获取消息。本文介绍消息发送和订阅的接口和参数说明。背景信息 云消息队列 RocketMQ 版 支持以下两种消息获取方式：Push...
实例化支持
在2019年01月23日，云消息队列 RocketMQ 版 优化了资源隔离、资源申请、协议支持以及权限管理。本文提供相关更新说明，帮助您更顺畅地使用 云消息队列 RocketMQ 版。说明 为兼容新老资源配置，建议您将ons-client客户端升级到最新版本。...
Control Center基本使用
Control Center是 云消息队列 Confluent 版 的核心管理服务，提供了一个可视化的监控平台。本文介绍Control Center平台上的基本操作。登录Control Center 创建 云消息队列 Confluent 版 集群，详情请参见 购买和部署实例。在 云消息队列 ...
授权信息
访问控制（RAM）是阿里云提供的管理用户身份与资源访问权限的服务。使用RAM可以让您避免与其他用户共享阿里云账号密钥，并可按需为用户授予最小权限。RAM中使用权限策略描述授权的具体内容。本文为您介绍 消息队列Kafka版（AliKafka）为RAM...
签名鉴权模式
如果您需使用 云消息队列 MQTT 版 的签名鉴权模式，可根据本文提供的签名计算方式获取签名，再使用控制台来验证计算得出的签名是否正确。签名计算方式 按照 鉴权概述 的描述，如果选择签名校验模式，MQTT客户端实际连接MQTT消息服务器时，...
Topic管理
Topic是 云消息队列 RocketMQ 版 里对消息的一级归类。云消息队列 RocketMQ 版 支持发布和订阅模型，通过Topic完成消息的发布和订阅。消息生产者将消息发送到Topic中，而消息消费者则通过订阅该Topic来消费消息。本文介绍如何在 云消息队列...
开源MQTT迁移至云消息队列 MQTT 版
本文为您介绍如何将开源MQTT客户端从其他开源MQTT服务端迁移至阿里云的 云消息队列 MQTT 版 服务端上。背景信息 云消息队列 MQTT 版 拥有多协议、多语言平台的开发能力，并支持设备级权限控制以及SSL/TLS传输加密，您可以不变更开源客户端...
签名鉴权模式
如果您需使用 云消息队列 MQTT 版 的签名鉴权模式，可根据本文提供的签名计算方式获取签名，再使用控制台来验证计算得出的签名是否正确。签名计算方式 按照 鉴权概述 的描述，如果选择签名校验模式，MQTT客户端实际连接MQTT消息服务器时，...
授权信息
访问控制（RAM）是阿里云提供的管理用户身份与资源访问权限的服务。使用RAM可以让您避免与其他用户共享阿里云账号密钥，并可按需为用户授予最小权限。RAM中使用权限策略描述授权的具体内容。本文为您介绍 消息队列 MQ（Ons）为RAM权限策略...
签名机制
背景信息 AccessKey ID和AccessKey Secret由阿里云官方颁发给访问者（可以通过阿里云管理控制台申请和管理），其中：AccessKey ID用于标识访问者的身份。AccessKey Secret用于加密签名字符串和服务器端验证签名字符串的密钥，必须严格保密...
功能与特性概述
本文列举 云消息队列 RocketMQ 版 所支持的所有功能与特性。概览 云消息队列 RocketMQ 版 在阿里云多个地域（Region）提供了高可用消息云服务。单个地域内采用多机房部署，可用性极高，即使整个机房都不可用，仍然可以为应用提供消息发布...
OnsInstanceDelete-删除实例
调用OnsInstanceDelete接口删除云消息队列 RocketMQ 版实例。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能...
授权信息
访问控制（RAM）是阿里云提供的管理用户身份与资源访问权限的服务。使用RAM可以让您避免与其他用户共享阿里云账号密钥，并可按需为用户授予最小权限。RAM中使用权限策略描述授权的具体内容。本文为您介绍 消息队列 MQ（RocketMQ）为RAM权限...
OpenOnsService-开通服务
调用OpenOnsService开通云消息队列 RocketMQ 版服务。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致...
示例代码
云消息队列 RocketMQ 版 5.x版本实例可兼容C++ 1.x/2.x SDK客户端接入，您可以使用1.x/2.x版本的SDK接入5.x实例进行消息收发。本文为您介绍1.x/2.x版本下的C++ SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK...
作为Output接入
云消息队列 Kafka 版 可以作为Output接入Logstash。本文说明如何在VPC环境下通过Logstash向 云消息队列 Kafka 版 发送消息。前提条件 购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 VPC接入。下载并安装Logstash。具体操作，请...
收发顺序消息
顺序消息FIFO（First In First Out）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的C/C++ SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，...
- 产品推荐
- 这些文档可能帮助您