安装和使用Confluent CLI

本文介绍如何安装和使用 云消息队列 Confluent 版 的命令行界面(CLI)。安装Confluent CLI 下载 Confluent CLI 并安装最新的二进制文件。Darwin/x64 Windows/x64 Linux/x64 Linux/386 Checksums(operating system agnostic)将PATH环境设置...

使用任务队列ack-kube-queue

本文介绍如何安装及使用任务队列ack-kube-queue。前提条件 已开通云原生AI套件。使用限制 仅支持ACK Pro托管版集群,且集群版本为1.18.aliyun.1及以上。安装ack-kube-queue 分为以下两个场景讲解如何安装ack-kube-queue。场景一:未部署云...

安装CPP动态库

使用C++ SDK接入阿里云 云消息队列 RocketMQ 版 收发消息前,您需按本文提供的操作步骤安装CPP动态库。重要 推荐您使用最新的RocketMQ 5.x系列SDK,5.x系列SDK作为主力研发版本,和 云消息队列 RocketMQ 版 5.x服务端完全兼容,提供了更...

安装CPP动态库

在使用社区版C++ SDK接入阿里云 云消息队列 RocketMQ 版 来收发消息前,您需按本文提供的操作步骤安装CPP动态库。前提条件 在开始做准备工作前,请确保您的操作系统满足以下条件:Linux:CentOS 6.8、CentOS 7.2、RHEL 6.x、RHEL 7.x ...

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

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

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

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

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

MQTT客户端的上下线事件将会触发MQTT服务端生成一条通知消息,云消息队列 MQTT 版 支持将该条消息数据导出至其他阿里云产品,并使用MQTT的Java SDK实现MQTT客户端与后端应用收发消息。本文以当前仅支持的 云消息队列 RocketMQ 版 数据互通...

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

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

Demo工程

本文以社区版Apache RocketMQ Client为例,提供操作示例帮助您从零开始搭建阿里云 云消息队列 RocketMQ 版 收发消息的测试工程。Demo工程包含普通消息、顺序消息、事务消息的测试代码。前提条件 安装IDE。您可以使用IntelliJ IDEA或者...

快速使用MQTT.fx模拟SDK收发消息

前提条件 下载并安装 MQTT.fx。背景信息 云消息队列 MQTT 版 最简单的使用场景即MQTT客户端消息的自发自收。如下图所示,您可以使用MQTT.fx作为MQTT客户端,在MQTT.fx客户端配置相关参数后接入 云消息队列 MQTT 版 实现消息的发送和接收。...

使用Spring Cloud框架收发消息

本文介绍如何使用Spring Cloud框架接入 云消息队列 Kafka 版 并收发消息。前提条件 安装1.8或以上版本JDK。安装2.5或以上版本Maven。下载 kafka-spring-stream-demo,并将其上传在准备好的Linux操作系统。确保您的 云消息队列 Kafka 版 ...

Spring集成

环境准备 安装1.8或以上版本JDK 安装2.5或以上版本Maven 安装IDEA 步骤一:下载Demo工程 云消息队列 RocketMQ 版 提供SpringBoot和Spring两种方式的Demo,本文以SpringBoot的工程为例为您介绍如何使用SDK收发消息,Spring方式的Demo工程...

PHP SDK收发消息

环境准备 安装GCC 安装PHP 安装PECL 安装C++依赖库 执行以下命令切换到yum源配置目录/etc/yum.repos.d/。cd/etc/yum.repos.d/创建yum源配置文件 confluent.repo。[Confluent.dist]name=Confluent repository(dist)baseurl=...

Python SDK收发消息

本文介绍如何使用Python SDK通过接入点接入 云消息队列 Kafka 版 并收发消息。环境准备 安装Python 说明 Python版本为2.7或3.X。安装pip 添加Python依赖库 执行以下命令安装依赖库。pip install confluent-kafka=1.9.2 重要 建议您安装...

消息收发功能

智能设备管理:例如,通过安装在手机上的App向接入到 云消息队列 MQTT 版 服务端的共享充电宝下发指令,充电宝收到指令消息后自动弹出。终端和云端消息收发 该场景下消息的发送端和消费端分别为移动终端设备和部署在阿里云上的业务应用。...

Node.js SDK收发消息

本文介绍如何使用Node.js SDK通过接入点接入 云消息队列 Kafka 版 并收发消息。环境配置 安装GCC 安装Node.js 重要 Node.js版本必须大于等于4.0.0。安装OpenSSL 安装C++依赖库 执行以下命令切换到yum源配置目录/etc/yum.repos.d/。cd/etc/...

队列(MessageQueue)

队列的主要作用如下:存储顺序性 队列天然具备顺序性,即消息按照进入队列的顺序写入存储,同一队列间的消息天然存在顺序关系,队列头部为最早写入的消息,队列尾部为最新写入的消息。消息在队列中的位置和消息之间的顺序通过位点(Offset...

排他队列

如果您想创建一个只有自己可见的队列,不允许其他用户访问,您可以使用 云消息队列 RabbitMQ 版 的排他性队列特性,将指定的队列声明为排他性。什么是排他队列 排他性队列的特点如下:排他队列只对首次声明它的连接(Connection)可见,...

Ruby SDK收发消息

本文介绍如何使用Ruby SDK通过接入点接入 云消息队列 Kafka 版 并收发消息。环境准备 您已安装Ruby。更多信息,请参见 安装Ruby。安装Ruby依赖库 执行以下命令安装Ruby依赖库。gem install ruby-kafka-v 0.6.8 准备配置 可选:下载SSL根...

消息收发流程变更

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

C# SDK收发消息

本文介绍如何使用C#SDK通过接入点接入 云消息队列 Kafka 版 并收发消息。环境配置 您已安装.NET。更多信息,请参见 安装.NET 。安装C#依赖库 执行以下命令安装C#依赖库。dotnet add package-v 1.5.2 Confluent.Kafka 准备配置 可选:下载...

资源使用变更

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

MQTT与RocketMQ的消息结构映射

本文针对使用 云消息队列 RocketMQ 版 SDK与 云消息队列 MQTT 版 交互的场景,提供交互中所涉及的消息结构和属性字段的映射关系,方便您更好的理解和组合使用这两个产品。云消息队列 MQTT 版 是一款面向移动端的网关产品,可通过数据互通...

默认配置映射关系

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

死信队列

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

基本概念

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

MQTT快速入门

作为使用和熟悉产品功能的入门指导,本文提供如何快速使用 云消息队列 MQTT 版 通过默认支持的MQTT协议收发消息的步骤。对于非MQTT协议的接入,例如新能源,您必须首先购买 云消息队列 MQTT 版 企业铂金版,并通过专属通道享受对应的文档和...

计费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 ...

跨云产品数据流入

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

开源对比

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

默认配置映射关系

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

计费FAQ

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

Topic使用变更

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

什么是云消息队列 Kafka 版?

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

计费常见问题

本文汇总了 云消息队列 MQTT 版 计费相关的常见问题。我已经购买了包年包月微消息队列MQTT版实例,为什么发消息后,还会继续扣钱呢?包年包月(预付费)实例的费用只限于 云消息队列 MQTT 版 所支持的协议,即 云消息队列 MQTT 版 的消息...

数据流入规则管理

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

消费者负载均衡

消费者从 云消息队列 RocketMQ 版 获取消息消费时,通过消费者负载均衡策略,可将主题内的消息分配给指定消费者分组中的多个消费者共同分担,提高消费并发能力和消费者的水平扩展能力。本文介绍 云消息队列 RocketMQ 版 消费者的负载均衡...
共有200条 < 1 2 3 4 ... 200 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云消息队列 RocketMQ 版 云消息队列 Kafka 版 数据管理 全局事务服务 (文档停止维护) 弹性公网IP 短信服务
新人特惠 爆款特惠 最新活动 免费试用