创建MNS Sink Connector
本文介绍如何在 云消息队列 Kafka 版 控制台创建消息流出任务，将 云消息队列 Kafka 版 的数据导出至 消息服务。前提条件 您已购买并部署 云消息队列 Kafka 版 实例，且实例处于 服务中 状态。具体步骤，请参见 步骤二：购买和部署实例。您...
收发顺序消息
顺序消息（FIFO 消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的.NET SDK收发顺序消息的示例代码。顺序消息分类 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照...
消费进度管理
消费进度原理 消息位点（Offset）参考 云消息队列 RocketMQ 版 主题 和 队列 的定义，消息是按到达服务端的先后顺序存储在指定主题的多个队列中，每条消息在队列中都有一个唯一的Long类型坐标，这个坐标被定义为消息位点。任意一个消息队列...
主题（Topic）
主题管理尽量避免自动化机制 在 云消息队列 RocketMQ 版 架构中，主题属于顶层资源和容器，拥有独立的权限管理、可观测性指标采集和监控等能力，创建和管理主题会占用一定的系统资源。因此，生产环境需要严格管理主题资源，请勿随意进行增...
产品架构
本文介绍 云消息队列 Kafka 版 的系统架构和发布/订阅模型。云消息队列 Kafka 版 系统架构 如 云消息队列 Kafka 版的系统架构 所示，一个 云消息队列 Kafka 版 集群包括Producer、Kafka Broker、Group、ZooKeeper。图 1.云消息队列 Kafka ...
脚本任务
本文介绍如何在创建任务时通过编写Shell、Python或Go脚本创建脚本任务。创建脚本任务 步骤一：选择脚本语言 在 任务管理 页面创建任务，具体操作，请参见 任务管理。任务类型 选择 脚本任务，然后选择 脚本语言。当前支持的脚本语言类型：...
脚本任务
本文介绍如何在创建任务时通过编写Shell、Python或Go脚本创建脚本任务。创建脚本任务 步骤一：选择脚本语言 在 任务管理 页面创建任务，具体操作，请参见 任务管理。任务类型 选择 脚本任务，然后选择 脚本语言。当前支持的脚本语言类型：...
赋值节点
赋值节点支持ODPS SQL、SHELL和Python三种赋值语言，将节点最后一条查询或输出结果自动赋值给节点自带的输出参数（outputs），便于赋值节点的下游节点引用。您可结合节点上下文配置，参考本文使用赋值节点。注意事项 部分节点可通过节点...
操作指南
您可以在 云消息队列 RocketMQ 版 控制台管理实例、Topic、Group等资源，并进行消息轨迹查询、...云消息队列 RocketMQ 版4.x系列 实例管理 Topic管理 Group管理 查询消息轨迹 监控报警 重置消费位点 其他更多操作，请参见 4.x系列操作指南。
准备环境
在运行Java代码收发消息前，您需按照本文提供的步骤来准备环境。...以下版本号请替换为Java SDK的最新版本号-><version>1.8.8.1.Final</version></...后续步骤 日志配置 更多信息 Spring集成 发送普通消息（三种方式）发送消息（多线程）
领域模型概述
消息存储 主题（Topic）：云消息队列 RocketMQ 版 消息传输和存储的分组容器，主题内部由多个队列组成，消息的存储和水平扩展实际是通过主题内的队列实现的。队列（MessageQueue）：云消息队列 RocketMQ 版 消息传输和存储的实际单元容器，...
MQTT与RocketMQ的消息结构映射
本文针对使用 云消息队列 RocketMQ 版 SDK与 云消息队列 MQTT 版 交互的场景，提供交互中所涉及的消息结构和属性字段的映射关系，方便您更好的理解和组合使用这两个产品。云消息队列 MQTT 版 是一款面向移动端的网关产品，可通过数据互通...
新零售电子价签解决方案（MQTT）
新零售电子价签解决方案由阿里云 云消息队列 MQTT 版 推出，通过MQTT以实现商场超市、公共场所电子标签、多媒体屏幕的数据更新管理。本文将以电子价签为例详细描述该解决方案的系统架构、数据流设计以及注意事项，其他类似行业可参考该方案...
常见问题
本文汇总了使用 云消息队列 RocketMQ 版 时的常见问题。产品功能常见问题 消息队列RocketMQ版5.x系列相比4.x系列实例有什么优势？消息队列RocketMQ版5.x系列实例兼容哪些版本客户端？消息队列RocketMQ版支持哪些语言客户端？消息队列...
开源RabbitMQ迁移上云
创建Shovel任务，将Source配置为开源RabbitMQ集群的服务地址和队列名称，Destination配置为 云消息队列 RabbitMQ 版 的EndPoint和队列名称。EndPoint的查看方式，请参见 查看实例详情 修改开源RabbitMQ队列消费者的接入点、用户名、密码，...
常见问题
本文汇总了使用 云消息队列 RocketMQ 版 时的常见问题。产品功能常见问题 云消息队列 RocketMQ 版5.0系列相比4.0系列实例有什么优势？云消息队列 RocketMQ 版5.0系列实例兼容哪些版本客户端？云消息队列 RocketMQ 版支持哪些语言客户端？云...
YARN调度器
主调度（MainScheduler）：是基于资源请求的异步多线程处理框架，内部包含分配线程和提交线程，一个或多个分配线程负责定位优先级最高的资源请求，根据其资源大小及摆放约束批量选择合适的候选节点，生成分配提案放入中间队列，由单个提交...
顺序消息
串行发送 云消息队列 RocketMQ 版 生产者客户端支持多线程安全访问，但如果生产者使用多线程并行发送，则不同线程间产生的消息将无法判定其先后顺序。满足以上条件的生产者，将顺序消息发送至 云消息队列 RocketMQ 版 后，会保证设置了同一...
应用场景
本文为您介绍 云消息队列 RocketMQ 版 的应用场景，以便您更好地判断如何在业务中使用 云消息队列 RocketMQ 版。例如，针对一家互联网电商企业，其业务涉及广泛，如注册、订单、库存、物流等；同时，也会涉及许多业务峰值时刻，如秒杀活动...
收发顺序消息
顺序消息FIFO（First In First Out）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的C/C++ SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，...
数据流入规则管理
如需将其他阿里云产品的数据导入 云消息队列 MQTT 版，您需创建数据流入规则。该规则用于从您配置的阿里云产品中读取数据并将数据通过MQTT协议推送到MQTT客户端，从而实现直接调用阿里云产品的API发送数据到MQTT客户端。流程说明 规则限制 ...
MQTT快速入门
作为使用和熟悉产品功能的入门指导，本文提供如何快速使用 云消息队列 MQTT 版 通过默认支持的MQTT协议收发消息的步骤。对于非MQTT协议的接入，例如新能源，您必须首先购买 云消息队列 MQTT 版 企业铂金版，并通过专属通道享受对应的文档和...
开源对比
本文从稳定性、内核能力、治理能力以及使用习惯等方面，对比阿里云 云消息队列 Kafka 版 与开源Apache Kafka。稳定性 项目 云消息队列 Kafka 版 Apache Kafka 磁盘水位 磁盘写满删除旧数据。磁盘写满直接宕机。线程池隔离 读冷数据仍可以...
消息堆积和延迟问题
本文主要介绍 云消息队列 RocketMQ 版 TCP协议的Java客户端使用过程中，经常会出现的消息堆积和消息延迟的问题。通过了解 云消息队列 RocketMQ 版 客户端的消费原理和消息堆积的主要原因，帮助您可以在业务部署前更好的规划资源和配置，或...
消费者（Consumer）
使用建议 不建议在单一进程内创建大量消费者 云消息队列 RocketMQ 版 的消费者在通信协议层面支持非阻塞传输模式，网络通信效率较高，并且支持多线程并发访问。因此，大部分场景下，单一进程内同一个消费分组只需要初始化唯一的一个消费者...
Connection和Channel
本文介绍 云消息队列 RabbitMQ 版 中Connection和Channel的概念及其使用建议。Connection Connection是物理TCP连接。Connection将应用与 云消息队列 RabbitMQ 版 连接在一起。Connection会执行认证、IP解析、路由等底层网络任务。应用与 云...
VPC接入
如果仅需要在VPC网络接入 云消息队列 Kafka 版，您可以购买并部署VPC实例。前提条件 已授予 云消息队列 Kafka 版 访问其他云服务资源的权限。具体信息，请参见 步骤一：获取访问授权。已搭建VPC网络。具体操作，请参见 创建和管理专有网络...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的Java SDK收发顺序消息的示例代码。前提条件 您已完成以下操作：下载1.2.7或以上版本的Java SDK。更多信息，请参见...
分账规则及最佳实践
分账，是指企业根据成本中心将云上资源的成本划分到各个项目组或业务部门，快速梳理云上成本结构，建立复杂组织架构下的成本关系，便捷地进行云上成本管理。本文为您介绍 云消息队列 RocketMQ 版 的分账规则和最佳实践。分账规则 分账对象...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的Java SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格...
开通消息队列服务并授权
在阿里云官方网站开通消息队列服务后方可开始使用 云消息队列 RocketMQ 版。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的 云消息队列 RocketMQ 版 资源，并使用资源通过SDK收发消息。前提条件 您已注册...
开通消息队列服务并授权
在阿里云官方网站开通消息队列服务后方可开始使用 云消息队列 RocketMQ 版。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的 云消息队列 RocketMQ 版 资源，并使用资源通过SDK收发消息。前提条件 您已注册...
企业铂金版计费说明
企业铂金版实例的计费方式为包年包月（预付费），适合高SLA要求或消息量较大的业务场景。通过包年包月付费方式您可以提前...云消息队列 RocketMQ 版 支持企业铂金版和标准版实例互相转换，更多信息，请参见 企业铂金版和标准版实例相互转换。
公网和VPC接入
如果需要同时在VPC网络和公网接入 云消息队列 Kafka 版，您需要购买并部署公网/VPC实例。前提条件 已授予 云消息队列 Kafka 版 访问其他云服务资源的权限。具体信息，请参见 获取访问授权。已搭建VPC网络。具体操作，请参见 创建和管理专有...
分账规则及最佳实践
分账，是指企业根据成本中心将云上资源的成本划分到各个项目组或业务部门，快速梳理云上成本结构，建立复杂组织架构下的成本关系，便捷地进行云上成本管理。本文为您介绍 云消息队列 RocketMQ 版 的分账规则和最佳实践。分账规则 分账对象...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的PHP SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格...
使用限制
云消息队列 RocketMQ 版 对某些具体指标进行了约束和规范，您在使用 云消息队列 RocketMQ 版 时不要超过对应的限制值，避免程序出现异常。云消息队列 RocketMQ 版5.x系列 5.x系列使用限制 云消息队列 RocketMQ 版4.x系列 4.x系列使用限制
基本概念
本文主要对 云消息队列 RocketMQ 版 涉及的专有名词及术语进行定义和解析，方便您更好地理解相关概念并使用 云消息队列 RocketMQ 版。Topic 消息主题，一级消息类型，通过Topic对消息进行分类。更多信息，请参见 Topic与Tag最佳实践。消息...
消费者分组（ConsumerGroup）
本文介绍 云消息队列 RocketMQ 版 中消费者分组（ConsumerGroup）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 消费者分组是 云消息队列 RocketMQ 版 系统中承载多个消费行为一致的消费者的负载均衡分组。和消费者...
数据流出规则管理
如需将 云消息队列 MQTT 版 的数据导出至其他阿里云产品，您需创建数据流出规则。该规则用于将MQTT客户端发送的消息导出到您配置的其他阿里云产品中，从而实现直接调用云产品的API读取MQTT客户端发送的消息。流程说明 规则限制 限制项 限制...
- 产品推荐
- 这些文档可能帮助您