队列操作方法-队列操作方法文档介绍内容-阿里云

将云消息队列 Kafka 版接入阿里云Elasticsearch

将云消息<em>队列</em> Kafka 版接入阿里云Elasticsearch

本文介绍将云消息队列 Kafka 版接入阿里云Elasticsearch的操作方法。前提条件在开始本教程前，请确保您已完成以下操作：购买并部署云消息队列 Kafka 版实例。具体信息，请参见 VPC接入。创建阿里云Elasticsearch实例。具体信息，请...

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

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

队列（MessageQueue）

流式操作语义云消息队列 RocketMQ 版基于队列的存储模型可确保消息从任意位点读取任意数量的消息，以此实现类似聚合读取、回溯读取等特性，这些特性是RabbitMQ、ActiveMQ等非队列存储模型不具备的。模型关系在整个云消息队列 RocketMQ ...

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

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

怎样让Consumer不立即消费消息并使消息重入队列？

您可以通过basicReject或basicNack方法否定应答消息，使消息重入队列，从而是其他Consumer可以消费消息。使用basicReject方法否定应答单条消息并使消息重入队列您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。...

怎样让Consumer不立即消费消息并使消息重入队列？

您可以通过basicReject或basicNack方法否定应答消息，使消息重入队列，从而是其他Consumer可以消费消息。使用basicReject方法否定应答单条消息并使消息重入队列您可以使用basicReject方法实现Consumer否定应答单条消息并使其重入队列。...

MQTT和RocketMQ进行数据互通（客户端上下线通知）

MQTT客户端的上下线事件将会触发MQTT服务端生成一条通知消息，云消息队列 MQTT 版支持将该条消息数据导出至其他阿里云产品，并使用MQTT的Java SDK实现MQTT客户端与后端应用收发消息。本文以当前仅支持的云消息队列 RocketMQ 版数据互通...

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

解决方案企业A需要授予企业B的员工对云消息队列 RocketMQ 版的资源进行操作。假设企业A和企业B分别有一个阿里云账号A和阿里云账号B，需要完成以下操作完成企业A和企业B的跨云账号授权及资源访问。步骤一：创建RAM角色并授权阿里云账号A...

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

GroupID在云消息队列 MQTT 版控制台创建，具体操作，请参见步骤一：创建云消息队列 MQTT 版资源；DeviceID由用户自定义。GroupID、DeviceID以及clientId的取值规范，请参见客户端限制。取值示例如下：GID_test@device001。sampleClient...

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

解决方案企业A需要授予企业B的员工对云消息队列 RocketMQ 版的资源进行操作。假设企业A和企业B分别有一个阿里云账号A和阿里云账号B，需要完成以下操作完成企业A和企业B的跨云账号授权及资源访问：步骤一：创建RAM角色并授权阿里云账号A...

SDK FAQ

您可以使用basicReject方法否定应答单条消息，或者使用basicNack方法否定应答一条或多条消息，并使消息重入队列。使用basicReject方法否定应答消息并使消息重入队列参数说明 deliveryTag Channel的消息投递的唯一标识符。requeue 被否定...

通过原始日志快速分析和定位问题

本文介绍基于云消息队列 RabbitMQ 版当前日志快速查询和分析问题的方法。当您遇到消息不符合预期、消费异常、消息堆积时，通过该方法可以帮助您高效识别出异常、保证业务正常运行。前提条件推送云消息队列 RabbitMQ 版实例的消息操作...

队列控制台操作帮助

本文介绍在消息服务MNS 控制台上可以执行的队列模型相关操作。前提条件开通消息服务MNS并授权创建队列登录消息服务MNS控制台。在左侧导航栏，单击队列列表。在顶部菜单栏，选择地域。在队列列表页面，单击创建队列。在创建队列 ...

基于日志服务的日志说明

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

云消息队列 Kafka 版支持被审计的事件说明

云消息队列 Kafka 版已与操作审计服务集成，您可以在操作审计中查询操作云消息队列 Kafka 版产生的管控事件。操作审计支持将管控事件投递到日志服务SLS的LogStore或对象存储OSS的存储空间中，满足实时审计、问题回溯分析等需求。事件...

删除队列消息

本文介绍如何删除某个队列的所有消息。您可以使用Java客户端库中 queuePurge 方法删除某个队列的所有消息。示例代码如下：channel.queuePurge("queue-name");

管理队列

操作步骤打开节点与队列页面。登录弹性高性能计算控制台。在顶部菜单栏左上角处，选择地域。在左侧导航栏，选择资源管理>节点与队列。在集群列表中选择目标集群。在节点类型列表中选择计算节点。按照需要进行以下操作。创建新的...

查询TPS统计图表

本文介绍基于云消息队列 RabbitMQ 版当前日志快速查询TPS统计图表的方法。当您遇到TPS流量超限时，通过该方法可以及时查询秒级的TPS统计图表，帮助您高效识别出异常，保证业务正常运行。前提条件登录云消息队列 RabbitMQ 版控制台，将...

快速入门概述

具体操作步骤如下：开通服务并授权开通消息队列服务，并授予RAM用户操作云消息队列 MQTT 版资源的权限。创建资源在云消息队列 MQTT 版控制台创建实例、Topic和Group资源。调用SDK收发消息快速使用MQTT的Java SDK收发消息（终端和...

仪表盘

借助于阿里云ARMS Prometheus监控服务和Grafana的指标存储和展示能力，云消息队列 RocketMQ 版提供可实时进行数据统计的仪表盘功能。该功能可帮助您一站式、全方位、多维度地统计和观测指标，进而快速了解业务的运行状态。本文介绍仪表盘...

消息（Message）

本文介绍云消息队列 RocketMQ 版中消息（Message）的定义、模型关系、内部属性、行为约束及使用建议。定义消息是云消息队列 RocketMQ 版中的最小数据传输单元。生产者将业务数据的负载和拓展属性包装成消息发送到云消息队列 RocketMQ...

RAM跨云账号授权

背景信息企业A开通了云消息队列 Kafka 版，该企业需要企业B代为操作云消息队列 Kafka 版的资源，例如实例、Topic、Group。企业A的需求如下：企业A希望能专注于业务系统，仅作为云消息队列 Kafka 版所有者。企业A希望可以授权企业B来...

RAM跨云账号授权

背景信息企业A开通了云消息队列 RabbitMQ 版，该企业需要企业B代为操作云消息队列 RabbitMQ 版的资源，例如实例、Topic、Consumer Group。企业A的需求如下：企业A希望能专注于业务系统，仅作为云消息队列 RabbitMQ 版所有者。企业A...

使用Canal将MySQL的数据同步至云消息队列 Kafka 版

本教程介绍如何使用Canal将MySQL的数据同步至云消息队列 Kafka 版。背景信息 Canal的主要用途是基于MySQL数据库增量日志解析，提供增量数据订阅和消费。Canal伪装自己为MySQL Slave，向MySQL Master发送dump请求。MySQL Master收到dump...

企业铂金版生命周期管理

创建企业铂金版实例云消息队列 RocketMQ 版铂金版实例支持通过控制台创建，操作入口如下：在云消息队列 RocketMQ 版控制台的实例列表页面选择指定地域。在实例列表页选择创建实例，按照提示完成购买。实例版本：选择 4.0系列 ...

消息轨迹

操作步骤登录云消息队列 RabbitMQ 版控制台，然后在左侧导航栏选择实例列表。在实例列表页面的顶部菜单栏选择地域，然后在实例列表中，单击目标实例名称。在左侧导航栏，单击消息轨迹。在消息轨迹页面，选择需查询消息的Vhost，...

环境准备（v2.x.x）

本文介绍使用C++ SDK v2.x.x版本接入云消息队列 RocketMQ 版所需完成的准备工作、使用说明以及注意事项，以便后续使用C++ SDK收发消息。重要推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和云消息队列 RocketMQ ...

RAM主子账号授权

背景信息企业A开通了云消息队列 Kafka 版服务，该企业需要员工操作云消息队列 Kafka 版服务所涉及的资源，例如实例、Topic、Consumer Group。由于每个员工的工作职责不一样，需要的权限也不一样。企业A的需求如下：出于安全或信任的...

迁移概述

本文介绍将自建Kafka集群迁移到云消息队列 Kafka 版实例的优势、原理、方案架构、迁移工具和操作流程。迁移优势将自建Kafka集群迁移到云消息队列 Kafka 版实例的优势，请参见产品优势。迁移原理对于消息队列来说，如果要实现集群...

RAM主子账号授权

背景信息企业A开通了云消息队列 RabbitMQ 版服务，该企业需要员工操作云消息队列 RabbitMQ 版服务所涉及的资源，例如实例、Vhost、Queue和Exchange。由于每个员工的工作职责不一样，需要的权限也不一样。企业A的需求如下：出于安全或...

环境准备（v2.x.x）

本文介绍使用C++ SDK v2.x.x及以上版本接入云消息队列 RocketMQ 版所需完成的准备工作、使用说明以及注意事项，以便后续使用C++ SDK收发消息。使用前，请注意以下几点：本文仅针对C++ SDK v2.x.x及以上版本进行说明，若您需从当前使用的v...

收发定时消息和延时消息

建议您优先使用云上定时延时的方式，使用方法，请参考以下步骤。前提条件您已完成以下操作：下载4.5.2或以上版本的社区版 Java SDK。准备工作。获取阿里云访问密钥AccessKey ID和AccessKey Secret。更多信息，请参见创建AccessKey。发送...

概述

操作流程根据网络类型不同，快速入门的操作流程有所不同，详情请参见云消息队列 Kafka 版快速入门操作流程。图 1.云消息队列 Kafka 版快速入门操作流程操作步骤具体操作步骤如下：步骤一：获取访问授权步骤二：购买和部署实例 VPC接...

迁移数据上云

本文介绍如何使用MirrorMaker将自建Kafka集群的数据迁移到云消息队列 Kafka 版集群。前提条件您已完成以下操作：下载迁移工具MirrorMaker 迁移Topic上云背景信息 Kafka的镜像特性可实现Kafka集群的数据备份。实现这一特性的工具就是...

自动创建Topic

自动创建Topic是指当云消息队列 Kafka 版实例发送请求以获取不存在的Topic元数据时，例如向不存在的Topic发送生产请求，云消息队列 Kafka 版可以自动创建Topic。自动创建Topic适用于迁移上云场景或测试场景，无需手动重复创建Topic，...

签名机制

DATE：表示此次操作的时间，不能为空，目前只支持GMT格式，示例：Thu,07 Mar 2012 18:49:58 GMT。MQVersion：表示云消息队列 RocketMQ 版接口的版本号，当前版本即为2015-06-06。CanonicalizedResource：表示HTTP所请求资源的URI（统一...

消息查询

操作步骤登录云消息队列 RocketMQ 版控制台，在左侧导航栏，单击实例列表。在顶部菜单栏，选择地域，如华东1（杭州）。在实例列表页面，找到目标实例，在其操作列，单击更多，然后在下拉菜单中，选择消息查询。在消息查询页面...

开源RabbitMQ迁移上云

在使用开源RabbitMQ集群时，当您希望能够解决各种稳定性痛点（例如消息堆积、脑裂等问题）、实现高并发、分布式、灵活扩缩容时，您可以将开源RabbitMQ集群迁移至云消息队列 RabbitMQ 版，本文介绍迁移上云的前提条件、操作步骤、注意事项...

顺序消息

顺序消息为云消息队列 RocketMQ 版中的高级特性消息，本文为您介绍顺序消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景在有序事件处理、撮合交易、数据实时增量同步等场景下，异构系统间需要维持强一致的状态同步，...

查询消息

如果您对发送到云消息队列 RabbitMQ 版的消息有问题，您可以在控制台查询消息。云消息队列 RabbitMQ 版支持按Queue查询和按Message ID查询两种方式，前者适用于只知道消息发送到的Queue，不知道发送消息时设置的Message ID的模糊查询...

队列操作方法

新品推荐