队列机制不可用-队列机制不可用文档介绍内容-阿里云

功能与特性概述

单个地域内采用多机房部署，可用性极高，即使整个机房都不可用，仍然可以为应用提供消息发布服务。云消息队列 RocketMQ 版提供TCP和HTTP协议的多语言接入方式，方便不同编程语言开发的应用快速接入云消息队列 RocketMQ 版消息云服务。您...

消息发送重试和流控机制

本文为您介绍云消息队列 RocketMQ 版的消息发送重试机制和消息流控机制。背景信息消息发送重试云消息队列 RocketMQ 版的消息发送重试机制主要为您解答如下问题：部分节点异常是否影响消息发送？请求重试是否会阻塞业务调用？请求重试...

不在同一可用区内的ECS实例如何访问云消息队列 Kafka ...

概述不在同一可用区内的ECS实例可通过非公网的方式访问云消息队列 Kafka 版实例，详情请查看以下内容。详细信息以非公网的方式访问云消息队列 Kafka 版实例时，必须满足以下两个条件：ECS实例与云消息队列 Kafka 版实例在同一VPC网络实例...

管理资源队列

配置说明队列名称队列名称不可重复，只允许小写字母、数字和中划线（-）且长度不超过32位。说明资源队列添加成功后，不可修改资源队列名称。资源量（CU）允许配置的资源量上限由该项目空间剩余的可用资源量决定。如果项目空间可用资源...

实例管理

已停服实例不可用。实例的资源和数据保留，可恢复。已释放实例不可用。实例的资源和数据删除，不可恢复。支持的操作操作说明创建实例云消息队列 RabbitMQ 版提供专业版、企业版、铂金版和Serverless版实例。具体规格差异，请参见 ...

迁移自建Kafka集群至新实例

本文介绍如何在云消息队列 Kafka 版控制台创建并启动迁移任务。前提条件下载JDK 8 安装Tsar 为了更准确的获取执行机器的配置，推荐您提前安装Tsar软件。您也可以在运行迁移工具时通过指定-installTsar 参数自动安装Tsar软件，但自动安装...

按量计费转包年包月

注意事项按量计费转包年包月的过程中，实例始终处于服务中状态，不会因为实例重启而导致服务短暂不可用。按量计费转包年包月不会改变实例的ID或接入点。操作步骤登录云消息队列 Kafka 版控制台。在概览页面的资源分布区域，选择...

新增分区时对应的Topic数量额度

可使用的Topic数量与总分区数强相关。例如，您已购买了分区数为50、流量规格为alikafka.hw.2xlarge、规格内赠送分区数为1000的实例，那么该...云消息队列 Kafka 版 Serverless实例不受此项限制。购买分区的操作步骤，请参见升级实例配置。

工作队列

注意：该机制不支持周期work的处理。工作机制 workqueue的处理依赖于task任务。一个workqueue队列会创建关联其对应的task任务，一个workqueue会挂载多个work处理，每个work处理对应一个处理函数。当workqueue得到调度，即其关联的task得到...

消息存储和清理机制

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

实例规格

可用性 99.99%（累计不可用时间最长不超过4.3分钟/月）99.95%（累计不可用时间最长不超过21.5分钟/月）专家尊享通道产品专家与研发专家在线支持，及时协助处理线上问题。提供保驾护航服务，例如大促保障护航、新业务上线等。云消息队列 ...

产品优势

高可用提供明确 SLA，保障多可用区高可用，即便整个机房不可用仍可正常提供消息服务。集群分布式部署，服务节点无状态、无单点。即使单节点不可用，请求将Failover至其他节点保障消息服务正常提供。功能增强延时消息支持延时消息，实现...

队列（MessageQueue）

模型关系在整个云消息队列 RocketMQ 版的领域模型中，队列所处的流程和位置如下：云消息队列 RocketMQ 版默认提供消息可靠存储机制，所有发送成功的消息都被持久化存储到队列中，配合生产者和消费者客户端的调用可实现至少投递一次的...

续费说明

续费规则续费对象续费功能仅适用于包年包月的云消息队列 RocketMQ 版实例，按量付费实例不需要续费，只要保证您的阿里云账户可用额度充足即可。续费时间自动续费：实例到期前9天开始触发，持续至到期前1天，每天触发一次，直到续费...

事务消息

事务超时机制云消息队列 RocketMQ 版事务消息的生命周期存在超时机制，即半事务消息被生产者发送服务端后，如果在指定时间内服务端无法确认提交或者回滚状态，则消息默认会被回滚。事务超时时间，请参见参数限制。不支持多个sendReceipt...

开源MQTT迁移至云消息队列 MQTT 版

具体操作流程如下：使用限制若迁移前使用的服务端为EMQX开源服务端，则原系统Topic不可用。例如$delayed、$share等以$开头的Topic。迁移前使用过的开源MQTT客户端必须符合MQTT 3.1.1协议。云消息队列 MQTT 版客户端不支持使用自定义用户...

Token鉴权概述

应用服务器需要做本地容灾，避免因MQTT服务器访问短暂不可用而导致业务阻塞的情况。相关API Token鉴权流程通过相关的API来完成。应用服务器负责Token的申请和吊销管理，和云消息队列 MQTT 版服务器之间通过HTTPS的OpenAPI进行交互。每个...

Token鉴权概述

应用服务器需要做本地容灾，避免因MQTT服务器访问短暂不可用而导致业务阻塞的情况。相关API Token鉴权流程通过相关的API来完成。应用服务器负责Token的申请和吊销管理，和云消息队列 MQTT 版服务器之间通过HTTPS的OpenAPI进行交互。每个...

迁移元数据上云

使用限制由于RabbitMQ和云消息队列 RabbitMQ 版在权限管控机制等方面存在差异，rabbit_version、users、permissions、parameters、global_parameters 和 policies 元数据不支持导入云消息队列 RabbitMQ 版实例，在导入时会被自动忽略...

产品架构

本文介绍云消息队列 RocketMQ 版的系统部署架构，方便您更好地理解云消息队列 RocketMQ 版的高可用性。云消息队列 RocketMQ 版在任何一个环境都是可扩展的，生产者必须是一个集群，消息服务器必须是一个集群，消费者也同样。集群级别...

生产者负载均衡

生产者发送消息到云消息队列 RocketMQ 版服务端时，云消息队列 RocketMQ 版将根据生产者负载均衡策略将消息均匀的存储在多个队列中，避免产生热点队列和性能瓶颈。本文介绍云消息队列 RocketMQ 版生产者的负载均衡策略。背景信息了解...

使用限制

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

是否支持优先级队列？

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

是否支持优先级队列？

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

一机一密概述

应用服务器需要做本地容灾，避免因MQTT服务器访问短暂不可用而导致业务阻塞的情况。相关API 一机一密鉴权流程通过相关的API来完成。应用服务器负责设备访问凭证的申请和管理，和云消息队列 MQTT 版服务器之间通过HTTPS的OpenAPI进行交互...

SDK FAQ

云消息队列 RabbitMQ 版不支持直接使用开源RabbitMQ JMS Client。您需要通过Maven配置依赖库才能接入云消息队列 RabbitMQ 版收发消息。如何通过Maven配置依赖库来收发消息，请参见 JMS概述。JMS标准有哪些接口不支持？云消息队列 ...

应用场景

其高性能的消息处理能力可以承接流量脉冲而不被击垮，在确保系统可用性的同时，通过快速有效的请求响应技术提升用户体验。其海量消息堆积能力确保下游业务在安全水位内平滑稳定地运行，避免流量高峰的冲击。分布式缓存同步大量并发访问...

消息过滤

消费者订阅了某个主题后，云消息队列 RocketMQ 版会将该主题中的所有消息投递给消费者。若消费者只需要关注部分消息，可通过设置过滤条件在云消息队列 RocketMQ 版服务端进行过滤，只获取到需要关注的消息子集，避免接收到大量无效的...

什么是云消息队列 RocketMQ 版？

当某个可用区不可用时，仍然能够保障服务的正常访问。数据复制：支持跨地域和同地域的数据复制，通过路由规则将消息数据从源实例同步到目标实例中。更多信息，请参见全球消息路由。稳定性SLA 多可用区部署，提供业内领先的稳定性SLA保障，...

查看迁移进度

迁移类型包括：通过命令行迁移迁移Topic上云迁移Group上云迁移数据上云通过元数据文件迁移上云迁移自建Kafka集群至新实例位点迁移重要目前不支持将自建Kafka集群的位点迁移到云消息队列 Kafka 版。操作步骤重要云消息队列 Kafka...

CreateInstance-创建实例

创建云消息队列 RocketMQ 版5.x系列实例。接口说明注意阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致链路产生风险...

基本概念

本文说明云消息队列 Kafka 版涉及的专有名词和术语，帮助您更好地理解相关概念并使用该产品。Apache Kafka 一款开源的分布式数据流处理平台，可以实时发布、订阅、存储和处理数据流。更多信息，请参见 Apache Kafka。云消息队列 Kafka 版...

开源对比

项目云消息队列 Kafka 版 Apache Kafka 差异原因 Topic 创建方式云消息队列 Kafka 版控制台云消息队列 Kafka 版 OpenAPI 服务端自动创建（默认不开启）Kafka CLI Kafka Manager 服务端自动创建云消息队列 Kafka 版默认通过阿里云控制...

消息收发计算规格费用

实例不支持或未开启弹性TPS功能，则云消息队列 RocketMQ 版对实例进行限流。实例限流的详细信息，请参见消息流控机制。消息收发TPS计算规则消息收发TPS即为每秒钟消息发送和订阅消息次数的最大总和。实例默认的收发能力比例为1:1，对于...

产品功能

说明云消息队列 RabbitMQ 版不支持事务消息，即不支持AMQP 0-9-1协议中的事务操作（包括 txSelect、txCommit、txRollback 等命令）。为兼容以上事务操作，云消息队列 RabbitMQ 版服务端在接收命令后会直接返回成功状态，但并不具备实际...

从自建MySQL同步至云消息队列 Kafka 版

可能会导致数据库的负载上升，在数据库性能较差、规格较低或业务量较大的情况下（例如源库有大量慢SQL、存在无主键表或目标库存在死锁等），可能会加重数据库压力，甚至导致数据库服务不可用。因此您需要在执行数据同步前评估源库和目标库...

迁移上云操作

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

收发事务消息

TagA",/Message Body，不能为空，消息队列RocketMQ版不做任何干预，需要Producer与Consumer协商好一致的序列化和反序列化方式。factoryInfo.getMessageContent());设置代表消息的业务关键属性，请尽可能全局唯一。以方便您在无法正常收到...

生产者（Producer）

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

云消息队列 Kafka 版服务等级协议

云消息队列 Kafka 版规定了阿里云向客户提供的阿里云云消息队列 Kafka 版的服务可用性等级指标及赔偿方案。如需查看云消息队列 Kafka 版的服务可用性等级指标及赔偿方案，请参见云消息队列 Kafka 版服务等级协议。

队列机制不可用

新品推荐