收发顺序消息
背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和消费。分区顺序：对于指定的一个Topic，所有消息根据Sharding Key进行区块分区。同一个分区内的消息...
SendMessage-向云消息队列 MQTT 版发送单条消息
从服务端应用向云消息队列 MQTT 版发送单条消息。接口说明 SendMessage 接口为服务端应用调用，与 MQTT 客户端发送消息互补。服务端和客户端的使用场景区别，请参见 开发指南使用指引。调用 SendMessage 接口前，请确认您的云消息队列 MQTT...
快速使用MQTT.fx模拟SDK收发消息
（RAM用户必选）步骤一：为RAM用户授权 若您开通消息队列服务使用的是账号是RAM用户，必须先为RAM用户进行授权，才能访问 云消息队列 MQTT 版 的资源。若您的账号是阿里云账号，默认拥有使用 云消息队列 MQTT 版 资源的权限，您可以跳过该...
主题（Topic）
本文介绍 云消息队列 RocketMQ 版 中主题（Topic）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 主题是 云消息队列 RocketMQ 版 中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。主题的作用主要如下：...
JMS概述
云消息队列 RabbitMQ 版 提供JMS库供JMS客户端接入 云消息队列 RabbitMQ 版。本文介绍 云消息队列 RabbitMQ 版 JMS库的相关概念、获取方式、使用限制和使用教程。背景信息 JMS是一种消息传递标准，允许基于Java EE（Java平台企业版）的应用...
常见问题
消息队列RocketMQ版集群消费和广播消费的区别是什么？多个Group订阅同一个Topic消息如何消费？消息队列RocketMQ版的消息体最大是多少？消息在消息队列RocketMQ版中能保存多久？消息的负载均衡策略是什么？消息消费失败是否会重新消费？消息...
RegisterCaCertificate-注册CA证书
云消息队列 MQTT 版支持X.509证书认证，客户端可通过设备证书完成接入认证。CA证书用于为客户端签发设备证书，并验证设备证书的正确性，您需要先将申请的CA证书注册到云消息队列 MQTT 版的服务端上，才能用于认证设备证书。本接口用于将...
Terraform
以列出云账号下所有的 云消息队列 Kafka 版 实例为例，示例代码如下：data"alicloud_alikafka_instances""instances_ds"{ name_regex="alikafkaInstanceName"output_file="instances.txt"} output"first_instance_name"{ value=data....
QueryMqttTraceMessagePublish-查询消息发送轨迹
调试 授权信息 当前API暂无授权信息透出。请求参数 名称 类型 必填 描述 示例值 MqttRegionId string 是 云消息队列 MQTT 版实例地域（Region）的 ID。请参见 服务接入点。cn-hangzhou InstanceId string 是 云消息队列 MQTT 版实例的 ID，...
接入Filebeat
本文介绍如何将 云消息队列 Kafka 版 接入Filebeat。Filebeat Filebeat是用于转发和集中日志数据的轻量级传输程序。Filebeat可以监听指定的日志文件或位置，从中收集日志事件并将其转发到Elasticsearch或Logstash进行索引。Filebeat的工作...
QueryMqttTraceMessageOfClient-查询消息轨迹
调试 授权信息 当前API暂无授权信息透出。请求参数 名称 类型 必填 描述 示例值 MqttRegionId string 是 云消息队列 MQTT 版实例地域（Region）的 ID。请参见 服务接入点。cn-hangzhou InstanceId string 是 云消息队列 MQTT 版实例的 ID，...
RegisterDeviceCredential-为某个设备注册访问凭证
当设备与云消息队列 MQTT 版建立连接时，需要将设备访问凭证中的信息按照约定的形式设置到Username和Password中，向云消息队列 MQTT 版发起认证请求，云消息队列 MQTT 版认证通过后激活设备，设备与云消息队列 MQTT 版间才可传输数据。...
实例管理
使用 云消息队列 RocketMQ 版 进行消息收发，必须先创建 云消息队列 RocketMQ 版 实例。本文介绍如何在 云消息队列 RocketMQ 版 控制台上创建、删除、更新和查看实例详情。背景信息 云消息队列 RocketMQ 版 实例按照规格分为标准版和企业...
什么是云消息队列 Kafka 版？
云消息队列 Kafka 版 是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。云消息队列 Kafka 版 广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域，已成为大数据生态中不可或缺的部分。产品优势 云消息队列 ...
GetDeviceCredential-查询设备的访问凭证
一机一密认证方式下，设备与云消息队列 MQTT 版建立连接时，需要携带提前申请的设备访问凭证信息向云消息队列 MQTT 版发起认证请求，请求通过则允许设备接入服务端。本接口用于查询指定设备的访问凭证。接口说明 本接口的单用户 QPS 限制为...
创建资源
在调用TCP协议的SDK收发消息前，您需在 云消息队列 RocketMQ 版 控制台创建相关资源。您在调用SDK时需填写这些资源信息。前提条件 开通消息队列服务并授权 背景信息 针对TCP和HTTP两种通信协议，云消息队列 RocketMQ 版 分别提供了多语言...
QueryMqttTraceDevice-查询设备轨迹
分页查询微消息队列MQTT版客户端的设备轨迹。当设备的状态出现异常时，您可以通过该接口查询指定设备的连接历史，帮助您快速定位异常原因。接口说明 每成功调用一次 QueryMqttTraceDevice 接口，都会计算为一次消息 TPS，从而影响您的计费...
是否支持优先级队列？
云消息队列 RabbitMQ 版 不支持优先级队列。云消息队列 RabbitMQ 版 内部暂未实现消息优先级的处理逻辑，您的客户端通过可选队列参数 x-max-priority 声明的优先级队列实际是无效的。
是否支持优先级队列？
云消息队列 RabbitMQ 版 不支持优先级队列。云消息队列 RabbitMQ 版 内部暂未实现消息优先级的处理逻辑，您的客户端通过可选队列参数 x-max-priority 声明的优先级队列实际是无效的。
创建资源
网络访问限制 在使用 云消息队列 RocketMQ 版 时，请注意以下网络访问限制：只有在同一个地域下的同一个实例中的Topic和Group ID才能互通，例如，某Topic创建在 华东1（杭州）地域的实例A中，那么该Topic只能被在 华东1（杭州）地域的实例A...
收发普通消息
设置TCP接入域名，进入消息队列RocketMQ版控制台实例详情页面的接入点区域查看。factoryInfo.setFactoryProperty(ONSFactoryProperty:NAMESRV_ADDR,"XXX");您在消息队列RocketMQ版控制台创建的Topic。factoryInfo.setFactoryProperty...
升级实例配置
云消息队列 Kafka 版 的VPC实例没有公网接入点，不能使用公网资源，无法满足业务需求。升级后会引发集群逐台重启，且暂停弹缩。云消息队列 Kafka 版 的公网/VPC实例不再使用公网资源，需要变更为VPC实例。升级后会引发集群逐台重启，且暂停...
定时/延时消息
功能原理 什么是定时消息 定时消息是 云消息队列 RocketMQ 版 提供的一种高级消息类型，消息被发送至服务端后，在指定时间后才能被消费者消费。通过设置一定的定时时间可以实现分布式场景的延时调度触发效果。定时时间设置原则 云消息队列 ...
顺序消息
全局顺序消息 对于指定的一个Topic，所有消息按照严格的先入先出（FIFO）的顺序来发布和消费。适用场景 适用于性能要求不高，所有的消息严格按照FIFO原则来发布和消费的场景。示例 在证券处理中，以人民币兑换美元为Topic，在价格相同的...
在线教育视频直播
视频直播 视频直播（ApsaraVideo Live）基于内容接入与分发网络和大规模分布式实时视频处理技术（含窄带高清TM）打造的音视频直播平台，提供易接入、低延迟、高并发、高清流畅的音视频直播服务。更多关于视频直播的介绍，参见 视频直播产品...
事务消息
功能原理 什么是事务消息 事务消息是 云消息队列 RocketMQ 版 提供的一种高级消息类型，支持在分布式场景下保障消息生产和本地事务的最终一致性。事务消息处理流程 事务消息交互流程如下图所示。生产者将消息发送至 云消息队列 RocketMQ 版...
开源RabbitMQ迁移上云
在使用开源RabbitMQ集群时，当您希望能够解决各种稳定性痛点（例如消息堆积、脑裂等问题）、实现高并发、分布式、灵活扩缩容时，您可以将开源RabbitMQ集群迁移至 云消息队列 RabbitMQ 版，本文介绍迁移上云的前提条件、操作步骤、注意事项...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的PHP SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装PHP SDK。更多信息，请参见 准备环境...
GetInstanceList-查询指定地域的实例信息
云消息队列 Kafka 版实例支持域名接入点和 IP 接入点。域名接入点：由云消息队列 Kafka 版实例域名和端口号拼接而成，格式为 {实例域名}:{端口号}。IP 接入点：由 Broker 的 IP 地址和端口号拼接而成，格式为 {Broker 的 IP 地址}:{端口号}...
接入Logstash
本文介绍如何将 云消息队列 Kafka 版 接入Logstash。Logstash Logstash是开源的服务器端数据处理管道，能够同时从多个数据源采集数据，然后对数据进行转换，并将数据写入指定的存储中。Logstash的数据处理流程如下：输入：采集各种格式、...
批量消费
什么是批量消费 定义 批量消费是 云消息队列 RocketMQ 版 通过Push消费者提供的、将消息分批次消费的功能。说明 根据消息获取方式，云消息队列 RocketMQ 版 提供Push和Pull两种类型的消费者，更多信息，请参见 基本概念。功能原理 批量消费...
创建资源
在使用SDK收发消息前，您需要在 云消息队列 MQTT 版 控制台创建相关资源，包括实例、Topic和Group。您在调用SDK时需要填写这些创建的资源信息。前提条件 开通服务并授权 创建实例并获取接入点 实例是用于 云消息队列 MQTT 版 服务的虚拟机...
消费者（Consumer）
本文介绍 云消息队列 RocketMQ 版 中消费者（Consumer）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 消费者是 云消息队列 RocketMQ 版 中用来接收并处理消息的运行实体。消费者通常被集成在业务系统中，从 云消息...
产品功能
云消息队列 RabbitMQ 版 兼容开源RabbitMQ并提供一套完善的运维工具。资源支持 云消息队列 RabbitMQ 版 兼容开源RabbitMQ的各个组件：Queue：支持消息存储，支持集群消费模式。说明 云消息队列 RabbitMQ 版 内部暂未实现消息优先级的处理...
Topic管理
根据MQTT协议，Topic存在多级，定义第一级Topic为父级Topic，在使用 云消息队列 MQTT 版 前，需先创建该父级Topic资源。注意事项 Topic不能跨实例使用，例如不能使用实例B的接入点订阅创建在实例A中的Topic。Topic名称长度限制为3~64个字符...
生产者（Producer）
本文介绍 云消息队列 RocketMQ 版 中生产者（Producer）的定义、模型关系、内部属性、版本兼容性及使用建议。定义 生产者是 云消息队列 RocketMQ 版 系统中用来构建并传输消息到服务端的运行实体。生产者通常被集成在业务系统中，将业务...
使用Canal将MySQL的数据同步至云消息队列 Kafka 版
本教程介绍如何使用Canal将MySQL的数据同步至 云消息队列 Kafka 版。背景信息 Canal的主要用途是基于MySQL数据库增量日志解析，提供增量数据订阅和消费。Canal伪装自己为MySQL Slave，向MySQL Master发送dump请求。MySQL Master收到dump...
音视频通信解决方案（MQTT）
音视频通信解决方案是由阿里云 云消息队列 MQTT 版 和音视频通信RTC联合推出的有助于快速搭建各种实时通信场景产品，譬如在线音视频会议、1对1语音通话应用的解决方案。本文将详细描述该解决方案的系统架构、数据流设计以及相关注意事项。...
消息检索
当 云消息队列 Kafka 版 控制台提供的按位点查询和按时间查询消息的功能无法满足您搜索消息的需求时，您可以使用 云消息队列 Kafka 版 消息检索功能。消息检索支持按Topic分区、位点范围、时间范围以及消息Key和Value关键字检索。本文介绍...
4.x和5.x版本差异及兼容性说明
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布，阿里云 云消息队列 RocketMQ 版 将为您提供更加稳定可靠的服务端5...
- 产品推荐
- 这些文档可能帮助您