查看实例风险
云消息队列 Kafka 版 实例的实时诊断功能能够定期对实例进行检测，支持查看诊断发现的问题、提供修复建议，并将异常的检查项上报告警给相关联系人。实现方案 报警通知说明 仅紧急且不健康的报警会发送报警通知。如果未添加报警联系人，则...
消费者负载均衡
重要 消息粒度负载均衡策略保证同一个队列的消息可以被多个消费者共同处理，但是该策略使用的消息分配算法结果是随机的，并不能指定消息被哪一个特定的消费者处理。消息粒度的负载均衡机制，是基于内部的单条消息确认语义实现的。消费者...
准备环境
在使用PHP SDK收发消息前，您需按照本文提供的内容来准备环境。环境要求 安装PHP 5.5.0或以上版本，更多信息，请参见 安装PHP。重要 对于PHP版本小于7.2.5的运行环境，需要将Composer依赖降低到2.2.x或以下版本。安装Composer，更多信息，...
收发事务消息
云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能，通过 云消息队列 RocketMQ 版 事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的PHP SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示。更...
消息收发功能
本文提供单独使用 云消息队列 MQTT 版 收发消息以及与 云消息队列 RocketMQ 版 结合使用时需使用的代码示例的链接。单独使用 云消息队列 MQTT 版 收发消息 语言 链接 Java ...
功能与特性概述
集群消费和广播消费：当使用集群消费模式时，云消息队列 RocketMQ 版 认为任意一条消息只需要被消费者集群内的任意一个消费者处理即可；当使用广播消费模式时，云消息队列 RocketMQ 版 会将每条消息推送给消费者集群内所有注册过的消费者，...
P2P消息收发模式（MQTT）
本文介绍P2P模式的概念、原理以及如何使用 云消息队列 MQTT 版 点对点收发消息。什么是P2P模式 P2P，顾名思义，是一对一的消息收发模式，即只有一个消息发送者和一个消息接收者。而Pub/Sub模式通常用于一对多或多对多的消息群发场景，即...
P2P消息收发模式（MQTT）
本文介绍P2P模式的概念、原理以及如何使用 云消息队列 MQTT 版 点对点收发消息。什么是P2P模式 P2P，顾名思义，是一对一的消息收发模式，即只有一个消息发送者和一个消息接收者。而Pub/Sub模式通常用于一对多或多对多的消息群发场景，即...
使用AMQProxy解决PHP等客户端Connection复用问题
AMQProxy处理客户端发起的Connection相关请求的逻辑如下：如果客户端发送开启Connection的请求，AMQProxy将根据用户名、密码、Vhost查找当前是否有合适的Connection可以复用，如果有就复用该Connection，如果没有就由AMQProxy代替客户端和 ...
事务消息
使用规则 生产消息规则 事务消息发送完成本地事务后，可在 execute 方法中返回以下三种状态：TransactionStatus.CommitTransaction：提交事务，允许消费者消费该消息。TransactionStatus.RollbackTransaction：回滚事务，消息将被丢弃不...
消费者分类
云消息队列 RocketMQ 版 支持PushConsumer和SimpleConsumer这两种类型的消费者，本文分别从使用方式、实现原理、可靠性重试和适用场景等方面为您介绍这两种类型的消费者。背景信息 云消息队列 RocketMQ 版 面向不同的业务场景提供了不同...
QueueHasDiffField
本文为您介绍 云消息队列 RabbitMQ 版 客户端报QueueHasDiffField类型错误的原因和处理方法。问题现象 使用 云消息队列 RabbitMQ 版 客户端连接 云消息队列 RabbitMQ 版 服务端时，报QueueHasDiffField类型错误。例如QueueHasDiffField...
顺序消息
本文介绍 云消息队列 RocketMQ 版 顺序消息的概念、适用场景、实现原理以及使用过程中的注意事项。什么是顺序消息 顺序消息是 云消息队列 RocketMQ 版 提供的一种对消息发送和消费顺序有严格要求的消息。对于一个指定的Topic，消息严格按照...
ExchangeHasDiffFields
介绍 云消息队列 RabbitMQ 版 客户端报ExchangeHasDiffFields类型错误的原因和处理方法。问题现象 使用 云消息队列 RabbitMQ 版 客户端连接 云消息队列 RabbitMQ 版 服务端时，报ExchangeHasDiffFields类型错误。例如ExchangeHasDiffFields...
迁移上云操作
本文为您介绍如何使用 云消息队列 RocketMQ 版 的迁移工具将开源自建的Apache RocketMQ迁移至阿里云 云消息队列 RocketMQ 版。前提条件 创建消息队列RocketMQ版5.0系列实例 创建服务关联角色 角色名称：AliyunServiceRoleForRMQMigration ...
MQTT和RocketMQ进行数据互通（客户端上下线通知）
MQTT客户端的上下线事件将会触发MQTT服务端生成一条通知消息，云消息队列 MQTT 版 支持将该条消息数据导出至其他阿里云产品，并使用MQTT的Java SDK实现MQTT客户端与后端应用收发消息。本文以当前仅支持的 云消息队列 RocketMQ 版 数据互通...
收发普通消息
普通消息是指 云消息队列 RocketMQ 版 中无特性的消息，区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的PHP SDK收发普通消息的示例代码。前提条件 您已完成以下操作：安装PHP SDK。更多信息，请参见 准备环境...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的PHP SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格...
收发定时消息和延时消息
本文提供使用HTTP协议下的PHP SDK收发定时消息和延时消息的示例代码。背景信息 延时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时...
顺序消息
使用限制 顺序消息仅支持使用 MessageType 为 FIFO 的主题，即顺序消息只能发送至类型为顺序消息的主题中，发送的消息的类型必须和主题的类型一致。使用示例 和普通消息发送相比，顺序消息发送必须要设置消息组。消息组的粒度建议按照业务...
队列服务订阅推送
介绍队列服务订阅推送功能的使用。在订阅推送可以持续地将就绪的数据立即推送到客户端手中，避免通过Get API进行轮询造成的时延和通过队列服务的内部机制进行查询，可以最大程度地降低处理时延和队列服务的负载。但是在使用上，由于有较多...
跨云产品的数据流出
设备数据上报 海量设备通过MQTT协议上报状态数据到 云消息队列 MQTT 版，配置数据流出规则将 云消息队列 MQTT 版 的Topic映射到 云消息队列 RocketMQ 版 的Topic后，可以直接在后台服务启动 云消息队列 RocketMQ 版 的消费者消费处理上报...
快速使用MQTT.fx模拟SDK收发消息
本文以Windows系统为例，介绍如何使用MQTT.fx模拟SDK接入 云消息队列 MQTT 版 并进行消息收发。前提条件 下载并安装 MQTT.fx。背景信息 云消息队列 MQTT 版 最简单的使用场景即MQTT客户端消息的自发自收。如下图所示，您可以使用MQTT.fx...
管理资源队列
您也可以将批作业部署到指定资源队列，并配合任务编排功能确定调度优先级，以确保关键或重要作业获得更高的处理优先级和更多的资源，从而提高系统性能和资源利用率。您可以通过以下方式使用资源队列：部署作业时，部署目标选择为目标资源...
PHP SDK收发消息
本文介绍如何使用PHP SDK通过接入点接入 云消息队列 Kafka 版 并收发消息。环境准备 安装GCC 安装PHP 安装PECL 安装C++依赖库 执行以下命令切换到yum源配置目录/etc/yum.repos.d/。cd/etc/yum.repos.d/创建yum源配置文件 confluent.repo。...
什么是云消息队列 RocketMQ 版？
云消息队列 RocketMQ 版 是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台，面向互联网分布式应用场景提供微服务异步解耦、流式数据处理、事件驱动处理等核心能力。为什么选择云...
如何快速使用消息队列RocketMQ版的TCP Java SDK收发...
本文提供使用 消息队列RocketMQ版 的TCP Java SDK收发消息的快速入门视频。
消费者（Consumer）
本文介绍 云消息队列 RocketMQ 版 中消费者（Consumer）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义 消费者是 云消息队列 RocketMQ 版 中用来接收并处理消息的运行实体。消费者通常被集成在业务系统中，从 云消息...
消息轨迹
使用限制 使用 云消息队列 RabbitMQ 版 消息轨迹功能时，限制如下：仅当实例支持消息轨迹时，才可以查询该实例中消息收发的轨迹。说明 实例是否支持消息轨迹和可以查询的消息轨迹时间范围，由您在创建实例时选择配置。如果实例未配置消息...
定时/延时消息
定时/延时消息为 云消息队列 RocketMQ 版 中的高级特性消息，本文为您介绍定时/延时消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 说明 定时消息和延时消息本质相同，都是服务端根据消息设置的定时时间在某一固定时刻...
消息过滤
使用 云消息队列 RocketMQ 版 的消息过滤功能，可以帮助消费者更高效地过滤自己需要的消息集合，避免大量无效消息投递给消费者，降低下游系统处理压力。云消息队列 RocketMQ 版 主要解决的单个业务域即同一个主题内不同消息子集的过滤问题...
使用Canal和RocketMQ实现数据库变更订阅处理
本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版，实现MySQL数据库Binlog数据的变更处理。背景信息 CDC（Change Data Capture）是一种监测并捕获数据库变更的典型技术方案，常应用于异构数据源之间的数据同步。Canal...
使用Canal和RocketMQ实现数据库变更订阅处理
本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版，实现MySQL数据库Binlog数据的变更处理。背景信息 CDC（Change Data Capture）是一种监测并捕获数据库变更的典型技术方案，常应用于异构数据源之间的数据同步。Canal...
消息收发流程变更
云消息队列 MQTT 版 V2.x.x版本强依赖 云消息队列 RocketMQ 版 作为消息存储，因此 云消息队列 MQTT 版 消息和 云消息队列 RocketMQ 版 天然打通，创建了Topic后即可天然使用 云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 的SDK相互通信...
设置消息通知
步骤二、创建主题或队列 媒体处理支持接收MNS主题和队列消息，您可以根据实际业务需要创建主题或队列。创建主题 在MNS控制台左侧导航栏选择 主题列表，在主题列表页面单击 创建主题。在创建主题页面，填写如下参数，完成配置。参数 说明 ...
消费重试
以下场景不建议使用消息重试 消费处理逻辑中使用消费失败来做条件判断的结果分流，是不合理的，因为处理逻辑已经预见了一定会大量出现该判断分支。消费处理中使用消费失败来做处理速率限流，是不合理的。限流的目的是将超出流量的消息暂时...
调用方式
HTTP调用 云消息队列 RabbitMQ 版 HTTP调用是向 云消息队列 RabbitMQ 版 API的服务端地址发送HTTP请求，并按照接口说明在请求中加入相应请求参数，调用后系统会返回处理结果。请求及返回结果都使用UTF-8字符集进行编码。云消息队列 ...
使用云消息队列 Kafka 版时出现消息堆积
使用 云消息队列 Kafka 版 时，可能会发现Group中出现消息堆积。本文介绍如何判断消息堆积是否属于正常情况，以及处理方法。客户端消费流程 了解客户端消费流程，有助于理解消息是否堆积。一般情况下，客户端消费流程大致如下：判断消息...
SDK FAQ
您可以使用basicReject方法否定应答单条消息，或者使用basicNack方法否定应答一条或多条消息，并使消息重入队列。使用basicReject方法否定应答消息并使消息重入队列 参数 说明 deliveryTag Channel的消息投递的唯一标识符。requeue 被否定...
订阅关系（Subscription）
本文介绍 云消息队列 RocketMQ 版 中订阅关系（Subscription）的定义、模型关系、内部属性及使用建议。定义 订阅关系是 云消息队列 RocketMQ 版 系统中消费者获取消息、处理消息的规则和状态配置。订阅关系由消费者分组动态注册到服务端...
- 产品推荐
- 这些文档可能帮助您