队列（MessageQueue）
模型关系 在整个 云消息队列 RocketMQ 版 的领域模型中，队列所处的流程和位置如下：云消息队列 RocketMQ 版 默认提供消息可靠存储机制，所有发送成功的消息都被持久化存储到队列中，配合生产者和消费者客户端的调用可实现至少投递一次的...
默认配置映射关系
在创建消息流入或流出任务时，您可以选择系统的默认配置来定义消息转换规则，从而提高创建任务的效率。本文介绍了默认配置的映射关系详情。同构消息映射关系 当消息的流入方和流出方为同一服务类型时，配置详情，请参见下文：基于事件流...
默认配置映射关系
在创建消息流入或流出任务时，您可以选择系统的默认配置来定义消息转换规则，从而提高创建任务的效率。本文介绍了默认配置的映射关系详情。同构消息映射关系 当消息的流入方和流出方为同一服务类型时，配置详情，请参见下文：基于事件流...
步骤二：创建资源
在调用SDK收发消息前，您需要提前创建 云消息队列 RocketMQ 版 的相关资源，包括创建 云消息队列 RocketMQ 版 实例、获取实例的接入点、创建Topic、创建ConsumerGroup。调用SDK时，需要将这些资源信息填写到SDK代码中。前提条件 创建专有...
使用Canal和RocketMQ实现数据库变更订阅处理
不涉及 高阶参数配置 数据同步Topic和顺序性设置 Canal传输数据库变更事件到 云消息队列 RocketMQ 版 默认遵循一定的顺序性原则，在早期版本中每个任务默认是发送到 云消息队列 RocketMQ 版 单个Topic的单个分区。Topic设置方法可以使用 ...
使用Canal和RocketMQ实现数据库变更订阅处理
MQ_INST_1266540465*_BYSLmTAL 高阶参数配置 数据同步Topic和顺序性设置 Canal传输数据库变更事件到 云消息队列 RocketMQ 版 默认遵循一定的顺序性原则，在早期版本中每个任务默认是发送到 云消息队列 RocketMQ 版 单个Topic的单个分区。...
普通消息
普通消息为 云消息队列 RocketMQ 版 中最基础的消息，区别于有特性的顺序消息、定时/延时消息和事务消息。本文为您介绍普通消息的应用场景、功能原理、使用方法和使用建议。应用场景 普通消息一般应用于微服务解耦、事件驱动、数据集成等...
死信消息
死信消息保存规则 云消息队列 RocketMQ 版 默认不保存死信消息，消息转为死信状态后将被丢弃。您可以通过控制台开启死信消息保存功能，开启后，死信消息将被存储至指定的Topic中，该Topic被称为死信Topic。具体操作，请参见 配置死信消息...
消息查询
查询方式说明 由于消息在 云消息队列 RocketMQ 版 中存储的时间默认为3天（不建议修改），即只能查询从当前查询时间算起3天内的消息。例如，当前时间是2019年06月10日15:09:48，那么能查询到的某Topic下的消息最早的时间点为2019年06月07日...
定时/延时消息
定时/延时消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 说明 定时消息和延时消息本质相同，都是服务端根据消息设置的定时时间在某一固定时刻...
查询消息轨迹
云消息队列 RocketMQ 版 将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数，例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等，并支持可视化查询。当消息收发结果不符合预期...
顺序消息
顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下，异构系统间需要维持强一致的状态同步，...
快速入门概述
本文为您介绍如何快速使用 云消息队列 RocketMQ 版 实现消息收发。使用流程 快速使用 云消息队列 RocketMQ 版 收发消息的流程如下图所示。使用说明 权限说明 若您的账号为RAM用户，则必须先为该RAM用户进行授权，才能访问 云消息队列 ...
日志配置
语言 默认路径 Java {$HOME}/logs/rocketmq/rocketmq-client.log C++ {$HOME}/logs/rocketmq/client.log C#{$HOME}/logs/rocketmq/rocketmq-client.log Go {$HOME}/logs/rocketmq/rocketmq_client_go.log 日志参数 客户端启动后，会按照...
事务消息
事务消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 分布式事务的诉求 分布式系统调用的特点为一个核心业务逻辑的执行，同时需要调用多个下游业务...
消息（Message）
消息持久化 云消息队列 RocketMQ 版 会默认对消息进行持久化，即将接收到的消息存储到 云消息队列 RocketMQ 版 服务端的存储文件中，保证消息的可回溯性和系统故障场景下的可恢复性。模型关系 在整个 云消息队列 RocketMQ 版 的领域模型中...
版本管理
云消息队列 RocketMQ 版 为您提供全托管的版本管理服务，服务端版本更新后，系统会在后台自动完成升级，不影响消息收发，业务侧无感知。您可以根据波峰谷时间修改后台升级的执行时间和可维护时间段。使用限制 仅铂金版实例支持版本管理功能...
常见问题
本文汇总了使用 云消息队列 RocketMQ 版 时的常见问题。产品功能常见问题 云消息队列 RocketMQ 版5.0系列相比4.0系列实例有什么优势？云消息队列 RocketMQ 版5.0系列实例兼容哪些版本客户端？云消息队列 RocketMQ 版支持哪些语言客户端？云...
消息队列RocketMQ版
数据清洗 服务及函数名称 默认创建名称为 RocketMQ_RocketMQ_Transform_<TemplateName>_的服务和函数。当 消息体（body）选择 数据清洗 且选择 新建函数模板 时，需要配置该参数。RocketMQ_RocketMQ_Transform_Customized_1688540172662 ...
订阅关系（Subscription）
消费状态：云消息队列 RocketMQ 版 服务端默认提供订阅关系持久化的能力，即消费者分组在服务端注册订阅关系后，当消费者离线并再次上线后，可以获取离线前的消费进度并继续消费。订阅关系判断原则 云消息队列 RocketMQ 版 的订阅关系按照...
消息队列RabbitMQ版
数据清洗 服务及函数名称 默认创建名称为 RocketMQ_RocketMQ_Transform_<TemplateName>_的服务和函数。当 消息体（body）选择 数据清洗 且选择 新建函数模板 时，需要配置该参数。RocketMQ_RocketMQ_Transform_Customized_1688540172662 ...
计费概述
消息收发费用 消息收发为 云消息队列 RocketMQ 版 的基础功能，您只要开通 云消息队列 RocketMQ 版 服务，则默认使用消息收发功能，标准版实例会计算相应费用。具体计费详情，请参见 消息收发定价详情。公网费用 云消息队列 RocketMQ 版 ...
步骤一：（可选）RAM用户授权
RAM用户默认没有 云消息队列 RocketMQ 版 资源的操作权限。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或OpenAPI管理 云消息队列 RocketMQ 版 的资源。背景信息 本操作仅针对RAM用户，若您的账号为阿里云账号，则默认...
消息过滤
消费者订阅了某个主题后，云消息队列 RocketMQ 版 会将该主题中的所有消息投递给消费者。若消费者只需要关注部分消息，可通过设置过滤条件在 云消息队列 RocketMQ 版 服务端进行过滤，只获取到需要关注的消息子集，避免接收到大量无效的...
消费进度管理
云消息队列 RocketMQ 版 通过消费位点管理消费进度，本文为您介绍 云消息队列 RocketMQ 版 的消费进度管理机制。背景信息 云消息队列 RocketMQ 版 的生产者和消费者在进行消息收发时，必然会涉及以下场景，消息先生产后订阅或先订阅后生产...
消息存储和清理机制
本文为您介绍 云消息队列 RocketMQ 版 中消息的存储机制，包括消息的存储粒度、判断依据及后续处理策略等。背景信息 参考 云消息队列 RocketMQ 版 中 队列 的定义，消息按照达到服务器的先后顺序被存储到队列中，理论上每个队列都支持无限...
存储费用
包年包月和按量付费计费方式下，存储费用为 云消息队列 RocketMQ 版 的必选计费项，系统会根据实例的存储空间占用量进行计费。计费说明 项目 说明 计费公式 存储费用=存储空间×存储单价×存储时长 存储空间的值取计费周期（1小时）内起始...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的Go SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示。更...
4.x和5.x版本差异及兼容性说明
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布，阿里云 云消息队列 RocketMQ 版 将为您提供更加稳定可靠的服务端5...
消息负载均衡策略
云消息队列 RocketMQ 版 的消息负载均衡策略针对生产者和消费者有所差异。对消费者而言，消息负载均衡策略在一定程度上影响消息堆积。背景信息 随着SDK版本的升级，云消息队列 RocketMQ 版 的负载均衡策略也有所优化，根据SDK版本，负载...
云消息队列 RocketMQ 版
RocketMQ_RocketMQ_Transform_Customized_1688540172662 函数模版 选择函数模板。当 消息体（body）选择 数据清洗 且选择 新建函数模板 时，需要配置该参数。内容分割：根据正则表达式对消息内容进行分割，将分割后的消息逐条发送至目标。...
云消息队列 RocketMQ 版
RocketMQ_RocketMQ_Transform_Customized_1688540172662 函数模版 选择函数模板。当 消息体（body）选择 数据清洗 且选择 新建函数模板 时，需要配置该参数。内容分割：根据正则表达式对消息内容进行分割，将分割后的消息逐条发送至目标。...
消息队列RocketMQ版
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 RocketMQ 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。创建消息流出任务 登录 云...
安装CPP动态库
为方便安装，本文以社区版2.0.1版本为例，针对不同的操作系统分别进行说明：CentOS 7.2和RHEL 7.x CentOS默认支持RPM管理，RPM包名为 rocketmq-client-cpp-2.0.1，可以执行以下 rpm 命令直接安装。rpm-ivh ...
安装CPP动态库
为方便安装，本文以社区版2.0.1版本为例，针对不同的操作系统分别进行说明：CentOS 7.2和RHEL 7.x CentOS默认支持RPM管理，RPM包名为 rocketmq-client-cpp-2.0.1，可以执行以下 rpm 命令直接安装。rpm-ivh ...
函数计算
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 Kafka 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已开通函数计算服务，具体...
实例规格
不支持 消息存储时长 3天 若您购买实例的存储空间规格不足时，云消息队列 RocketMQ 版 会按存储时间滚动删除最早的消息，此时消息的存储时长可能不足3天。说明 若您对消息存储时长有特殊要求，您可以联系 云消息队列 RocketMQ 版 技术支持...
消息服务MNS
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 消息服务MNS 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已创建 消息服务MNS 队列。具体步骤，...
消息队列Kafka版
本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流出目标为 云消息队列 Kafka 版 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 版 实例，且实例处于 服务中 状态。具体步骤，请参见 创建资源。您已购买并部署 云消息队列 ...
消息服务MNS
RocketMQ_RocketMQ_Transform_Customized_1688540172662 函数模版 选择函数模板。当 消息体（body）选择 数据清洗 且选择 新建函数模板 时，需要配置该参数。内容分割：根据正则表达式对消息内容进行分割，将分割后的消息逐条发送至目标。...
- 产品推荐
- 这些文档可能帮助您