数据库队列-数据库队列文档介绍内容-阿里云

默认配置映射关系

消息服务MNS 默认入参目标端类型模式值云消息队列 Kafka 版部分事件$.data.value 云消息队列 RocketMQ 版部分事件$.data.body 云消息队列 RabbitMQ 版部分事件$.data.body 云消息队列 MQTT 版部分事件$.data.body 数据传输服务DTS ...

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

客户端状态数据，实际生产环境中建议使用数据库或者Redis等外部持久化存储来保存该信息，避免应用重启丢失状态，本示例以单机内存版实现为例。MqttClientStatusStore mqttClientStatusStore=new MemoryHashMapStoreImpl();Consumer ...

计费常见问题

若您使用云消息队列 MQTT 版的数据流入、数据流出规则和云消息队列 RocketMQ 版进行通信，云消息队列 RocketMQ 版会根据调用的云消息队列 RocketMQ 版的消息收发API或Topic资源等进行计费。客户端上线下事件流出到消息队列RocketMQ...

定时/延时消息

传统基于数据库的定时调度方案在分布式场景下，性能不高，实现复杂。基于云消息队列 RocketMQ 版的定时消息可以封装出多种类型的定时触发器。典型场景二：任务超时处理以电商交易场景为例，订单下单后暂未支付，此时不可以直接关闭订单...

基本概念

本文介绍云消息队列 RocketMQ 版的基本概念，以便您更好地理解和使用云消息队列 RocketMQ 版。主题（Topic）云消息队列 RocketMQ 版中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。主题通过TopicName来做唯一标识和区分。...

MQTT与RocketMQ的消息结构映射

云消息队列 MQTT 版是一款面向移动端的网关产品，可通过数据互通规则实现与其他阿里云产品，例如云消息队列 RocketMQ 版的交互。规则的详细信息，请参见规则管理。如果单独使用云消息队列 MQTT 版，则无需关注本文提供的映射关系，...

重试和死信

死信队列死信息队列将以任务维度为依据进行限制，当发生无法处理或者超过重试次数的情况时，会将失败的原始数据原封不动发送至消息队列，该选项默认为不启用状态。说明当前仅支持将死信发送至云消息队列 RocketMQ 版和消息服务MNS。

死信队列

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

直播互动解决方案

背景信息在直播互动的场景下，您需创建相应的数据互通规则实现云消息队列 MQTT 版与云消息队列 RocketMQ 版的数据互通，包含数据流入规则、数据流出规则以及客户端上下线通知规则。使用云消息队列 MQTT 版的客户端收发消息时，...

新功能发布记录

JMS应用可以通过云消息队列 RabbitMQ 版 JMS库接入云消息队列 RabbitMQ 版。新增 JMS概述 AMQP和JMS差异 JMS接口兼容性 JMS P2P（主账号与RAM账号场景）JMS Pub/Sub（主账号与RAM账号）2020-06-30 功能名称功能描述功能类型相关文档 ...

重试和死信

死信队列死信消息队列将以任务维度为依据进行限制，当发生无法处理或者超过重试次数的情况时，会将失败的原始数据原封不动发送至消息队列，该选项默认为不启用状态。说明当前仅支持将死信发送至云消息队列 RocketMQ 版和消息服务MNS。

重试和死信

死信队列死信息队列将以任务维度为依据进行限制，当发生无法处理或者超过重试次数的情况时，会将失败的原始数据原封不动发送至消息队列，该选项默认为不启用状态。说明当前仅支持将死信发送至云消息队列 RocketMQ 版和消息服务MNS。

开源对比

稳定性项目云消息队列 Kafka 版 Apache Kafka 磁盘水位磁盘写满删除旧数据。磁盘写满直接宕机。线程池隔离读冷数据仍可以保证写入基本正常。读冷数据直接导致线程堵塞，数据写入大量失败。分区规模万级分区仍然可以保证稳定写入。千级...

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

客户端状态数据，实际生产环境中建议使用数据库或者Redis等外部持久化存储来保存该信息，避免应用重启丢失状态，本Demo以单机内存版实现做演示。MqttClientStatusStore mqttClientStatusStore=new MemoryHashMapStoreImpl();Consumer ...

MQTT快速入门

注意事项云消息队列 MQTT 版需搭配后端消息存储队列一起使用，具体说明如下：云消息队列 MQTT 版实例是一个无状态网关类型实例，用来完成IoT移动场景下的客户端连接维持和消息转发，本身并不提供消息数据持久化功能，具体的消息存储和...

默认配置映射关系

消息服务MNS 默认入参源端类型模式值云消息队列 Kafka 版部分事件$.data.value 云消息队列 RocketMQ 版部分事件$.data.body 云消息队列 RabbitMQ 版部分事件$.data.body 云消息队列 MQTT 版部分事件$.data.body 数据传输服务DTS ...

创建RabbitMQ Source Connector

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

网络访问与安全设置

本文介绍如何进行云消息队列 Confluent 版集群的网络访问与安全设置。网络访问类型云消息队列 Confluent 版集群提供阿里云VPC访问和公网访问方式。阿里云VPC访问 VPC访问是指您在云消息队列 Confluent 版集群所在网络VPC内或者其它...

创建RabbitMQ Sink Connector

本文介绍如何在云消息队列 Kafka 版控制台创建消息流出任务，将云消息队列 Kafka 版的数据导出至云消息队列 RabbitMQ 版。前提条件您已购买并部署云消息队列 Kafka 版实例，且实例处于服务中状态。具体步骤，请参见步骤二：购买和...

Topic使用变更

云消息队列 MQTT 版从V2.x.x升级至V3.x.x后，实现了独立存储，Topic资源不再依赖于云消息队列 RocketMQ 版，因此两个产品的Topic将完全彼此独立。本文介绍两个版本中Topic资源控制台操作的差异并提供相应控制台截图进行对比。变更说明 ...

计费FAQ

本文汇总了云消息队列 RabbitMQ 版计费的常见问题。向10个Queue发送同一条消息，为什么收10次API调用费？将1条消息发送给10个Queue，实际上是10次API调用。为什么删除的Vhost、Exchange、Queue会被自动重建并重新开始计费？虽然删除了...

产品架构

本文介绍云消息队列 Kafka 版的系统架构和发布/订阅模型。云消息队列 Kafka 版系统架构如云消息队列 Kafka 版的系统架构所示，一个云消息队列 Kafka 版集群包括Producer、Kafka Broker、Group、ZooKeeper。图 1.云消息队列 Kafka ...

客户端首次接入云消息队列 Kafka 版时出现异常的排查...

关于客户端Demo，请参见云消息队列 Kafka 版Demo库。说明云消息队列 Kafka 版对客户端版本有限制。例如，如果服务端版本为0.10.2.2，建议客户端版本也为0.10.2.2。具体以服务端版本为准。配置问题：默认接入点配置错误、RAM用户未授权等...

实例使用变更

云消息队列 MQTT 版从V2.x.x升级至V3.x.x后，不再需要与云消息队列 RocketMQ 版的实例进行绑定。本文介绍两个版本之间的控制台实例相关操作的具体差异，并提供控制台截图进行对比。变更说明由于V3.x.x版本的云消息队列 MQTT 版实现了...

MQTT和RocketMQ进行数据互通（跨产品数据流入）

如果您的云端应用需要使用云消息队列 RocketMQ 版产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将云消息队列 MQTT 版和云消息队列 RocketMQ 版数据进行流转。本文介绍如何将云消息队列 RocketMQ...

实例管理

本文介绍如何对云消息队列 MQTT 版的实例进行续费、变配及运维管理。实例续费云消息队列 MQTT 版实例到期之前7天会按照账号给对应的手机发送通知，请及时续费。如果到期未续费，实例将被保留7天，之后自动释放。登录云消息队列 MQTT ...

消费者负载均衡

队列粒度的负载均衡，基于队列数量、消费者数量等运行数据进行统一的算法分配，将每个队列绑定到特定的消费者，然后每个消费者按照取消息>提交消费位点>持久化消费位点的消费语义处理消息，取消息过程不提交消费状态，因此，为了避免消息被...

基本概念

具体信息，请参见云消息队列 Kafka 版Demo库。普通消息默认情况下，保证相同Key的消息分布在同一个分区中，且分区内消息按照发送顺序存储。集群重启或者宕机时，会导致极少量乱序。更多信息，请参见存储引擎对比。分区顺序消息默认情况...

计费FAQ

本文汇总了云消息队列 RabbitMQ 版计费的常见问题。向10个Queue发送同一条消息，为什么收10次API调用费？将1条消息发送给10个Queue，实际上是10次API调用。为什么删除的Vhost、Exchange、Queue会被自动重建并重新开始计费？虽然删除了...

消费进度管理

云消息队列 RocketMQ 版通过消费位点管理消费进度，本文为您介绍云消息队列 RocketMQ 版的消费进度管理机制。背景信息云消息队列 RocketMQ 版的生产者和消费者在进行消息收发时，必然会涉及以下场景，消息先生产后订阅或先订阅后生产...

查看迁移进度

操作步骤重要云消息队列 Kafka 版不支持数据迁移和位点迁移信息上报，即如果您已经开始数据迁移或位点迁移，您目前无法在云消息队列 Kafka 版控制台查看迁移进度。登录云消息队列 Kafka 版控制台。在概览页面的资源分布区域，...

创建Kafka Sink Connector

本文介绍如何在云消息队列 Kafka 版控制台创建消息流出任务，将指定云消息队列 Kafka 版实例中的数据导出至其他的云消息队列 Kafka 版。前提条件您已购买并部署云消息队列 Kafka 版实例，且实例处于服务中状态。具体步骤，请参见...

音视频通信解决方案（MQTT）

数据交互数据流所展示的是基于云消息队列 MQTT 版和音视频通信RTC实现一次音视频通话会议的调用流程，其中灰色部分为您的自建开发程序或服务，蓝色部分是云消息队列 MQTT 版、云消息队列 RocketMQ 版以及音视频通信RTC所提供的服务。...

创建RocketMQ Source Connector

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

什么是云消息队列 MQTT 版

云消息队列 MQTT 版是阿里云推出的一款面向移动互联网以及物联网领域的轻量级消息中间件。如果说传统的消息队列中间件一般应用于微服务之间，那么适用于物联网的云消息队列 MQTT 版则实现了端与云之间的消息传递和真正意义上的万物互联...

什么是云消息队列 Confluent 版？

高SLA保障，数据持久化：专业团队保障更高可用性，消息持久化落盘到消息队列，数据可靠性高，服务可用性高。高吞吐能力：在海量消息堆积的情况下，始终能保持云消息队列 Confluent 版集群的高吞吐能力。全自动巡检运维体系保障，服务可用...

收发延时消息

发送延时消息具体的示例代码，请以云消息队列 RocketMQ 版代码库为准。发送延时消息的示例代码如下：import com.aliyun.openservices.ons.api.Message;import com.aliyun.openservices.ons.api.ONSFactory;import ...

迁移数据上云

本文介绍如何使用MirrorMaker将自建Kafka集群的数据迁移到云消息队列 Kafka 版集群。前提条件您已完成以下操作：下载迁移工具MirrorMaker 迁移Topic上云背景信息 Kafka的镜像特性可实现Kafka集群的数据备份。实现这一特性的工具就是...

新功能发布记录

新增使用限制计费规则欠费说明 2022-05-20 功能名称功能描述功能类型相关文档迁移路由支持自建实例与云消息队列 Kafka 版实例之间或者云消息队列 Kafka 版实例之间的数据同步。新增迁移路由 2022-04-18 功能名称功能描述 ...

开发参考

本文介绍云消息队列 RocketMQ 版的SDK和API的支持情况，供您进行对应的开发操作。云消息队列 RocketMQ 版消息收发需要通过调用SDK完成，云消息队列 RocketMQ 版的SDK支持Java、C++、.NET、Go等多语言开发。SDK参考提供了各语言的SDK的...

数据库 队列

新品推荐

数据库队列