先入先出队列如何安装-先入先出队列如何安装文档介绍内容-阿里云

访问控制概述

云消息队列 RocketMQ 版支持通过RAM和ACL实现对云消息队列 RocketMQ 版资源的访问控制。使用限制按量付费实例和包年包月实例需要先开启公网访问功能，才支持IP白名单功能。具体操作，请参见实例升降配。按量付费实例和包年包月实例...

MNS是否提供对消息的先入先出（FIFO）访问？

本文介绍消息服务MNS 能否提供消息先入先出访问的问题。消息服务MNS 消费消息时尽量做到先进先出，正是因为分布式消息队列的一些特性并不能保证您能按照消息的发送顺序消费消息，如果您的业务必须先进先出，建议在消息中加入序号信息以便...

步骤二：创建资源

在调用SDK收发消息前，您需要提前创建云消息队列 RocketMQ 版的相关资源，包括创建云消息队列 RocketMQ 版实例、获取实例的接入点、创建Topic、创建ConsumerGroup。调用SDK时，需要将这些资源信息填写到SDK代码中。前提条件创建专有...

MQTT快速入门

对于非MQTT协议的接入，例如新能源，您必须首先购买云消息队列 MQTT 版企业铂金版，并通过专属通道享受对应的文档和技术支持服务。说明您可观看入门操作视频来快速上手云消息队列 MQTT 版。视频详细信息，请参见快速入门视频。注意...

产品优势

功能增强延时消息支持延时消息，实现秒级精准，无先入先出限制。简单易用，在代码上只需要设置一个参数即可完成，解决开源RabbitMQ无延时队列的痛点。高精度支持，最短可精确到秒级，最长可持续1天。高性能，性能与普通消息一致。多副本...

步骤一：获取访问授权

开通云消息队列 Kafka 版服务需要使用阿里云其他云产品中的资源，因此，您需要先授权云消息队列 Kafka 版访问您所拥有的其他阿里云资源。前提条件注册阿里云账号并完成实名认证。详情请参见注册阿里云账号。背景信息为了方便您快速...

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

通过数据传输服务DTS（Data Transmission Service），您可以将自建MySQL同步至云消息队列 Kafka 版，扩展消息处理能力。前提条件您已完成以下操作：自建MySQL数据库且数据库版本为5.1、5.5、5.6、5.7或8.0版本。购买并部署云消息队列 ...

实例管理

使用云消息队列 RocketMQ 版进行消息收发，必须先创建云消息队列 RocketMQ 版实例。本文介绍如何在云消息队列 RocketMQ 版控制台上创建、删除、更新和查看实例详情。背景信息云消息队列 RocketMQ 版实例按照规格分为标准版和企业...

API概览

一机一密 API 标题 API概述 GetDeviceCredential 查询设备的访问凭证一机一密认证方式下，设备与云消息队列 MQTT 版建立连接时，需要携带提前申请的设备访问凭证信息向云消息队列 MQTT 版发起认证请求，请求通过则允许设备接入服务端。...

名词解释

根据MQTT协议，Topic存在多级，定义第一级Topic为父级Topic，使用云消息队列 MQTT 版前，需先在控制台创建该父级Topic，可以在云消息队列 MQTT 版控制台创建，或者直接在云消息队列 RocketMQ 版的控制台创建。子级Topic（Subtopic）...

专业版实例计费

公网下行流量指的是使用公网接入点接入云消息队列 MQTT 版服务端产生的公网出流量。计费方式按量付费计费周期每小时计算一次费用计费公式每小时公网流量费用=1小时内公网出流量累计值×单价公网流量单价地域单价（元/GB）亚太 ...

快速入门概述

使用说明权限说明若您的账号为RAM用户，则必须先为该RAM用户进行授权，才能访问云消息队列 RocketMQ 版，并对云消息队列 RocketMQ 版的指定资源进行增删改查操作。更多信息，请参见权限概述。接入点说明调用SDK收发消息时，需要在...

开通消息队列服务并授权

如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的云消息队列 RocketMQ 版资源，并使用资源通过SDK收发消息。前提条件您已注册阿里云账号并完成实名认证。更多信息，请参见阿里云账号注册流程。步骤一：...

开通消息队列服务并授权

如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或API访问相应的云消息队列 RocketMQ 版资源，并使用资源通过SDK收发消息。前提条件您已注册阿里云账号并完成实名认证。更多信息，请参见阿里云账号注册流程。步骤一：...

消息轨迹

同一MessageGroup的消息将遵循先进先出的顺序关系进行处理。事务消息 Check回调时间半事务消息检查事务状态的回调时间。提交时间事务消息被服务端提交给消费者消费的时间。回滚时间事务消息回滚的时间。定时消息预设定时时间定时消息...

IP白名单

IP白名单用于控制客户端是否可以连接云消息队列 RocketMQ 版服务端实例，您可以为指定实例设置IP白名单，允许特定IP地址段下的客户端连接云消息队列 RocketMQ 版实例。功能介绍云消息队列 RocketMQ 版实例创建后默认IP白名单地址段为...

用户身份识别

为提高数据安全性，云消息队列 RocketMQ 版服务端会在客户端接入时对客户端进行身份验证，仅通过验证的客户端才能连接服务端进行消息收发。同时云消息队列 RocketMQ 版支持ACL身份识别，您可以按需为指定ACL用户赋予具体的Topic或Group...

升级实例配置

云消息队列 Kafka 版的VPC实例没有公网接入点，不能使用公网资源，无法满足业务需求。升级后会引发集群逐台重启，且暂停弹缩。云消息队列 Kafka 版的公网/VPC实例不再使用公网资源，需要变更为VPC实例。升级后会引发集群逐台重启，且暂停...

计费概述

云消息队列 RabbitMQ 版提供包年包月预付费和Serverless按量后付费计费方式，每种计费方式的计费项和计费规则都有所差异，您可以...后续您想再次使用云消息队列 RabbitMQ 版服务需要重新购买实例，新购买的实例ID和接入点和原实例不同。

Exchange管理

x-jms-topic：适用于通过云消息队列 RabbitMQ 版提供的JMS接口接入云消息队列 RabbitMQ 版的JMS应用，该类型路由规则会将消息路由到Binding Key与Routing Key通配符匹配的Queue中。更多信息，请参见 JMS概述。x-delayed-message：通过...

集成概述

例如，创建流出目标端为Tablestore的Sink Connector，请先开通表格存储（Tablestore）服务。说明若目标服务为日志服务，可不开通函数计算服务。计费说明事件总线目前处于公测中，免费使用。函数计算的计费说明，请参见计费概述。权限...

降低实例配置

说明为了避免因带宽不足触发网络限制，云消息队列 Kafka 版会根据您选择的实例规格，评估出最佳带宽大小，请您根据界面提示，按一定倍数购买公网流量。降低后的分区数量不能低于实际使用的分区数量。在专业版（高写版）/专业版（高读版）...

创建前提

例如，创建Tablestore Sink Connector，请先开通表格存储（Tablestore）服务。说明若目标服务为SLS Sink Connector，可不开通函数计算服务。权限策略阿里云账号：在控制台创建Connector时，控制台会弹出详细授权策略，按照控制台提示确认...

数据传输服务DTS

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

迁移消费者程序

本文介绍如何将自建Kafka集群上的消费者程序平滑地迁移到云消息队列 Kafka 版。背景信息云消息队列 Kafka 版控制台提供迁移实例功能，您可以使用该功能将自建Kafka集群或其他云Kafka集群的元数据（Topic和Group配置信息）和消息数据同步...

标签管理

例如，云消息队列 RocketMQ 版实例先添加了 city:shanghai 标签，后续如需添加 city:shenzhen 标签，需先删除 city:shanghai 标签。您可以参见标签最佳实践了解设计标签键值的建议。使用限制键（Key）的最大长度：64个Unicode字符，...

DeleteCaCertificate-删除CA证书

云消息队列 MQTT 版支持X.509证书认证，客户端可通过设备证书完成接入认证。CA证书用于为客户端签发设备证书，并验证设备证书的正确性。使用CA证书需要先将证书注册到云消息队列 MQTT 版服务端，若您不再需要使用某个CA证书，您可以调用...

CreateInstance-创建实例

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

实例管理

实例是用于云消息队列 MQTT 版服务的虚拟机资源，会存储消息主题（Topic）和客户端ID（Group ID）信息。按照计费方式，云消息队列 MQTT 版提供包年包月（预付费）计费模式的实例。实例规格分为企业铂金版、标准版和专业版。使用限制 ...

定时/延时消息

基于云消息队列 RocketMQ 版的定时消息可以封装出多种类型的定时触发器。典型场景二：任务超时处理以电商交易场景为例，订单下单后暂未支付，此时不可以直接关闭订单，而是需要等待一段时间后才能关闭订单。使用云消息队列 RocketMQ 版...

OnsDLQMessageResendById-重发指定的死信消息

由于死信消息是经过重试逻辑依然消费失败的消息，通常意味着消费逻辑可能存在问题，故请先查明多次消费失败的原因，再调用本接口重新发送。当前消息队列 RocketMQ 版不管理死信重发的状态，重发后消费成功的消息不会从死信队列中移除。需...

消费者分类

如下图所示，SDK内置了一个长轮询线程，先将消息异步拉取到SDK内置的缓存队列中，再分别提交到消费线程中，触发监听器执行本地消费逻辑。可靠性重试 PushConsumer消费者类型中，客户端SDK和消费逻辑的唯一边界是消费监听器接口。客户端SDK...

消息堆积和延迟问题

本文主要介绍云消息队列 RocketMQ 版 TCP协议的Java客户端使用过程中，经常会出现的消息堆积和消息延迟的问题。通过了解云消息队列 RocketMQ 版客户端的消费原理和消息堆积的主要原因，帮助您可以在业务部署前更好的规划资源和配置，或...

如何处理不活跃的Topic

详细信息请先判断Topic的活跃状况，对于不活跃的Topic，您可以考虑进行删除，具体步骤如下。判断Topic的活跃状况判断Topic是否活跃主要依靠下列2个关键指标。当前服务器上消息总量（TotalCount）消息最后更新时间（LastTimeStamp）一般...

通过RAM角色实现跨云账号授权

STS Token配置示例初始化云消息队列 RocketMQ 版的客户端时，您只需将获取到的AccessKey ID、AccessKey Secret和SecurityToken填入到以下属性中即可：Properties properties=new Properties();请确保环境变量ALIBABA_CLOUD_ACCESS_KEY_...

RegisterCaCertificate-注册CA证书

云消息队列 MQTT 版支持X.509证书认证，客户端可通过设备证书完成接入认证。CA证书用于为客户端签发设备证书，并验证设备证书的正确性，您需要先将申请的CA证书注册到云消息队列 MQTT 版的服务端上，才能用于认证设备证书。本接口用于将...

Topic管理

根据MQTT协议，Topic存在多级，定义第一级Topic为父级Topic，在使用云消息队列 MQTT 版前，需先创建该父级Topic资源。注意事项 Topic不能跨实例使用，例如不能使用实例B的接入点订阅创建在实例A中的Topic。Topic名称长度限制为3~64个字符...

实例生命周期管理

预付费（包年包月）实例预付费（包年包月）实例生命周期各阶段状态部署实例（1→2）：当购买了云消息队列 Kafka 版实例后，实例处于未部署状态，若您需要使用该实例，请先在控制台上完成部署，部署成功后，实例状态切换为服务中。...

客户端连接常见问题

根据MQTT协议，Topic存在多级，定义第一级Topic为父级Topic，使用云消息队列 MQTT 版前，需先在控制台创建该父级Topic，可以在云消息队列 MQTT 版控制台创建，或者直接在云消息队列 RocketMQ 版的控制台创建。子级Topic（Subtopic）...

将云消息队列 Kafka 版的数据迁移至MaxCompute

本文介绍如何使用DataWorks数据同步功能，将云消息队列 Kafka 版集群上的数据迁移至阿里云大数据计算服务MaxCompute，方便您对离线数据进行分析加工。前提条件在开始本教程前，确保您在同一地域中已完成以下操作：云消息队列 Kafka 版 ...

先入先出队列如何安装

新品推荐