UpdateInstance-更新实例
更新云消息队列 RocketMQ 版实例的基本信息和规格配置。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致...
Topic与Tag最佳实践
在 消息队列RocketMQ版 中，Topic与Tag都是业务上用来归类的标识，区分在于Topic是一级分类，而Tag可以理解为是二级分类。您可通过本文了解如何搭配使用Topic和Tag来实现消息过滤。背景信息 Topic和Tag的定义如下：Topic 消息主题，通过...
授权信息
操作（Action）下表是 消息队列 MQ（RocketMQ）定义的操作，这些操作可以在RAM权限策略语句的 Action 元素中使用，用来授予执行该操作的权限。下面对表中的具体项提供说明：操作：是指具体的权限点。API：是指操作对应的API接口。访问级别...
CreateTopic-创建主题
创建云消息队列 RocketMQ 版的主题（Topic）。主题是云消息队列 RocketMQ 版中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。在消息收发模型中，生产者将消息发送至主题，消费者通过订阅指定的主题来消费其中的消息。调试 您...
创建资源
在调用TCP协议的SDK收发消息前，您需在 云消息队列 RocketMQ 版 控制台创建相关资源。您在调用SDK时需填写这些资源信息。前提条件 开通消息队列服务并授权 背景信息 针对TCP和HTTP两种通信协议，云消息队列 RocketMQ 版 分别提供了多语言...
创建资源
创建Topic Topic是 云消息队列 RocketMQ 版 里对消息的一级归类，例如创建名称为Topic_Trade的Topic来识别交易类消息，消息生产者将消息发送到Topic_Trade，而消息消费者则通过订阅该Topic来获取和消费消息。Topic的使用说明如下：Topic不...
自定义鉴权模式
MQTT服务器 云消息队列 MQTT 版 权限认证和消息收发服务器，用来处理应用服务器发起的鉴权相关的请求以及消息收发业务。使用说明 无论使用何种鉴权模式，本质上可以归结为身份认证和资源权限两个基本功能。身份认证，即客户端的身份标识，...
主题（Topic）
本文介绍 云消息队列 RocketMQ 版 中主题（Topic）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 主题是 云消息队列 RocketMQ 版 中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。主题的作用主要如下：...
消息过滤
消费者订阅了某个主题后，云消息队列 RocketMQ 版 会将该主题中的所有消息投递给消费者。若消费者只需要关注部分消息，可通过设置过滤条件在 云消息队列 RocketMQ 版 服务端进行过滤，只获取到需要关注的消息子集，避免接收到大量无效的...
生产者（Producer）
定义 生产者是 云消息队列 RocketMQ 版 系统中用来构建并传输消息到服务端的运行实体。生产者通常被集成在业务系统中，将业务消息按照要求封装成 云消息队列 RocketMQ 版 的 消息（Message）并发送至服务端。在消息生产者中，可以定义如下...
获取离线MQTT消息
为了简化离线消息获取机制，云消息队列 MQTT 版 系统在客户端成功建立连接并通过权限校验后，会自动加载离线消息并下发到客户端。注意事项 客户端建立连接后，需要通过权限校验才能自动加载离线消息。例如，若您使用的是Token验证的方式，...
发布者最佳实践
本文介绍 云消息队列 Kafka 版 发布者的最佳实践，帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端，其基本概念与思想是相通的，但实现细节可能存在差异。发送消息 发送消息的示例代码如下：Future...
获取离线MQTT消息
为了简化离线消息获取机制，云消息队列 MQTT 版 系统在客户端成功建立连接并通过权限校验后，会自动加载离线消息并下发到客户端。注意事项 客户端建立连接后，需要通过权限校验才能自动加载离线消息。例如，若您使用的是Token验证的方式，...
消息发送重试和流控机制
本文为您介绍 云消息队列 RocketMQ 版 的消息发送重试机制和消息流控机制。背景信息 消息发送重试 云消息队列 RocketMQ 版 的消息发送重试机制主要为您解答如下问题：部分节点异常是否影响消息发送？请求重试是否会阻塞业务调用？请求重试...
顺序消息
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下，异构系统间需要维持强一致的状态同步，...
使用限制
云消息队列 Kafka 版 对某些具体指标进行了约束和规范，您在使用 云消息队列 Kafka 版 时注意不要超过相应的限制值，以免程序出现异常。重要 若由于您的实例配置超出使用限制导致的任何不稳定情况，不在SLA承诺和赔偿范围内。云消息队列 ...
消息重试
云消息队列 RocketMQ 版 支持消息重试功能，即Consumer消费某条消息失败或消费超时，云消息队列 RocketMQ 版 会根据消息重试机制重新投递消息。本文介绍 云消息队列 RocketMQ 版 分别在HTTP协议和TCP协议下的消息重试策略。注意事项 一条...
Token鉴权概述
云消息队列 MQTT 版 通过Token鉴权模式向MQTT客户端提供临时访问权限。您可通过MQTT Token服务来给本地账号系统管理的用户颁发临时的访问凭证，并限制访问权限，以实现对单一客户端、单一资源的细粒度权限控制。本文介绍使用流程以及相关...
云消息队列 Kafka 版自定义权限策略参考
自定义权限策略支持版本控制，您可以按照RAM规定的版本管理机制来管理您创建的自定义权限策略版本。操作文档 创建自定义权限策略 修改自定义权限策略内容和备注 删除自定义权限策略 管理权限策略引用记录 管理自定义权限策略版本 自定义...
云消息队列 RocketMQ 版4.x系统权限策略参考
本文描述云消息队列 RocketMQ 版4.x支持的所有系统权限策略及其对应的权限描述，供您授权 RAM 身份时参考。什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问...
应用场景
本文为您介绍 云消息队列 RocketMQ 版 的应用场景，以便您更好地判断如何在业务中使用 云消息队列 RocketMQ 版。例如，针对一家互联网电商企业，其业务涉及广泛，如注册、订单、库存、物流等；同时，也会涉及许多业务峰值时刻，如秒杀活动...
将云消息队列 Kafka 版接入阿里云Elasticsearch
随着时间的积累，云消息队列 Kafka 版 中的日志数据会越来越多。当您需要查看并分析庞杂的日志数据时，可通过阿里云Logstash将 云消息队列 Kafka 版 中的日志数据导入阿里云Elasticsearch，然后通过Kibana进行可视化展示与分析。本文介绍将...
消息队列Kafka版系统权限策略参考
本文描述消息队列Kafka版支持的所有系统权限策略及其对应的权限描述，供您授权 RAM 身份时参考。什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问控制（RAM）...
消息超时和重试机制
重试机制 云消息队列 RabbitMQ 版 服务端有默认的消息重试机制，不支持您在Consumer客户端重新配置消息重试机制和关闭消息重试机制。云消息队列 RabbitMQ 版 服务端默认的消息重试机制如下：如果您没有开启Consumer客户端消费消息，则不会...
作为Output接入
云消息队列 Kafka 版 可以作为Output接入Filebeat。本文说明如何在VPC环境下通过Filebeat向 云消息队列 Kafka 版 发送消息。前提条件 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。更多信息，请参见 VPC...
云消息队列 RocketMQ 版5.x系统权限策略参考
本文描述云消息队列 RocketMQ 版5.x支持的所有系统权限策略及其对应的权限描述，供您授权 RAM 身份时参考。什么是系统权限策略 权限策略是用语法结构描述的一组权限的集合，可以精确地描述被授权的资源集、操作集以及授权条件。阿里云访问...
OpenOnsService-开通服务
调用OpenOnsService开通云消息队列 RocketMQ 版服务。接口说明 注意 阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致...
作为Output接入
云消息队列 Kafka 版 可以作为Output接入Filebeat。本文说明如何在公网环境下通过Filebeat向 云消息队列 Kafka 版 发送消息。前提条件 在开始本教程前，请确保您已完成以下操作：购买并部署 云消息队列 Kafka 版 实例。具体操作，请参见 ...
消费失败是否支持重试？
重试机制 云消息队列 RabbitMQ 版 服务端有默认的消息重试机制，不支持您在Consumer客户端重新配置消息重试机制和关闭消息重试机制。云消息队列 RabbitMQ 版 服务端默认的消息重试机制如下：如果您没有开启Consumer客户端消费消息，则不会...
SDK概述
本文介绍 云消息队列 Kafka 版 SDK、支持的多语言SDK。SDK简介 SDK（Software Development Kit）即软件开发工具包，包含示例Demo、库文件、编译工具链以及编译脚本等，不需要开发者进行任何其他的配置，直接可以在SDK对应目录环境下，进行...
API概览
本产品（云消息队列 RocketMQ 5.0 版/2022-08-01）的OpenAPI采用 ROA 签名风格，签名细节参见 签名机制说明。我们已经为开发者封装了常见编程语言的SDK，开发者可通过 下载SDK 直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能...
云消息队列 RocketMQ 版自定义权限策略
自定义权限策略支持版本控制，您可以按照RAM规定的版本管理机制来管理您创建的自定义权限策略版本。操作文档 创建自定义权限策略 修改自定义权限策略内容和备注 删除自定义权限策略 管理权限策略引用记录 管理自定义权限策略版本 自定义...
OnsDLQMessageResendById-重发指定的死信消息
死信消息已达最大重试次数，若重发后再次消费失败，则死信队列中将增加一条 Message ID 相同的消息，可通过控制台死信队列的查询页面或者管控 API 查看该结果。您可通过同一 Message ID 的消息出现次数判断重发后依然消费失败的次数。由于...
示例代码
云消息队列 RocketMQ 版 5.x版本实例可兼容4.x/3.x SDK客户端接入，您可以使用4.x/3.x版本的SDK接入5.x实例进行消息收发。本文为您介绍4.x/3.x版本下的C++ SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为...
OnsInstanceCreate-创建实例
实例是用于云消息队列 RocketMQ 版服务的虚拟机资源，用来存储 Topic 和 Group 信息。该接口一般在新业务发布需要创建新的服务资源的情况下使用。该接口只支持创建标准版实例，不支持创建铂金版实例。云消息队列 RocketMQ 版控制台同时支持...
收发事务消息
云消息队列 RocketMQ 版 发送事务消息时需要实现 LocalTransactionChecker 接口，用来处理Broker主动发起的本地事务状态回查请求；因此在事务消息的Check方法中，需要完成两件事情：检查该半事务消息对应的本地事务的状态（committed or ...
调用方式
Action：要执行的操作，如调用 ApplyToken 来申请Token。Version：要使用的API版本，云消息队列 MQTT 版 的API版本是 2020-04-20。Parameters：请求参数，每个参数之间用“&”分隔。请求参数由公共请求参数和API自定义参数组成。公共参数中...
企业铂金版生命周期管理
升降配影响 云消息队列 RocketMQ 版 控制台和实例中每个服务节点可能出现秒级闪断，客户端有自动重试机制，一般不会影响业务，但会有异常日志产生，可能会有消息延迟的现象。消息可能会有重复，建议做好消息幂等处理。具体操作，请参见 ...
接入Logstash
本文介绍如何将 云消息队列 Kafka 版 接入Logstash。Logstash Logstash是开源的服务器端数据处理管道，能够同时从多个数据源采集数据，然后对数据进行转换，并将数据写入指定的存储中。Logstash的数据处理流程如下：输入：采集各种格式、...
领域模型概述
云消息队列 RocketMQ 版 通过流式特性的无限队列结构来存储消息，消息在队列内具备顺序性存储特征。消息（Message）：云消息队列 RocketMQ 版 的最小传输单元。消息具备不可变性，在初始化发送和完成存储后即不可变。消息消费 消费者分组...
- 产品推荐
- 这些文档可能帮助您