详解PHP队列的实现-详解PHP队列的实现文档介绍内容-阿里云

MQTT与RocketMQ的消息结构映射

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

消费者（Consumer）

本文介绍云消息队列 RocketMQ 版中消费者（Consumer）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义消费者是云消息队列 RocketMQ 版中用来接收并处理消息的运行实体。消费者通常被集成在业务系统中，从云消息...

资源使用变更

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

在线教育视频直播

场景描述适用于在线教育的视频直播场景，通过阿里云视频直播服务实现移动端的推拉流能力，同时移动端利用云消息队列 MQTT 版实现发送和接收消息，在消息转发时利用内容安全服务对消息内容进行审核。发送的消息可以存储在表格存储中。...

什么是云消息队列 RocketMQ 版？

为什么选择云消息队列 RocketMQ 版云消息队列 RocketMQ 版基于阿里云云原生优质的基础设施实现，兼容Apache RocketMQ的核心API和功能。相对于自建RocketMQ集群，云消息队列 RocketMQ 版具有如下优势：架构先进性全面采用存储和计算分离...

消息收发流程变更

由于云消息队列 MQTT 版 V2.x.x和V3.x.x相比，V3.x.x实现了独立存储，对云消息队列 RocketMQ 版没有强依赖，因此消息收发流程有相应的变更。云消息队列 MQTT 版 V2.x.x版本强依赖云消息队列 RocketMQ 版作为消息存储，因此云消息队列...

权益分发

可以帮助简化DB和缓存间的实现，大大减少代码开发量。如果没有云消息队列 RocketMQ 版，实现方法则十分复杂。支持实时消息收发以及重试功能，确保消息不丢，从而保证消息强一致性。更多信息云消息队列 RocketMQ 版的功能与特性详情，请...

新功能发布记录

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

消费者分类

云消息队列 RocketMQ 版支持PushConsumer和SimpleConsumer这两种类型的消费者，本文分别从使用方式、实现原理、可靠性重试和适用场景等方面为您介绍这两种类型的消费者。背景信息云消息队列 RocketMQ 版面向不同的业务场景提供了不同...

配置消息监控告警实现风险预警

云消息队列 RocketMQ 版支持通过云监控配置告警规则，以便您可以实时监控实例的运行状态和关键的业务指标，并能够及时收到异常的告警通知，实现生产环境的风险预警。背景信息云消息队列 RocketMQ 版提供全托管的消息服务，对于每个规格...

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

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

迁移上云操作

步骤二：配置网络信息创建迁移任务并配置源自建集群的网络信息，用于云消息队列 RocketMQ 版迁移工具读取源自建集群的元数据信息，并实现后续迁移任务的控制。注意事项云消息队列 RocketMQ 版迁移工具按照最小范围粒度仅访问源自建...

服务关联角色

本文介绍云消息队列 RabbitMQ 版服务关联角色的背景信息，权限策略、注意事项和常见问题。背景信息服务关联角色是某个云服务在某些情况下，为了完成自身的某个功能，需要获取其他云服务的访问权限而提供的RAM角色。您在该云服务的控制台...

消息队列RabbitMQ版

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

延时消息

如果您希望消息被投递后延迟一段时间被消费者消费，您可以使用云消息队列 RabbitMQ 版的延时消息。云消息队列 RabbitMQ 版原生支持延时消息，使用方式比开源RabbitMQ更简单。什么是延时消息延时消息是指在指定时间段之后才被消费者消费...

快速入门概述

消息服务MNS 支持使用队列模型和主题模型收发消息，实现...主题模型快速入门流程主题模型投递消息至队列的流程如下：创建队列创建主题创建订阅发布消息接收消息删除队列删除主题更多信息使用多语言SDK实现消息收发，请参见 SDK参考。

消息队列RocketMQ版

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

云消息队列 RocketMQ 版

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

服务关联角色

本文介绍云消息队列 Kafka 版服务关联角色的背景信息、策略内容、注意事项和常见问题。背景信息服务关联角色是某个云服务在某些情况下，为了完成自身的某个功能，需要获取其他云服务的访问权限而提供的RAM角色。您在该云服务的控制台...

消息服务MNS

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

基于Flink的资讯场景实时数仓

本文介绍如何针对资讯聚合类业务场景搭建基于云消息队列 Kafka 版和实时计算Flink的实时数仓。场景描述本文首先介绍什么是实时数仓以及相关技术架构，接着介绍资讯聚合类业务的典型场景及其业务目标，并据此设计了相应的技术架构。然后...

迁移概述

重要消息队列的特点是，数据一旦被消费，则已经完成使命。因此，除了需要将自建Kafka集群的数据备份云消息队列 Kafka 版实例的情况外，一般情况下不推荐您迁移数据。查看迁移进度：查看自建Kafka集群迁移到云消息队列 Kafka 版的进度...

消费者分组（ConsumerGroup）

本文介绍云消息队列 RocketMQ 版中消费者分组（ConsumerGroup）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义消费者分组是云消息队列 RocketMQ 版系统中承载多个消费行为一致的消费者的负载均衡分组。和消费者...

开源RabbitMQ迁移上云

在使用开源RabbitMQ集群时，当您希望能够解决各种稳定性痛点（例如消息堆积、脑裂等问题）、实现高并发、分布式、灵活扩缩容时，您可以将开源RabbitMQ集群迁移至云消息队列 RabbitMQ 版，本文介绍迁移上云的前提条件、操作步骤、注意事项...

消息检索

背景信息云消息队列 Kafka 版消息检索借助云消息队列 Kafka 版的Connector功能及表格存储（Tablestore）实现，通过Connector对Topic中的消息进行转储，发送到表格存储中的数据表中，由表格存储索引功能提供消息检索的能力。开通消息...

基本概念

本文主要对云消息队列 RocketMQ 版涉及的专有名词及术语进行定义和...云消息队列 RocketMQ 版的全球消息路由功能依托阿里云优质基础设施实现的高速通道专线，可以高效地实现不同地域之间的消息同步复制。更多信息，请参见全球消息路由。

什么是消息队列RabbitMQ版？

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

快速入门概述

云消息队列 MQTT 版支持使用多种语言的SDK接入服务端实现消息收发，本文以Java为例介绍不同场景下的消息收发流程。操作流程使用SDK收发消息流程如下图所示。具体操作步骤如下：开通服务并授权开通消息队列服务，并授予RAM用户操作云...

通过元数据文件迁移上云

本文介绍如何在云消息队列 Kafka 版控制台创建迁移任务，将元数据迁移至云消息队列 Kafka 版已有实例。前提条件下载JDK 8 购买并部署云消息队列 Kafka 版实例：购买并部署VPC实例购买并部署公网/VPC实例背景信息 Kafka集群元数据...

数据传输服务DTS

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

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

前提条件如果您要使用SSL连接AMQProxy和云消息队列 RabbitMQ 版，请确保您的客户端服务器已安装OpenSSL。更多信息，请参见 Downloads。重要 VPC环境下不支持使用SSL连接云消息队列 RabbitMQ 版。背景信息部分语言的客户端，例如PHP客户...

消息服务MNS

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

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

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

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

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

收发事务消息

云消息队列 RocketMQ 版发送事务消息时需要实现 LocalTransactionChecker 接口，用来处理Broker主动发起的本地事务状态回查请求，因此在事务消息的Check方法中，需要完成两件事情：检查该半事务消息对应的本地事务的状态（committed or ...

数据传输服务DTS

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

新零售电子价签解决方案（MQTT）

新零售电子价签解决方案由阿里云云消息队列 MQTT 版推出，通过MQTT以实现商场超市、公共场所电子标签、多媒体屏幕的数据更新管理。本文将以电子价签为例详细描述该解决方案的系统架构、数据流设计以及注意事项，其他类似行业可参考该方案...

收发事务消息

目前支持的地域包括公网、华东1（杭州）、华北2（北京）、华东2（上海）、华南1（深圳）。...具体代码的更多信息，请参见 MyLocalTransactionChecker 的实现。订阅事务消息事务消息的订阅与普通消息订阅一致，更多信息，请参见订阅消息。

使用ACL功能进行访问控制

当需要对不同的用户或用户组授予不同级别的访问权限时，您可以使用云消息队列 Kafka 版专业版或V3系列Serverless 实例的访问控制列表（ACL）功能，为SASL用户赋予对Topic、Group等资源的操作权限，实现细粒度的权限管理。背景信息企业A...

怎样让Consumer不立即消费消息并使消息重入队列？

使用basicReject方法否定应答单条消息并使消息重入队列您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。basicReject方法的参数说明如下：deliveryTag：Channel的消息投递的唯一标识符。requeue：被否定应答的消息...

详解PHP队列的实现

新品推荐