网络异常自动恢复

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

MQTT与RocketMQ的消息结构映射

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

SDK列表

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

数据流入规则管理

如需将其他阿里云产品的数据导入 云消息队列 MQTT ,您需创建数据流入规则。该规则用于从您配置的阿里云产品中读取数据并将数据通过MQTT协议推送到MQTT客户端,从而实现直接调用阿里云产品的API发送数据到MQTT客户端。流程说明 规则限制 ...

数据流出规则管理

如需将 云消息队列 MQTT 的数据导出至其他阿里云产品,您需创建数据流出规则。该规则用于将MQTT客户端发送的消息导出到您配置的其他阿里云产品中,从而实现直接调用云产品的API读取MQTT客户端发送的消息。流程说明 规则限制 限制项 限制...

上下线通知规则管理

数据流入:用于将其他阿里云产品的数据导入至 云消息队列 MQTT 详细信息,请参见 跨云产品数据流入。上下线通知:用于将获取的 云消息队列 MQTT 版 客户端上下线事件数据导出至其他阿里云产品。详细信息,请参见 MQTT客户端上下线事件...

MQTT快速入门

创建完 云消息队列 MQTT 实例后,您还需要创建用于存储Topic和消息的实例(目前仅支持 云消息队列 RocketMQ 的实例),然后将创建的 云消息队列 RocketMQ 的实例与 云消息队列 MQTT 实例进行一对一的绑定。绑定关系有以下限制...

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

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

SDK概述

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

创建RabbitMQ Sink Connector

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

可观测性体系概述

指标 云消息队列 RocketMQ 中定义了详细的Metrics指标,这些指标覆盖生产者、消费者、服务端及消息收发关键接口和流程的统计数据,并支持从实例、Topic和Group等多个维度进行聚合展示,帮助您实时监控消息业务或 云消息队列 RocketMQ ...

如何通过代理访问云消息队列 Kafka 实例

概述 暂不支持通过代理访问云消息队列 Kafka 实例,具体请查看 详细信息。详细信息 云消息队列 Kafka 的客户端访问服务端的原理如下。通过 bootstrap.servers 随机访问服务器获取Metadata。通过Metadata里的IP地址进行后续的消息收发。...

查看接入点

如需使用SDK接入 云消息队列 Kafka 收发消息,您需要根据实例的网络环境类型来配置接入点。本文介绍如何在 云消息队列 Kafka 控制台查看接入点。背景信息 云消息队列 Kafka 提供以下类型的接入点:默认接入点:适用于在VPC环境...

消息收发流程变更

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

资源使用变更

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

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

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

计费常见问题

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

查看接入点

如需使用客户端连接 云消息队列 Kafka 收发消息,您需要根据客户端的网络环境类型及传输的安全需要来配置接入点。默认接入点适用于在保密性较高的VPC环境收发消息;SASL接入点适用于无需对传输链路加密但需对消息收发鉴权;同时需要链路...

默认配置映射关系

映射关系如下:消息服务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 ...

默认配置映射关系

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

创建前提

资源创建 购买一个 云消息队列 Kafka 实例,详细步骤,请参见 购买Kafka实例。创建Topic资源。详细步骤,请参见 创建资源。(可选)创建Group资源。您可以提前创建Group,也可以在创建Connector时创建Group。详细步骤,请参见 创建资源...

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

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

视频专区

本文为您介绍 云消息队列 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 ...

默认配置映射关系

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

跨云产品数据流入

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

产品概述

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

跨云产品的数据流出

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

消息队列 Kafka 服务等级协议

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

开发参考

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

什么是云消息队列 Kafka

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

步骤三:调用SDK收发消息

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

使用限制

消息队列 RocketMQ 对某些具体指标进行了约束和规范,您在使用 云消息队列 RocketMQ 时不要超过对应的限制值,避免程序出现异常。云消息队列 RocketMQ 5.x系列 5.x系列使用限制 云消息队列 RocketMQ 4.x系列 4.x系列使用限制

快速入门

如果您首次使用 云消息队列 Kafka ,您可以参考快速入门文档。快速入门文档 云消息队列 Kafka 快速入门 云消息队列 Confluent 快速入门

快速入门概述

本文为您介绍如何快速使用 云消息队列 RocketMQ 实现消息收发。使用流程 快速使用 云消息队列 RocketMQ 收发消息的流程如下图所示。使用说明 权限说明 若您的账号为RAM用户,则必须先为该RAM用户进行授权,才能访问 云消息队列 ...

创建RabbitMQ Source Connector

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

新功能发布记录

本文介绍 云消息队列 RabbitMQ 的产品功能动态及对应的文档。2024-03-14 功能名称 功能描述 功能类型 相关文档 新增开服地域 马来西亚(吉隆坡)和美国(硅谷)地域新增支持创建Serverless实例和企业实例。新增 开服地域 预付费实例...

开源对比

本文从稳定性、内核能力、治理能力以及使用习惯等方面,对比阿里云 云消息队列 Kafka 与开源Apache Kafka。稳定性 项目 云消息队列 Kafka Apache Kafka 磁盘水位 磁盘写满删除旧数据。磁盘写满直接宕机。线程池隔离 读冷数据仍可以...

产品计费

本文为您介绍 云消息队列 RocketMQ 的实例类型、计费方式、计费组成等信息。云消息队列 RocketMQ 5.x系列 5.x系列计费概述 云消息队列 RocketMQ 4.x系列 4.x系列计费概述
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云消息队列 Kafka 版 云消息队列 RocketMQ 版 全局事务服务 (文档停止维护) 弹性公网IP 短信服务 人工智能平台 PAI
新人特惠 爆款特惠 最新活动 免费试用