网络异常自动恢复

设置Vhost名称,请确保已在消息队列AMQP版控制台上创建。factory.setVirtualHost("${VhostName}");默认端口,非加密端口5672,加密端口5671。factory.setPort(5672);基于网络环境设置合理的超时时间。factory.setConnectionTimeout(30*1000...

资源类型索引

消息队列RabbitMQ ALIYUN:AMQP:Binding:为Exchange绑定目标对象Queue或Exchange ALIYUN:AMQP:Exchange:创建Exchange ALIYUN:AMQP:Instance:创建一个消息队列RabbitMQ实例 ALIYUN:AMQP:Queue:创建Queue ALIYUN:AMQP:VirtualHost:创建...

SDK列表

消息队列 RabbitMQ SDK(RAM角色跨账号授权场景)如果您是RAM STS角色授权的使用场景,需要通过 云消息队列 RabbitMQ SDK收发消息,该SDK只比开源SDK多一个加签依赖。云消息队列 RabbitMQ 支持的多语言或框架SDK如 云消息队列 ...

开源SDK接入(主子账号授权)

阿里云的 云消息队列 RabbitMQ 支持AMQP 0-9-1协议,兼容开源的RabbitMQ客户端,您可以使用开源的客户端SDK接入 云消息队列 RabbitMQ 服务端进行消息收发。前提条件 创建实例 创建Vhost 背景信息 借助访问控制RAM的RAM用户,您可以...

消息队列 RocketMQ

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

消息队列RabbitMQ版

本文介绍如何在 云消息队列 RocketMQ 控制台创建流出目标为 云消息队列 RabbitMQ 的消息流出任务。前提条件 您已购买 云消息队列 RocketMQ 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已购买并部署 云消息队列 ...

SDK概述

消息队列 RabbitMQ 支持通过AMQP 0-9-1协议与JMS客户端收发消息。AMQP 0-9-1协议支持多语言SDK,而JMS仅支持Java SDK。RabbitMQ Client SDK列表 开源SDK接入指南(主账号与RAM账号场景)开源SDK接入指南(RAM角色跨账号授权场景)AMQP...

消息队列RabbitMQ版

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

消息队列 Kafka

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

消息队列 RabbitMQ

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

创建RabbitMQ Sink Connector

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

函数计算

本文介绍如何在 云消息队列 RabbitMQ 控制台创建消息流出任务,将 云消息队列 RabbitMQ 的数据导出至函数计算。前提条件 您已购买 云消息队列 RabbitMQ 实例,且实例处于 服务中 状态。具体步骤,请参见 创建资源。您已开通函数...

消息队列 RabbitMQ

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

消息队列 MQTT

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

消息队列 Kafka

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

消息收发流程变更

消息队列 MQTT V2.x.x版本强依赖 云消息队列 RocketMQ 作为消息存储,因此 云消息队列 MQTT 消息和 云消息队列 RocketMQ 天然打通,创建了Topic后即可天然使用 云消息队列 RocketMQ 和 云消息队列 MQTT 的SDK相互通信...

使用AMQProxy解决PHP等客户端Connection复用问题

AMQP_URL 云消息队列 RabbitMQ 实例的URL。格式为 {amqp|amqps}:/{endpoint}。amqpAMQP协议。不使用SSL连接时使用。amqps:AMQP/SSL协议。使用SSL连接时使用。endpoint:云消息队列 RabbitMQ 实例的接入点。您可以在 云消息队列 ...

资源使用变更

消息队列 MQTT 从V2.x.x升级至V3.x.x实现了自身数据存储的能力,同时还去除了对 云消息队列 RocketMQ 的消息依赖,因此,云消息队列 MQTT 的实例和Topic使用有变更。资源 V2.x.x使用说明 V3.x.x使用说明 云消息队列 MQTT ...

消息服务MNS

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

MQTT与RocketMQ的消息结构映射

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

默认配置映射关系

映射关系如下:消息服务MNS 默认入参 目标端类型 模式 值 云消息队列 Kafka 部分事件$.data.value 云消息队列 RocketMQ 部分事件$.data.body 云消息队列 RabbitMQ 部分事件$.data.body 云消息队列 MQTT 部分事件$.data.body ...

消息队列 RocketMQ

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

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

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

默认配置映射关系

映射关系如下:消息服务MNS 默认入参 目标端类型 模式 值 云消息队列 Kafka 部分事件$.data.value 云消息队列 RocketMQ 部分事件$.data.body 云消息队列 RabbitMQ 部分事件$.data.body 云消息队列 MQTT 部分事件$.data.body ...

默认配置映射关系

映射关系如下:消息服务MNS 默认入参 目标端类型 模式 值 云消息队列 Kafka 部分事件$.data.value 云消息队列 RocketMQ 部分事件$.data.body 云消息队列 RabbitMQ 部分事件$.data.body 云消息队列 MQTT 部分事件$.data.body ...

计费常见问题

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

视频专区

本文为您介绍 云消息队列 RocketMQ 的操作视频。云消息队列 RocketMQ 5.x系列 快速使用 云消息队列 RocketMQ 5.x系列的Java SDK收发消息 云消息队列 RocketMQ 4.x系列 快速使用云消息队列 RocketMQ 4.x系列的Java SDK收发消息

产品架构

消息队列 Kafka 系统架构 如 云消息队列 Kafka 的系统架构 所示,一个 云消息队列 Kafka 集群包括Producer、Kafka Broker、Group、ZooKeeper。图 1.云消息队列 Kafka 的系统架构 Producer 通过push模式向 云消息队列 Kafka ...

Topic使用变更

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

默认配置映射关系

映射关系如下:消息服务MNS 默认入参 源端类型 模式 值 云消息队列 Kafka 部分事件$.data.value 云消息队列 RocketMQ 部分事件$.data.body 云消息队列 RabbitMQ 部分事件$.data.body 云消息队列 MQTT 部分事件$.data.body 数据...

开源对比

消息队列 RabbitMQ 是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品,能够兼容开源RabbitMQ客户端,与开源RabbitMQ相比,能够解决各种稳定性痛点(例如消息堆积、脑裂等问题),同时具备高并发、分布式、灵活扩缩容等...

产品概述

本文介绍 云消息队列 Kafka 的产品动态、产品简介及产品计费。云消息队列 Kafka 动态与公告 产品简介 产品计费 云消息队列 Confluent 什么是云消息队列 Confluent ?产品计费

跨云产品数据流入

您可通过配置 云消息队列 MQTT 的数据流入规则来自定义数据从其他阿里云产品流入到 云消息队列 MQTT 。本文介绍跨产品数据流入的原理、应用场景、使用限制以及 云消息队列 MQTT 与其他阿里云产品的资源映射关系。基本原理 如需将...

SourceRabbitMQParameters

名称 类型 描述 示例值 object EventBridge 消息队列 RabbitMQ 的自定义事件源参数 InstanceId string 消息队列 RabbitMQ 的实例的 ID。amqp-cn-nif22u74*QueueName string 消息队列 RabbitMQ 实例的 Queue 的名称。demo RegionId ...

跨云产品的数据流出

您可通过配置 云消息队列 MQTT 的数据流出规则来自定义数据从 云消息队列 MQTT 流出至其他阿里云产品。本文介绍数据流出的原理、应用场景、使用限制以及 云消息队列 MQTT 与其他阿里云产品的资源映射关系。基本原理 如需将 云消息...

步骤三:调用SDK收发消息

本文以Java SDK为例,说明如何将开源SDK客户端接入 云消息队列 RabbitMQ 服务端,并完成消息收发。前提条件 创建资源 安装IDEA 您可以使用IntelliJ IDEA或者Eclipse,本文以IntelliJ IDEA Ultimate为例。安装JDK 安装Maven 安装Java依赖...

消息队列 Kafka 服务等级协议

消息队列 Kafka 规定了阿里云向客户提供的阿里云 云消息队列 Kafka 的服务可用性等级指标及赔偿方案。如需查看 云消息队列 Kafka 的服务可用性等级指标及赔偿方案,请参见 云消息队列 Kafka 服务等级协议。

开发参考

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

什么是云消息队列 Kafka

消息队列 Kafka 阿里云提供的分布式、高吞吐、可扩展的消息队列服务。云消息队列 Kafka 广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域,已成为大数据生态中不可或缺的部分。产品优势 云消息队列 ...

快速入门

如果您是首次使用 云消息队列 RocketMQ ,您可以参考快速入门文档,了解如何购买实例并接入 云消息队列 RocketMQ 服务端完成基本的消息收发流程。使用流程 快速使用 云消息队列 RocketMQ 收发消息的流程如下图所示。详细操作,请...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云消息队列 RocketMQ 版 云消息队列 Kafka 版 全局事务服务 (文档停止维护) 弹性公网IP 短信服务 人工智能平台 PAI
新人特惠 爆款特惠 最新活动 免费试用