队列(MessageQueue)

消息在队列中的位置和消息之间的顺序通过位点(Offset)进行标记管理。流式操作语义 云消息队列 RocketMQ 版 基于队列的存储模型可确保消息从任意位点读取任意数量的消息,以此实现类似聚合读取、回溯读取等特性,这些特性是RabbitMQ、...

死信队列

对于消费失败且重试后依然失败的消息,云消息队列 RocketMQ 版 不会立丢弃,而是将消息转发至指定的队列中,即死信队列,这些消息即为死信消息。当消费失败的原因排查并解决后,您可以重发这些死信消息,让消费者重新消费;若您暂时无法...

消费者负载均衡

策略原理 消息粒度负载均衡策略中,同一消费者分组内的多个消费者将按照消息粒度平均分摊主题中的所有消息,即同一个队列中的消息,可被平均分配给多个消费者共同消费。如上图所示,消费者分组Group A中有三个消费者A1、A2和A3,这三个消费...

消息队列RabbitMQ版

amq.direct Queue 选择目标 云消息队列 RabbitMQ 版 实例中的队列。仅当 目标类型 参数配置为 Queue 模式 时需要配置该参数。queue Routing Key 路由消息规则。Body 需要投递的事件的消息内容。配置规则,请参见 消息转换。部分事件$.data....

消息服务MNS

test 开启 Base64编码 是:开启Base64编码,会帮助您将数据编码后投递至 消息服务MNS 中的队列。否:不开启Base64编码。是 在 数据处理 区域,设置消息的过滤、转换、重试和死信。消息过滤 无需过滤:默认投递全部事件。自定义配置:使用...

消息存储和清理机制

消息在队列中的存储情况如下:消息存储管理粒度说明 云消息队列 RocketMQ 版 按照服务端节点粒度管理存储时长而非队列或主题,原因如下:消息存储优势权衡:云消息队列 RocketMQ 版 基于统一的物理日志队列和轻量化逻辑队列的二级组织方式...

云消息队列 RabbitMQ 版

本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建流入任务,将指定 云消息队列 RabbitMQ 版 实例中的数据快速导入至另外的 云消息队列 RabbitMQ 版 实例中。前提条件 您已购买 云消息队列 RabbitMQ 版 实例,且实例处于 服务中 状态。...

消息队列RabbitMQ版

本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流入任务,实现将其他数据源中的数据快速导入 云消息队列 RabbitMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已购买...

仪表盘

在PushConsumer消费场景下,本地缓冲队列相关指标如下:本地缓冲队列中的消息量:本地缓冲队列中的消息总条数。本地缓冲队列中的消息大小:本地缓冲队列中所有消息大小的总和。消息等待处理时间:消息暂存在本地缓冲队列中的时间。Metrics...

消息服务MNS

test 开启 Base64编码 是:开启Base64编码,会帮助您将数据编码后投递至 消息服务MNS 中的队列。否:不开启Base64编码。是 在 数据处理 区域,设置消息的过滤、转换、重试和死信。消息过滤 无需过滤:默认投递全部事件。自定义配置:使用...

消息服务MNS

test 开启 Base64编码 是:开启Base64编码,会帮助您将数据编码后投递至 消息服务MNS 中的队列。否:不开启Base64编码。是 在 数据处理 区域,设置消息的过滤、转换、重试和死信。消息过滤 无需过滤:默认投递全部事件。自定义配置:使用...

ack-kube-queue

2023年12月 版本号 变更内容 变更时间 变更影响 v0.3.3 新增通过环境变量设置全局阻塞队列时将会全局刷新所有Queue的阻塞队列模式。2023年12月26日 此次升级不会对业务造成影响。2023年09月 版本号 变更内容 变更时间 变更影响 v0.3.1 修复...

MQTT和RocketMQ进行数据互通(客户端上下线通知)

本文以公网环境中的Java SDK为例说明 云消息队列 MQTT 版 如何将MQTT客户端上下线事件通知的消息发送至后端应用。此场景下可使用多语言的第三方开源SDK来实现消息收发。更多信息,请参见 SDK下载。重要 云消息队列 RocketMQ 版 和 云消息...

消费者分组(ConsumerGroup)

消息按照到达 云消息队列 RocketMQ 版 服务端的顺序存储到主题的指定队列中。消费者按照指定的订阅关系从 云消息队列 RocketMQ 版 服务端中获取消息并消费。内部属性 消费者分组名称 定义:消费者分组的名称,用于区分不同的消费者分组。...

删除队列消息

本文介绍如何删除某个队列的所有消息。您可以使用Java客户端库 queuePurge 方法删除某个队列的所有消息。示例代码如下:channel.queuePurge("queue-name");

订阅关系(Subscription)

消息按照到达 云消息队列 RocketMQ 版 服务端的顺序存储到主题的指定队列中。消费者按照指定的订阅关系从 云消息队列 RocketMQ 版 服务端中获取消息并消费。内部属性 过滤类型 定义:消息过滤规则的类型。订阅关系中设置消息过滤规则后,...

生产者(Producer)

消息按照到达 云消息队列 RocketMQ 版 服务端的顺序存储到主题的指定队列中。消费者按照指定的订阅关系从 云消息队列 RocketMQ 版 服务端中获取消息并消费。内部属性 客户端ID 定义:生产者客户端的标识,用于区分不同的生产者。集群内全局...

收发顺序消息

参考接口MessageQueueSelector,通过设置的自定义参数arg,计算发送到指定的路由队列中,此处的arg便是分区ID。ExampleSelectMessageQueueByHash*pSelector=new ExampleSelectMessageQueueByHash();for(int i=0;i;i){/发送消息时请设置您在...

通过原始日志快速分析和定位问题

本文介绍基于 云消息队列 ...822e-72dfad2a*or ResourceName:deliveryTag=1)其中 PushMessage 日志表示服务端推送消息到客户端,客户端在收到消息后调用 BasicReject(requeue=false),对应 SendDlqMessage 日志表示消息被路由到死信队列中

使用Canal和RocketMQ实现数据库变更订阅处理

本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版,实现MySQL数据库Binlog数据的变更处理。背景信息 CDC(Change Data Capture)是一种监测并捕获数据库变更的典型技术方案,常应用于异构数据源之间的数据同步。Canal...

使用Canal和RocketMQ实现数据库变更订阅处理

本文以MySQL数据库为例介绍如何使用Canal接入 云消息队列 RocketMQ 版,实现MySQL数据库Binlog数据的变更处理。背景信息 CDC(Change Data Capture)是一种监测并捕获数据库变更的典型技术方案,常应用于异构数据源之间的数据同步。Canal...

示例代码

参考接口MessageQueueSelector,通过设置的自定义参数arg,计算发送到指定的路由队列中,此处的arg便是分区ID。ExampleSelectMessageQueueByHash*pSelector=new ExampleSelectMessageQueueByHash();for(int i=0;i;i){/设置为您在消息队列...

SDK FAQ

本文记录通过SDK收发消息时常见的问题。开源客户端是否可以直接访问云上服务?云消息队列 RabbitMQ 版 完全兼容开源...您可以使用Java客户端库 queuePurge 方法删除某个队列的所有消息。示例代码如下:channel.queuePurge("queue-name");

顺序消息

消息存储 如上图所示,顺序消息的Topic中,每个逻辑队列对应一个物理队列,当消息按照顺序发送到Topic中的逻辑队列时,每个分区的消息将按照同样的顺序存储到对应的物理队列中。消息消费 云消息队列 RocketMQ 版 按照存储的顺序将消息投递...

生产者负载均衡

在极端场景下,可能会出现大部分消息集中在少数队列中的情况,建议设计消息组时尽量将消息离散开,不要集中在少量消息组中。使用示例 MessageGroupHash模式不需要额外设置,对于顺序消息类型默认启用。顺序消息发送,默认采用...

获取MQTT客户端在线状态

异步上下线通知 如上文所述,使用异步上下线通知的方式,上下线事件会映射到后端存储消息队列中。下文以 云消息队列 RocketMQ 版 作为后端存储消息队列的情况为例说明。操作步骤 创建上下线事件对应的Topic。您需关注哪些Group ID分组的...

MQTT客户端上下线事件数据流出

设置RocketMQ客户端的Group ID,注意此处的groupId和MQTT实例中的groupId是两个概念,请按照各自产品的说明申请填写。properties.setProperty(PropertyKeyConst.GROUP_ID,"GID_XXXX");账号AccessKey ID,从控制台获取。properties.put...

如何处理消息堆积

客户端堆栈信息可以通过以下方式获取:登录 云消息队列 RocketMQ 版 控制台 查看消费者状态,在客户端连接信息查看 Java客户端堆栈信息。具体操作,请参见 查看消费者状态。使用Jstack工具打印堆栈信息。请参见 查看消费者状态 获取消息...

MQTT与RocketMQ的消息结构映射

如上图所示,在 云消息队列 MQTT 版 中Topic是多级结构,而 云消息队列 RocketMQ 版 的Topic仅有一级,因此,云消息队列 MQTT 版 中的一级Topic映射到 云消息队列 RocketMQ 版 的Topic,而子级Topic,包括二级、三级、n级Topic则映射到 云...

消费进度管理

云消息队列 RocketMQ 版 定义消费位点的初始值为消费者首次获取消息时,该时刻队列中的最大消息位点。相当于消费者将从队列中最新的消息开始消费。重置消费位点 若消费者分组的初始消费位点或当前消费位点不符合您的业务预期,您可以通过...

基本概念

消息位点(MessageQueueOffset)消息是按到达 云消息队列 RocketMQ 版 服务端的先后顺序存储在指定主题的多个队列中,每条消息在队列中都有一个唯一的Long类型坐标,这个坐标被定义为消息位点。更多信息,请参见 消费进度管理。消费位点...

快速使用MQTT的Java SDK收发消息(终端和终端消息收发...

本文介绍如何快速使用 云消息队列 MQTT 版 的Java SDK实现MQTT终端与终端消息的收发。前提条件 创建资源 获取AccessKey 安装 IDE。您可以使用IntelliJ IDEA或者Eclipse,本文以IntelliJ IDEA为例。下载安装 JDK。背景信息 云消息队列 MQTT ...

顺序消息

顺序消息为 云消息队列 RocketMQ 版 中的高级特性消息,本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 在有序事件处理、撮合交易、数据实时增量同步等场景下,异构系统间需要维持强一致的状态同步,...

消费者分类

如下图所示,SDK内置了一个长轮询线程,先将消息异步拉取到SDK内置的缓存队列中,再分别提交到消费线程中,触发监听器执行本地消费逻辑。可靠性重试 PushConsumer消费者类型中,客户端SDK和消费逻辑的唯一边界是消费监听器接口。客户端SDK...

云消息队列 RabbitMQ 版

本文介绍如何在 云消息队列 RocketMQ 版 控制台创建流入任务,实现将 云消息队列 RabbitMQ 版 中的数据快速导入至 云消息队列 RocketMQ 版。前提条件 您已购买 云消息队列 RocketMQ 版 实例,且实例处于 服务中 状态。具体步骤,请参见 ...

产品架构

本文介绍 云消息队列 RocketMQ 版 的系统部署架构,方便您更好地理解 云消息队列 RocketMQ 版 的高可用性。云消息队列 RocketMQ 版 在任何一个环境都是可扩展的,生产者...更多信息 云消息队列 RocketMQ 版 中的概念详情,请参见 基本概念。

MQTT和RocketMQ进行数据互通(跨产品数据流入)

本文以公网环境中的Java SDK为例说明如何将 云消息队列 RocketMQ 版 数据流入至 云消息队列 MQTT 版。重要 云消息队列 RocketMQ 版 和 云消息队列 MQTT 版 的Topic不能跨地域使用,因此,本文中所有资源都应在公网地域创建。网络访问 云...

如何快速使用消息队列RabbitMQ版的Java SDK收发消息

本文提供使用 云消息队列 RabbitMQ 版 的Java SDK收发消息的快速入门视频。

如何快速使用微消息队列MQTT版的Java SDK收发消息?

本文提供使用 微消息队列MQTT版 的Java SDK收发消息的快速入门视频。

MQTT和RocketMQ进行数据互通(跨产品数据流出)

本文以公网环境中的Java SDK为例说明如何将 云消息队列 MQTT 版 的数据导出至 云消息队列 RocketMQ 版。此场景下可使用多语言的第三方开源SDK来实现消息收发。更多信息,请参见 SDK下载。重要 云消息队列 RocketMQ 版 和 云消息队列 MQTT ...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云消息队列 Kafka 版 云消息队列 RocketMQ 版 全局事务服务 (文档停止维护) 弹性公网IP 短信服务 人工智能平台 PAI
新人特惠 爆款特惠 最新活动 免费试用