通过消息队列实现是什么-通过消息队列实现是什么文档介绍内容-阿里云

收发顺序消息

顺序消息（FIFO 消息）是云消息队列 RocketMQ 版提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用TCP协议下的.NET SDK收发顺序消息的示例代码。顺序消息分类顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照...

订阅消息

本文介绍如何通过云消息队列 RocketMQ 版的Java SDK订阅消息。订阅方式云消息队列 RocketMQ 版支持以下两种订阅方式：集群订阅同一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息，一个Group ID有3个...

功能与特性概述

本文列举云消息队列 RocketMQ 版所支持的所有功能与特性。概览云消息队列 RocketMQ 版在阿里云多个地域（Region）提供了高可用消息云服务。单个地域内采用多机房部署，可用性极高，即使整个机房都不可用，仍然可以为应用提供消息发布...

数据流出规则管理

云消息队列 RocketMQ 版实例版本仅4.0系列实例支持云消息队列 MQTT 版和云消息队列 RocketMQ 版 通过消息流入或消息流出规则进行数据互通时，云消息队列 RocketMQ 版仅4.0系列实例支持消息流入或流出规则，5.0系列实例不支持。...

开通消息队列服务并授权

为了实现更细粒度的授权需求，云消息队列 RocketMQ 版还提供了更多的自定义权限策略，可针对某一类资源进行授权，例如只授予用户通过控制台管理Topic的权限。更多自定义权限策略信息，请参见权限策略和示例。后续步骤您可单击管理控制...

开通消息队列服务并授权

为了实现更细粒度的授权需求，云消息队列 RocketMQ 版还提供了更多的自定义权限策略，可针对某一类资源进行授权，例如只授予用户通过控制台管理Topic的权限。更多自定义权限策略信息，请参见权限策略和示例。后续步骤您可单击管理控制...

查看Rebalance详情

背景信息 Rebalance是云消息队列 Kafka 版对分区和Consumer Group之间的消费对应关系进行重分配的过程。消费客户端出现Rebalance可能是以下原因：当消费者主动新增订阅或者取消订阅时，会触发该Consumer Group内的Rebalance。当Topic的...

应用场景

普通消息处理如上所述，注册系统和邮件通知系统之间通过消息队列进行异步处理。注册系统将注册信息写入注册系统之后，发送一条注册成功的消息到云消息队列 RocketMQ 版，邮件通知系统订阅云消息队列 RocketMQ 版的注册消息，做相应的...

什么是云消息队列 Kafka 版？

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

收发顺序消息

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

订阅消息

本文介绍如何通过云消息队列 RocketMQ 版的SDK使用.NET语言进行消息订阅。说明请确保同一个Group ID下所有Consumer实例的订阅关系保持一致。更多信息，请参见订阅关系一致。云消息队列 RocketMQ 版支持以下两种订阅方式：集群订阅同...

收发顺序消息

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

云存储网关利用MQTT服务实现统一管控

通过云消息队列 MQTT 版所提供的服务，可采用统一的框架，即云控制台，来管理不同部署模式的云存储网关CSG（Cloud Storage Gateway），并实现安全合规的公网和私网穿透，以此提供一致的用户体验。名词解释 MQTT 一种物联网和移动互联网...

消费者（Consumer）

行为约束在云消息队列 RocketMQ 版领域模型中，消费者的管理通过消费者分组实现，同一分组内的消费者共同分摊消息进行消费。因此，为了保证分组内消息的正常负载和消费，云消息队列 RocketMQ 版要求同一分组下的所有消费者以下消费行为...

SDK列表

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

快速入门概述

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

消费进度管理

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

OnsRegionList-获取地域信息列表

在您使用 SDK 接入云消息队列 RocketMQ 版服务并进行管控操作时，需要依次指定两个地域的信息，第二个地域的信息才是通过 OnsRegionList 接口获取。具体场景如下：将您的应用接入云消息队列 RocketMQ 版服务：根据您的应用的部署地域选择...

收发顺序消息

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

收发顺序消息

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

收发顺序消息

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

收发顺序消息

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

使用限制

云消息队列 RocketMQ 版实例版本仅4.0系列实例支持云消息队列 MQTT 版和云消息队列 RocketMQ 版 通过消息流入或消息流出规则进行数据互通时，云消息队列 RocketMQ 版仅4.0系列实例支持消息流入或流出规则，5.0系列实例不支持。...

收发顺序消息

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

消息存储和清理机制

本文为您介绍云消息队列 RocketMQ 版中消息的存储机制，包括消息的存储粒度、判断依据及后续处理策略等。背景信息参考云消息队列 RocketMQ 版中队列的定义，消息按照达到服务器的先后顺序被存储到队列中，理论上每个队列都支持无限...

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

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

JMS概述

云消息队列 RabbitMQ 版提供JMS库供JMS客户端接入云消息队列 RabbitMQ 版。本文介绍云消息队列 RabbitMQ 版 JMS库的相关概念、获取方式、使用限制和使用教程。背景信息 JMS是一种消息传递标准，允许基于Java EE（Java平台企业版）的应用...

SDK概述

本文介绍云消息队列 Kafka 版 SDK、支持的多语言SDK。SDK简介 SDK（Software Development Kit）即软件开发工具包，包含示例Demo、库文件、编译工具链以及编译脚本等，不需要开发者进行任何其他的配置，直接可以在SDK对应目录环境下，进行...

基本概念

本文主要对云消息队列 RocketMQ 版涉及的专有名词及术语进行定义和解析，方便您更好地理解相关概念并使用云消息队列 RocketMQ 版。Topic 消息主题，一级消息类型，通过Topic对消息进行分类。更多信息，请参见 Topic与Tag最佳实践。消息...

使用ACL功能进行访问控制

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

生产者（Producer）

本文介绍云消息队列 RocketMQ 版中生产者（Producer）的定义、模型关系、内部属性、版本兼容性及使用建议。定义生产者是云消息队列 RocketMQ 版系统中用来构建并传输消息到服务端的运行实体。生产者通常被集成在业务系统中，将业务...

名词解释

在使用云消息队列 MQTT 版前，需理解该产品和MQTT协议所涉及的基本概念和术语。基本概念实例（Instance）创建购买云消息队列 MQTT 版服务的实体单元，每个云消息队列 MQTT 版实例都对应一个全局唯一的服务接入点URL。使用云消息...

开源对比

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

收发事务消息

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

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

如下图所示，您可以使用MQTT.fx作为MQTT客户端，在MQTT.fx客户端配置相关参数后接入云消息队列 MQTT 版实现消息的发送和接收。云消息队列 MQTT 版同时提供了公网接入点和 VPC 接入点。在物联网和移动互联网的场景中，客户端推荐使用 ...

RAM主子账号授权

仅限有权限的RAM用户可以通过云消息队列 RocketMQ 版控制台或API管理指定资源。应用场景企业A购买了云消息队列 RocketMQ 版服务，企业A的员工需要操作这些服务所涉及的资源，例如实例、Topic或Group资源，有的员工负责创建资源，有的...

上下线通知规则管理

云消息队列 RocketMQ 版实例版本仅4.0系列实例支持云消息队列 MQTT 版和云消息队列 RocketMQ 版 通过消息流入或消息流出规则进行数据互通时，云消息队列 RocketMQ 版仅4.0系列实例支持消息流入或流出规则，5.0系列实例不支持。...

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

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

应用场景

本文介绍云消息队列 Kafka 版的典型应用场景，包括网站活动跟踪、日志聚合、数据处理、数据中转枢纽。网站活动跟踪成功的网站运营需要对站点的用户行为进行分析。通过云消息队列 Kafka 版的发布/订阅模型，您可以实时收集网站活动数据...

普通消息

功能原理 什么是普通消息定义：普通消息是云消息队列 RocketMQ 版基本消息功能，支持生产者和消费者的异步解耦通信。普通消息生命周期初始化消息被生产者构建并完成初始化，待发送到服务端的状态。待消费消息被发送到服务端，对消费...

通过消息队列实现是什么

新品推荐