队列使用手册

本文介绍如何使用PHP SDK创建队列、发送消息、接收和删除消息、以及删除队列。步骤一:准备工作 下载文件 CreateQueueAndSendMessage.php。打开 CreateQueueAndSendMessage.php 文件,在文件的最下方配置AccessKeyId、AccessKeySecret和...

主题使用手册

本文介绍如何使用PHP SDK创建主题、创建队列、创建订阅和发布消息等操作。步骤一:准备工作 下载文件 CreateTopicAndPushMessageToQueue。打开 CreateTopicAndPushMessageToQueue.php 文件,在文件中最下方配置以下内容:AccessKey ID、...

PHP SDK收发消息

本文介绍如何使用PHP SDK通过接入点接入 云消息队列 Kafka 版 并收发消息。环境准备 安装GCC 安装PHP 安装PECL 安装C++依赖库 执行以下命令切换到yum源配置目录/etc/yum.repos.d/。cd/etc/yum.repos.d/创建yum源配置文件 confluent.repo。...

为什么PHP发送延时比较长?

PHP发送延时比较长是PHP的语言特性导致的。PHP每次发送时,都会重新初始化一个KafkaProducer对象,这个初始化会进行各种操作,包括连接各个Broker、更新Metadata等,在VPC内耗时100ms以上,在公网可能耗时500ms以上。相比之下,Java会复用...

准备环境

在使用PHP SDK收发消息前,您需按照本文提供的内容来准备环境。环境要求 安装PHP 5.5.0或以上版本,更多信息,请参见 安装PHP。重要 对于PHP版本小于7.2.5的运行环境,需要将Composer依赖降低到2.2.x或以下版本。安装Composer,更多信息,...

版本说明

本文介绍HTTP协议下PHP SDK的版本信息,包括各版本的发布时间、发布内容以及下载链接,以便您按需获取适用的PHP SDK收发消息。1.0.4 发布时间 发布内容 下载 2023-01-11 问题修复 修复当消息体存在不合法字符时无法解析的问题。mq-...

收发事务消息

云消息队列 RocketMQ 版 提供类似XA或Open XA的分布式事务功能,通过 云消息队列 RocketMQ 版 事务消息,能达到分布式事务的最终一致。本文提供使用HTTP协议下的PHP SDK收发事务消息的示例代码。背景信息 事务消息的交互流程如下图所示。更...

收发顺序消息

顺序消息(FIFO消息)是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的PHP SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类:全局顺序:对于指定的一个Topic,所有消息按照严格...

收发定时消息和延时消息

背景信息 延时消息:Producer将消息发送到 云消息队列 RocketMQ 版 服务端,但并不期望立马投递这条消息,而是延迟一定时间后才投递到Consumer进行消费,该消息即延时消息。定时消息:Producer将消息发送到 云消息队列 RocketMQ 版 服务端...

收发普通消息

普通消息是指 云消息队列 RocketMQ 版 中无特性的消息,区别于有特性的定时和延时消息、顺序消息和事务消息。本文提供使用HTTP协议下的PHP SDK收发普通消息的示例代码。前提条件 您已完成以下操作:安装PHP SDK。更多信息,请参见 准备环境...

消息收发功能

云消息队列 MQTT 版 支持多语言的消息收发。本文提供单独使用 云消息队列 MQTT 版 收发消息以及与 云消息队列 RocketMQ 版 结合使用时需使用的代码示例的链接。...php 云消息队列 MQTT 版 发送 云消息队列 RocketMQ 版 接收 语言 链接 Java ...

队列(MessageQueue)

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

排他队列

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

消息收发流程变更

云消息队列 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 版 ...

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 版 广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域,已成为大数据生态中不可或缺的部分。产品优势 云消息队列 ...

消费者负载均衡

消费者从 云消息队列 RocketMQ 版 获取消息消费时,通过消费者负载均衡策略,可将主题内的消息分配给指定消费者分组中的多个消费者共同分担,提高消费并发能力和消费者的水平扩展能力。本文介绍 云消息队列 RocketMQ 版 消费者的负载均衡...

数据流入规则管理

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

直播互动解决方案

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

消费进度管理

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

开发参考

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

跨云产品的数据流出

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

视频专区

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

计费常见问题

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

迁移概述

本文介绍将自建Kafka集群迁移到 云消息队列 Kafka 版 实例的优势、原理、方案架构、迁移工具和操作流程。迁移优势 将自建Kafka集群迁移到 云消息队列 Kafka 版 实例的优势,请参见 产品优势。迁移原理 对于消息队列来说,如果要实现集群...

网络访问与安全设置

本文介绍如何进行 云消息队列 Confluent 版 集群的网络访问与安全设置。网络访问类型 云消息队列 Confluent 版 集群提供阿里云VPC访问和公网访问方式。阿里云VPC访问 VPC访问是指您在 云消息队列 Confluent 版 集群所在网络VPC内或者其它...
共有126条 < 1 2 3 4 ... 126 >
跳转至: GO
产品推荐
云服务器 安全管家服务 安全中心
这些文档可能帮助您
云消息队列 Kafka 版 云消息队列 RocketMQ 版 阿里邮箱 云数据库 RDS 商标服务 弹性公网IP
新人特惠 爆款特惠 最新活动 免费试用