领域模型概述
本文为您介绍 云消息队列 RocketMQ 版 的领域模型。产品定位 云消息队列 RocketMQ 版 是一款典型的分布式架构下的中间件产品，使用异步通信方式和发布订阅的消息传输模型。通信方式和传输模型的具体说明，请参见下文 通信方式介绍 和 消息...
队列控制台操作帮助
接收消息 区域显示队列的消息列表。可选：在消息列表中找到目标消息，在其右侧 操作 列单击 详情，在 消息详情 对话框中查看消息内容等信息。删除消息 在 队列列表 页面，找到目标队列，在其右侧 操作 列选择 更多>收发消息。可选：在 队列...
主题（Topic）
本文介绍 云消息队列 RocketMQ 版 中主题（Topic）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 主题是 云消息队列 RocketMQ 版 中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。主题的作用主要如下：...
日志配置
您需要在 pom.xml配置文件或者lib中添加对应的日志实现依赖来打印 云消息队列 RocketMQ 版 客户端日志。推荐您使用最新版本的日志。重要 应用中同时依赖Log4j和Logback的日志实现会造成日志冲突导致客户端日志打印混乱。请确保应用只依赖...
怎样让Consumer不立即消费消息并使消息重入队列？
使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。basicReject方法的参数说明如下：deliveryTag：Channel的消息投递的唯一标识符。requeue：被否定应答的消息...
怎样让Consumer不立即消费消息并使消息重入队列？
使用basicReject方法否定应答单条消息并使消息重入队列 您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。basicReject方法的参数说明如下：deliveryTag：Channel的消息投递的唯一标识符。requeue：被否定应答的消息...
日志配置
客户端日志用于记录 云消息队列 RocketMQ 版 客户端运行过程中的异常，帮助您快速定位和修复问题。本文介绍如何为客户端开启日志打印功能、客户端日志的配置项说明以及如何自定义配置客户端日志。重要 推荐您使用最新的RocketMQ 5.x系列SDK...
队列（MessageQueue）
流式操作语义 云消息队列 RocketMQ 版 基于队列的存储模型可确保消息从任意位点读取任意数量的消息，以此实现类似聚合读取、回溯读取等特性，这些特性是RabbitMQ、ActiveMQ等非队列存储模型不具备的。模型关系 在整个 云消息队列 RocketMQ ...
权益分发
可以帮助简化DB和缓存间的实现，大大减少代码开发量。如果没有 云消息队列 RocketMQ 版，实现方法则十分复杂。支持实时消息收发以及重试功能，确保消息不丢，从而保证消息强一致性。更多信息 云消息队列 RocketMQ 版 的功能与特性详情，请...
使用MongoDB Connector连接MongoDB数据库
本文介绍如何创建MongoDB Connector，将MongoDB数据库和 云消息队列 Kafka 版 的数据进行双向同步。前提条件 开通事件总线EventBridge并授权。已开通对象存储OSS服务并创建存储空间（Bucket）。更多信息，请参见 控制台创建存储空间。已...
配额与限制
云消息队列 RocketMQ 版 对实例的资源配额、实例规格和相关参数进行了约束和规范，您在使用 云消息队列 RocketMQ 版 时不要超过对应的限制值，避免应用出现异常。参数限制 以下参数中各资源的命名及备注等限制值不支持调整，请严格按照规范...
应用场景
云消息队列 Kafka 版 忽略掉文件的细节，可以将多台主机或应用的日志数据抽象成一个个日志或事件的消息流，异步发送到 云消息队列 Kafka 版 集群，从而实现非常低的RT。云消息队列 Kafka 版 客户端可批量提交消息和压缩消息，对生产者而言...
基本概念
本文介绍 云消息队列 RocketMQ 版 的基本概念，以便您更好地理解和使用 云消息队列 RocketMQ 版。主题（Topic）云消息队列 RocketMQ 版 中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。主题通过TopicName来做唯一标识和区分。...
通过创建规则实现日志服务事件通知
消息服务MNS 支持通过创建规则实现 日志服务 SLS（Simple Log Service）事件通知。前提条件 开通消息服务MNS并授权 注意事项 事件通知规则创建完成后，约10分钟生效。事件通知规则指定消息接收端时，如果选择主题，就不能选择其他的接收...
ACL授权
本文介绍如何在 云消息队列 Confluent 版 上实现ACL授权。背景信息 ACL的全称是Access Control Lists，指访问控制列表。这种授权方式比RBAC授权粒度更细。ACL授权主要有两种方式：通过 云消息队列 Confluent 版 控制台实现ACL授权。本文...
通过创建默认规则实现OSS事件通知
本文介绍如何通过创建默认规则实现OSS事件通知。前提条件 开通消息服务MNS 注意事项 事件通知规则创建完成后，约10分钟生效。事件通知规则指定消息接收端时，如果选择主题，就不能选择其他的接收终端。即如果选择了主题，那只能继续选择...
通过元数据文件迁移上云
本文介绍如何在 云消息队列 Kafka 版 控制台创建迁移任务，将元数据迁移至 云消息队列 Kafka 版 已有实例。前提条件 下载JDK 8 购买并部署 云消息队列 Kafka 版 实例：购买并部署VPC实例 购买并部署公网/VPC实例 背景信息 Kafka集群元数据...
步骤一：（可选）RAM用户授权
RAM用户默认没有 云消息队列 RabbitMQ 版 资源的操作权限。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能拥有 云消息队列 RabbitMQ 版 资源的操作权限和消息收发权限。背景信息 本操作仅针对RAM用户，若您的账号为阿里云账号，则...
收发事务消息
云消息队列 RocketMQ 版 发送事务消息时需要实现 LocalTransactionChecker 接口，用来处理Broker主动发起的本地事务状态回查请求，因此在事务消息的Check方法中，需要完成两件事情：检查该半事务消息对应的本地事务的状态（committed or ...
迁移概述
借助工具迁移 迁移工具 迁移工具 说明 参考文档 kafka-migration-assessment.jar 您可以使用该工具将自建Kafka集群元数据通过控制台任务导出为JSON格式文件，然后上传该文件至 云消息队列 Kafka 版 迁移任务并运行任务，实现元数据迁移。...
消息存储和清理机制
背景信息 参考 云消息队列 RocketMQ 版 中 队列 的定义，消息按照达到服务器的先后顺序被存储到队列中，理论上每个队列都支持无限存储。但是在实际部署场景中，服务端节点的物理存储空间有限，消息无法做到永久存储。因此，在实际使用中...
收发事务消息
云消息队列 RocketMQ 版 发送事务消息时需要实现 LocalTransactionChecker 接口，用来处理Broker主动发起的本地事务状态回查请求，因此在事务消息的Check方法中，需要完成两件事情：检查该半事务消息对应的本地事务的状态（committed or ...
迁移自建Kafka集群至新实例
本文介绍如何在 云消息队列 Kafka 版 控制台创建并启动迁移任务。前提条件 下载JDK 8 安装Tsar 为了更准确的获取执行机器的配置，推荐您提前安装Tsar软件。您也可以在运行迁移工具时通过指定-installTsar 参数自动安装Tsar软件，但自动安装...
步骤一：（可选）RAM用户授权
RAM用户默认没有 云消息队列 RocketMQ 版 资源的操作权限。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或OpenAPI管理 云消息队列 RocketMQ 版 的资源。背景信息 本操作仅针对RAM用户，若您的账号为阿里云账号，则默认...
消息（Message）
本文介绍 云消息队列 RocketMQ 版 中消息（Message）的定义、模型关系、内部属性、行为约束及使用建议。定义 消息是 云消息队列 RocketMQ 版 中的最小数据传输单元。生产者将业务数据的负载和拓展属性包装成消息发送到 云消息队列 RocketMQ...
收发事务消息
云消息队列 RocketMQ 版 发送事务消息时需要实现 LocalTransactionChecker 接口，用来处理Broker主动发起的本地事务状态回查请求；因此在事务消息的Check方法中，需要完成两件事情：检查该半事务消息对应的本地事务的状态（committed or ...
直播互动解决方案
背景信息 在直播互动的场景下，您需创建相应的数据互通规则实现 云消息队列 MQTT 版 与 云消息队列 RocketMQ 版 的数据互通，包含 数据流入规则、数据流出规则 以及 客户端上下线通知规则。使用 云消息队列 MQTT 版 的客户端收发消息时，...
收发事务消息
目前支持的地域包括公网、华东1（杭州）、华北2（北京）、华东2（上海）、华南1（深圳）。...具体代码的更多信息，请参见 MyLocalTransactionChecker 的实现。订阅事务消息 事务消息的订阅与普通消息订阅一致，更多信息，请参见 订阅消息。
在Knative上实现Kafka消息推送
Knative已支持Kafka事件源，您可将Knative与 云消息队列 Kafka 版 对接，在Knative上实现Kafka消息推送。前提条件 部署Knative 购买并部署 云消息队列 Kafka 版 实例 重要 云消息队列 Kafka 版 实例和Knative必须处于同一VPC内。云消息队列...
名词解释
在使用 云消息队列 MQTT 版 前，需理解该产品和MQTT协议所涉及的基本概念和术语。基本概念 实例（Instance）创建购买 云消息队列 MQTT 版 服务的实体单元，每个 云消息队列 MQTT 版 实例都对应一个全局唯一的服务接入点URL。使用 云消息...
环境准备（v2.x.x）
本文介绍使用C++ SDK v2.x.x版本接入 云消息队列 RocketMQ 版 所需完成的准备工作、使用说明以及注意事项，以便后续使用C++ SDK收发消息。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和 云消息队列 RocketMQ ...
环境准备（v2.x.x）
本文介绍使用C++ SDK v2.x.x及以上版本接入 云消息队列 RocketMQ 版 所需完成的准备工作、使用说明以及注意事项，以便后续使用C++ SDK收发消息。使用前，请注意以下几点：本文仅针对C++ SDK v2.x.x及以上版本进行说明，若您需从当前使用的v...
签名鉴权模式
如果您需使用 云消息队列 MQTT 版 的签名鉴权模式，可根据本文提供的签名计算方式获取签名，再使用控制台来验证计算得出的签名是否正确。签名计算方式 按照 鉴权概述 的描述，如果选择签名校验模式，MQTT客户端实际连接MQTT消息服务器时，...
MQTT与RocketMQ的消息结构映射
云消息队列 MQTT 版 是一款面向移动端的网关产品，可通过数据互通规则实现与其他阿里云产品，例如 云消息队列 RocketMQ 版 的交互。规则的详细信息，请参见 规则管理。如果单独使用 云消息队列 MQTT 版，则无需关注本文提供的映射关系，...
基本概念
本文主要对 云消息队列 RocketMQ 版 涉及的专有名词及术语进行定义和解析，方便您更好地理解相关概念并使用 云消息队列 RocketMQ 版。Topic 消息主题，一级消息类型，通过Topic对消息进行分类。更多信息，请参见 Topic与Tag最佳实践。消息...
开源对比
云消息队列 RabbitMQ 版 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品，能够兼容开源RabbitMQ客户端，与开源RabbitMQ相比，能够解决各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等...
开源RabbitMQ迁移上云
在使用开源RabbitMQ集群时，当您希望能够解决各种稳定性痛点（例如消息堆积、脑裂等问题）、实现高并发、分布式、灵活扩缩容时，您可以将开源RabbitMQ集群迁移至 云消息队列 RabbitMQ 版，本文介绍迁移上云的前提条件、操作步骤、注意事项...
JMS概述
云消息队列 RabbitMQ 版 提供JMS库供JMS客户端接入 云消息队列 RabbitMQ 版。本文介绍 云消息队列 RabbitMQ 版 JMS库的相关概念、获取方式、使用限制和使用教程。背景信息 JMS是一种消息传递标准，允许基于Java EE（Java平台企业版）的应用...
死信队列
说明 死信消息产生的时间是指一条消息在投递重试达到最大次数后被发送到死信队列的时间。按 Message ID 查询 按Message ID查询消息属于精确查询。您可以根据Group ID与Message ID精确查询到任意一条消息。导出死信消息 若您暂时无法处理...
鉴权概述
本文主要介绍 云消息队列 MQTT 版 客户端鉴权的原理和分类，以便您使用相应的鉴权功能。鉴权原理 使用 云消息队列 MQTT 版 的客户端收发消息时，服务端会根据MQTT客户端设置的UserName和Password参数来进行鉴权。针对不同的权限验证场景，...
- 产品推荐
- 这些文档可能帮助您