主动队列管理算法怎么用-主动队列管理算法怎么用文档介绍内容-阿里云

管理资源队列

在左侧导航栏，单击 队列管理。单击添加队列。填写队列名称和资源量。配置说明队列名称队列名称不可重复，只允许小写字母、数字和中划线（-）且长度不超过32位。说明资源队列添加成功后，不可修改资源队列名称。资源量（CU）允许...

管理队列

本文介绍如何使用队列分组管理计算节点，包括创建和删除队列，以及在队列之间移动节点。背景信息创建集群时会自动创建一个默认队列，计算节点默认会加入到该队列中。操作步骤打开节点与队列页面。登录弹性高性能计算控制台。在顶部...

YARN调度器

主要特性 CapacityScheduler具备如下的特性：多级队列（树形结构）：支持多级租户管理，父队列资源配额能够限制其下所有子队列的资源使用，单个子队列的资源配额也不能超过父队列的资源配额，因此对于多租户管理具备较高的可控性，能够满足...

消息存储和清理机制

消息在队列中的存储情况如下：消息存储管理粒度说明云消息队列 RocketMQ 版按照服务端节点粒度管理存储时长而非队列或主题，原因如下：消息存储优势权衡：云消息队列 RocketMQ 版基于统一的物理日志队列和轻量化逻辑队列的二级组织方式...

消费重试

消费者出现异常，云消息队列 RocketMQ 版会根据消费重试策略重新投递该消息进行故障恢复。本文介绍消费重试的应用场景、原理机制、版本兼容性和使用建议。应用场景云消息队列 RocketMQ 版的消费重试主要解决的是业务处理逻辑失败导致的...

MQTT与RocketMQ的消息结构映射

本文针对使用云消息队列 RocketMQ 版 SDK与云消息队列 MQTT 版交互的场景，提供交互中所涉及的消息结构和属性字段的映射关系，方便您更好的理解和组合使用这两个产品。云消息队列 MQTT 版是一款面向移动端的网关产品，可通过数据互通...

SDK概述

云消息队列 Kafka 版使用SCRAM-SHA-256加密算法实现身份校验，比PLAIN机制安全性更高，同样支持不重启实例的情况下动态增加SASL用户。关于接入点的详细信息，请参见接入点对比。Demo使用说明根据购买的实例信息选择Demo文件，通过配置后...

开通服务并授权

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

操作指南

您可以在云消息队列 Kafka 版控制台创建实例、...云消息队列 Kafka 版 V3系列Serverless实例管理 V2系列实例管理 Topic Group Connector生态集成迁移权限管理云消息队列 Confluent 版集群资源规格评估实例管理权限管理集群配置与使用

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

MQTT.fx是一款基于Eclipse Paho、使用Java语言编写的MQTT客户端。支持Windows、Mac和Linux操作系统，可用于验证设备是否可以连接云消息队列 MQTT 版，并通过Topic发布和订阅消息。本文以Windows系统为例，介绍如何使用MQTT.fx模拟SDK接入 ...

接入点对比

云消息队列 Kafka 版使用SCRAM-SHA-256加密算法实现身份校验，比PLAIN机制安全性更高，同样支持不重启实例的情况下动态增加SASL用户。SSL（Secure Sockets Layer）：用以保障数据传输过程的安全，采用数据加密技术，防止数据在网络传输...

配置消息日志

您可以使用云消息队列 RabbitMQ 版的日志管理功能将云消息队列 RabbitMQ 版实例的消息操作日志推送到日志服务。当消息的发送、消费、确认出现异常时，您可在日志服务查询并分析消息的操作日志，进行异常诊断。前提条件创建云消息队列...

步骤一：（可选）RAM用户授权

RAM用户默认没有云消息队列 RocketMQ 版资源的操作权限。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能通过控制台或OpenAPI管理云消息队列 RocketMQ 版的资源。背景信息本操作仅针对RAM用户，若您的账号为阿里云账号，则默认...

创建前提

AliyunKafkaFullAccess：管理云消息队列 Kafka 版的权限。AliyunFCFullAccess：管理函数计算FC（Function Compute）的权限。AliyunEventBridgeFullAccess：管理事件总线EventBridge 的权限。目标服务的管理权限。除上述必要权限外，如...

开通消息队列服务并授权

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

开通消息队列服务并授权

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

集成概述

本文介绍Connector生态集成的计费说明、产品功能、使用限制以及基本概念等信息。背景信息企业在向数字化转型的过程中，往往会遇到诸多挑战。例如，缺少统一的信息集成途径；数据格式类型多样，给传输和集成带来不便；缺少分享数据和后端...

HTTP SDK错误码列表

本文介绍使用云消息队列 RocketMQ 版提供的商业版HTTP协议的SDK收发消息时可能遇到的错误码，以及建议的处理方式。错误码错误描述 HTTP状态码建议处理方式 AccessDenied The OwnerId that your Access Key Id associated to is ...

消息收发流程变更

云消息队列 MQTT 版 V2.x.x版本强依赖云消息队列 RocketMQ 版作为消息存储，因此云消息队列 MQTT 版消息和云消息队列 RocketMQ 版天然打通，创建了Topic后即可天然使用云消息队列 RocketMQ 版和云消息队列 MQTT 版的SDK相互通信...

创建资源

在调用TCP协议的SDK收发消息前，您需在云消息队列 RocketMQ 版控制台创建相关资源。您在调用SDK时需填写这些资源信息。前提条件开通消息队列服务并授权背景信息针对TCP和HTTP两种通信协议，云消息队列 RocketMQ 版分别提供了多语言...

创建资源

网络访问限制在使用云消息队列 RocketMQ 版时，请注意以下网络访问限制：只有在同一个地域下的同一个实例中的Topic和Group ID才能互通，例如，某Topic创建在华东1（杭州）地域的实例A中，那么该Topic只能被在华东1（杭州）地域的实例A...

退款说明

本文介绍了云消息队列 Kafka 版支持的退款情况。根据计费方式的特点，云消息队列 Kafka 版资源支持的退款情况如下：包年包月的云消息队列 Kafka 版资源如需退款，可在控制台上退订实例。详细信息，请参见实例生命周期管理。按量计费...

RAM鉴权

微消息队列MQTT版权限管理是通过阿里云的访问控制RAM（Resource Access Management）产品实现的。使用RAM可以让您避免与其他用户共享云账号密钥，即AccessKey（包含AccessKeyId和AccessKeySecret），按需为用户分配最小权限。在使用RAM账号...

基本概念

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

Topic使用变更

变更说明由于V3.x.x版本的云消息队列 MQTT 版实现了自身的消息存储，因此所有的云消息队列 MQTT 版 Topic资源都需要在云消息队列 MQTT 版控制台或调用其OpenAPI进行管理。云消息队列 MQTT 版的Topic资源不再和云消息队列 RocketMQ ...

步骤一：（可选）RAM用户授权

RAM用户默认没有云消息队列 RabbitMQ 版资源的操作权限。如果您的账号为RAM用户，必须先为RAM用户进行授权，才能拥有云消息队列 RabbitMQ 版资源的操作权限和消息收发权限。背景信息本操作仅针对RAM用户，若您的账号为阿里云账号，则...

Control Center基本使用

Control Center是云消息队列 Confluent 版的核心管理服务，提供了一个可视化的监控平台。本文介绍Control Center平台上的基本操作。登录Control Center 创建云消息队列 Confluent 版集群，详情请参见购买和部署实例。在云消息队列 ...

订阅消息

Pull：消息由Consumer主动从云消息队列 RocketMQ 版拉取。Pull Consumer提供了更多接收消息的选择。相比于Push Consumer，您可以使用Pull Consumer更加自由地控制消息拉取。具体的接口信息请参见接口和参数说明。重要如需使用Pull ...

接口和参数说明

云消息队列 RocketMQ 版提供Java SDK实现消息发送与订阅，订阅方可通过Push或Pull的方式从云消息队列 RocketMQ 版获取消息。本文介绍消息发送和订阅的接口和参数说明。背景信息云消息队列 RocketMQ 版支持以下两种消息获取方式：Push...

RAM鉴权

云消息队列 MQTT 版权限管理是通过阿里云的访问控制RAM（Resource Access Management）产品实现的。使用RAM可以让您避免与其他用户共享云账号密钥，即AccessKey（包含AccessKey ID和AccessKey Secret），按需为用户分配最小权限。在使用...

Dashboard

借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力，云消息队列 RabbitMQ 版为企业版和铂金版实例提供Dashboard大盘功能。通过该功能，您可以查看企业版和铂金版实例、Vhost、Queue和Exchange的各种指标数据，帮助您及时...

功能特性

Kafka商业模式功能集功能功能描述参考文档 Serverless版本升降配管理在云消息队列 Kafka 版控制台完成实例升配或降配，配置项包括规格类型、实例类型、发送能力预留和订阅能力预留等。升级实例配置降低实例配置弹性策略 V3系列...

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

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

欠费说明

若您在停服后7天内未完成续费，阿里云将主动释放您在云消息队列 MQTT 版上创建的实例，并且删除您实例下创建的Topic与Group ID，被释放的实例以及资源均不可恢复。按量付费实例欠费说明重要云消息队列 MQTT 版已不再售卖按量付费实例...

客户端证书认证

控制台操作服务器证书管理：支持将购买或自签的服务器证书托管到数字证书管理服务，并使用服务器证书初始化云消息队列 MQTT 版实例。CA证书管理：支持注册CA证书、修改CA证书状态和删除CA证书。设备证书管理：支持查询设备证书、修改...

签名鉴权模式

如果您需使用云消息队列 MQTT 版的签名鉴权模式，可根据本文提供的签名计算方式获取签名，再使用控制台来验证计算得出的签名是否正确。签名计算方式按照鉴权概述的描述，如果选择签名校验模式，MQTT客户端实际连接MQTT消息服务器时，...

消费进度管理

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

使用ACL功能进行访问控制

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

设置全局YARN资源队列

在DataWorks中，您可按照工作空间粒度指定各模块使用的YARN队列，后续各模块将默认使用该队列执行EMR任务。同时，可定义全局YARN资源队列优先级是否高于指定模块内配置的YARN资源队列优先级。本文为您介绍如何设置全局YARN资源队列。背景...

ACL授权

本文介绍如何在云消息队列 Confluent 版上实现ACL授权。背景信息 ACL的全称是Access Control Lists，指访问控制列表。这种授权方式比RBAC授权粒度更细。ACL授权主要有两种方式：通过云消息队列 Confluent 版控制台实现ACL授权。本文...

主动队列管理算法怎么用

新品推荐