阿里队列是什么-阿里队列是什么文档介绍内容-阿里云

开通服务并授权

在阿里云官方网站开通消息队列服务后方可开始使用云消息队列 MQTT 版。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的云消息队列 MQTT 版资源，并使用SDK收发消息。前提条件您已注册阿里云账号并完成...

收发事务消息

云消息队列 RocketMQ 版提供类似XA或Open XA的分布式事务功能，通过云消息队列 RocketMQ 版事务消息，能达到分布式事务的最终一致。交互流程事务消息交互流程如下图所示。更多信息，请参见事务消息。前提条件下载.NET SDK。更多信息...

常见问题

消息队列RocketMQ版集群消费和广播消费的区别是什么？多个Group订阅同一个Topic消息如何消费？消息队列RocketMQ版的消息体最大是多少？消息在消息队列RocketMQ版中能保存多久？消息的负载均衡策略是什么？消息消费失败是否会重新消费？消息...

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

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

顺序消息

功能原理 什么是顺序消息顺序消息是云消息队列 RocketMQ 版提供的一种高级消息类型，支持消费者按照发送消息的先后顺序获取消息，从而实现业务场景中的顺序处理。相比其他类型消息，顺序消息在发送、存储和投递的处理过程中，更多强调多...

定时/延时消息

功能原理 什么是定时消息定时消息是云消息队列 RocketMQ 版提供的一种高级消息类型，消息被发送至服务端后，在指定时间后才能被消费者消费。通过设置一定的定时时间可以实现分布式场景的延时调度触发效果。定时时间设置原则云消息队列 ...

事务消息

功能原理 什么是事务消息事务消息是云消息队列 RocketMQ 版提供的一种高级消息类型，支持在分布式场景下保障消息生产和本地事务的最终一致性。事务消息处理流程事务消息交互流程如下图所示。生产者将消息发送至云消息队列 RocketMQ 版...

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

支持Windows、Mac和Linux操作系统，可用于验证设备是否可以连接云消息队列 MQTT 版，并通过Topic发布和订阅消息。本文以Windows系统为例，介绍如何使用MQTT.fx模拟SDK接入云消息队列 MQTT 版并进行消息收发。前提条件下载并安装 MQTT....

网络访问与安全设置

阿里云VPC访问 VPC访问是指您在云消息队列 Confluent 版集群所在网络VPC内或者其它VPC访问和使用云消息队列 Confluent 版集群。此时，除Control Center提供公网访问方式外，其它集群组件无法从公网访问。公网访问公网访问是指您可以在...

是否支持优先级队列？

云消息队列 RabbitMQ 版不支持优先级队列。云消息队列 RabbitMQ 版内部暂未实现消息优先级的处理逻辑，您的客户端通过可选队列参数 x-max-priority 声明的优先级队列实际是无效的。

是否支持优先级队列？

云消息队列 RabbitMQ 版不支持优先级队列。云消息队列 RabbitMQ 版内部暂未实现消息优先级的处理逻辑，您的客户端通过可选队列参数 x-max-priority 声明的优先级队列实际是无效的。

P2P消息收发模式（MQTT）

什么是P2P模式 P2P，顾名思义，是一对一的消息收发模式，即只有一个消息发送者和一个消息接收者。而Pub/Sub模式通常用于一对多或多对多的消息群发场景，即拥有一个或多个消息发送者和多个消息接收者的场景。在P2P模式中，发送者发送消息时...

普通消息

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

环境准备

使用前，请注意以下几点：使用云消息队列 RocketMQ 版服务的应用程序需要部署在阿里云ECS上。代码里涉及到的Topic和Group ID，需要到控制台上创建。Message Tag可以完全由应用自定义。创建步骤，请参见快速入门中的创建资源。Windows....

环境准备

Windows.NET SDK简介阿里云提供的.NET版本是基于云消息队列 RocketMQ 版的CPP版本的托管封装，这样能保证.NET完全不依赖于Windows.NET公共库。内部采用C++多线程并发处理，保证.NET版本的高效稳定。在使用Visual Studio（VS）开发.NET的...

开源SDK接入（主子账号授权）

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

产品功能

云消息队列 RabbitMQ 版兼容开源RabbitMQ并提供一套完善的运维工具。资源支持云消息队列 RabbitMQ 版兼容开源RabbitMQ的各个组件：Queue：支持消息存储，支持集群消费模式。说明云消息队列 RabbitMQ 版内部暂未实现消息优先级的处理...

通过元数据文件迁移上云

元数据迁移是指将自建Kafka集群的元数据迁移到阿里云云消息队列 Kafka 版实例。您可以将自建Kafka集群元数据导出，然后导入云消息队列 Kafka 版实例，云消息队列 Kafka 版会根据成功导入的元数据在目标云消息队列 Kafka 版实例中...

阿里云电子政务云产品全家福

阿里云电子政务云平台价格是华北2公共云同等配置的2倍存储与CDN 产品名称产品描述政务云价格配置对象存储 OSS 阿里云对象存储服务（Object Storage Service，简称 OSS），是阿里云提供的海量、安全、低成本、高可靠的云存储服务。...

发布者最佳实践

因此，云消息队列 Kafka 版 Producer客户端什么时候把消息批量发送至服务器是由 batch.size 和 linger.ms 共同决定的。您可以根据具体业务需求进行调整。为了提升发送的性能，保障服务的稳定性，建议您设置 batch.size=16384 和 linger.ms=...

迁移自建Kafka集群至新实例

元数据迁移是指将自建Kafka集群的元数据迁移到阿里云云消息队列 Kafka 版实例。您可以将自建Kafka集群元数据导出，然后导入云消息队列 Kafka 版实例，云消息队列 Kafka 版会根据成功导入的元数据在目标云消息队列 Kafka 版实例中...

云消息队列 Kafka 版自定义权限策略参考

什么是自定义权限策略在基于RAM的访问控制体系中，自定义权限策略是指在系统权限策略之外，您可以自主创建、更新和删除的权限策略。自定义权限策略的版本更新需由您来维护。创建自定义权限策略后，需为RAM用户、用户组或RAM角色绑定权限...

开发参考

OpenAPI是阿里云产品提供的开放应用程序接口，是除控制台之外，云消息队列 RocketMQ 版管理资源的主要方式之一。API参考汇总了云消息队列 RocketMQ 版所有对外公开的API接口。云消息队列 RocketMQ 版5.x系列 5.x系列SDK参考 5.x系列API...

云消息队列 RocketMQ 版自定义权限策略

什么是自定义权限策略在基于RAM的访问控制体系中，自定义权限策略是指在系统权限策略之外，您可以自主创建、更新和删除的权限策略。自定义权限策略的版本更新需由您来维护。创建自定义权限策略后，需为RAM用户、用户组或RAM角色绑定权限...

迁移元数据上云

迁移元数据上云是指将开源RabbitMQ集群的元数据导出，并将其导入到阿里云云消息队列 RabbitMQ 版实例。云消息队列 RabbitMQ 版会根据成功导入的元数据在目标云消息队列 RabbitMQ 版实例中创建对应的Vhost、Queue、Exchange、Binding，...

JMS P2P（主账号与RAM账号场景）

某个发布者向某个Queue（队列）发送消息后，某个指定的订阅者从该Queue接收消息。发布者和订阅者之间不存在时间依赖性。发布者向Queue发送消息时不需要订阅者同时处于活跃状态，订阅者从Queue接收消息时同样不需发布者处于活跃状态。开源...

收发普通消息（三种方式）

阿里云云消息队列 RocketMQ 版提供三种方式来发送普通消息：同步发送、异步发送和单向（Oneway）发送。本文介绍了每种发送方式的原理、使用场景、示例代码，以及三种发送方式的对比；此外还提供了订阅普通消息的示例代码。前提条件您已...

步骤一：获取访问授权

说明 RAM是阿里云的访问控制系统，您可以通过创建RAM用户和角色，并为其配置相应的权限来管控您的资源访问。关于RAM的更多信息，请参见 RAM主子账号授权。操作步骤登录阿里云官网。在云资源访问授权页面，单击同意授权。执行结果同意...

订阅消息

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

延时消息

什么是延时消息延时消息是指在指定时间段之后才被消费者消费的消息。应用场景延时消息适用于以下场景：对消息生产和消费有时间窗口要求的场景。例如，在电商交易中超时未支付关闭订单的场景，在订单创建时会发送一条延时消息。这条消息将...

身份管理

RAM角色相关操作 RAM角色管理扮演RAM角色设置RAM角色最大会话时间角色SSO管理身份管理相关文档阿里云身份与权限 RAM基本概念 RAM相关使用限制云消息队列 RocketMQ 版4.x系统权限策略参考云消息队列 RocketMQ 版自定义权限策略

身份管理

RAM角色相关操作 RAM角色管理扮演RAM角色设置RAM角色最大会话时间角色SSO管理身份管理相关文档阿里云身份与权限 RAM基本概念 RAM相关使用限制云消息队列 RocketMQ 版5.x系统权限策略参考云消息队列 RocketMQ 版自定义权限策略

基于日志服务的日志说明

云消息队列 RabbitMQ 版的日志管理功能将云消息队列 RabbitMQ 版实例的消息操作日志推送到日志服务，通过SLS分析语句快速查询并统计TPS流量图表。本文介绍SLS中日志字段和请求方法。字段说明查询的日志字段说明如下表所示。表 1.日志...

身份管理

推荐的做法是使用RAM身份（即RAM用户和RAM角色）来访问云消息队列 Kafka 版。RAM用户 RAM用户需要由阿里云账号（主账号）或拥有管理员权限的RAM用户、RAM角色来创建，且必须在获得授权后才能登录控制台或使用API访问阿里云账号下的资源。...

调用方式

阿里云SDK免去您手动签名的过程。详情请参见获取SDK。OpenAPI Explorer调用 OpenAPI Explorer是可视化的API调用工具。通过该工具，您可以通过网页或者命令行调用各云产品以及API市场上开放的API，查看每次的API请求和返回结果，并生成相应...

身份管理

推荐的做法是使用RAM身份（即RAM用户和RAM角色）来访问云消息队列 RabbitMQ 版。RAM用户 RAM用户需要由阿里云账号（主账号）或拥有管理员权限的RAM用户、RAM角色来创建，且必须在获得授权后才能登录控制台或使用API访问阿里云账号下的资源...

身份管理

推荐的做法是使用RAM身份（即RAM用户和RAM角色）来访问云消息队列 MQTT 版。RAM用户 RAM用户需要由阿里云账号（主账号）或拥有管理员权限的RAM用户、RAM角色来创建，且必须在获得授权后才能登录控制台或使用API访问阿里云账号下的资源。...

控制台使用相关问题

本文介绍云消息队列 MQTT 版控制台使用时的常见问题。云监控的最大查询范围是多少？云消息队列 MQTT 版云监控支持查询3天以内的指标数据。为什么设备都断电了，控制台还显示设备在线？云消息队列 MQTT 版会定时检查客户端心跳，当系统...

迁移上云概述

和开源Apache RocketMQ相比，阿里云云消息队列 RocketMQ 版具有更高的稳定性、安全性及更完善的运维体系。您可以将开源RocketMQ集群迁移到云消息队列 RocketMQ 版上以获得更好的业务体验，本文为您介绍开源RocketMQ集群迁移上云的方案...

正式商用公告

如果您有共享服务需求，可考虑阿里云消息队列RocketMQ 或消息服务MNS 提供的按量付费共享服务。公测期间在所有地域（包括公网）创建的共享实例在2019年4月1日开始下线，于2019年5月底完成，届时共享实例将停止服务。请及时购买商用实例 ...

阿里队列是什么

新品推荐