阿里云mq查看队列消息如何使用-阿里云mq查看队列消息如何使用文档介绍内容-阿里云

HTTP SDK错误码列表

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

API概览

StartInstance 部署实例如需使用云消息队列 Kafka 版收发消息，需要购买并部署才可使用，本文介绍如何调用StartInstance部署实例。ModifyInstanceName 修改实例的名称实例部署完成后，云消息队列 Kafka 版支持修改实例的名称。本文介绍...

消息过滤

使用云消息队列 RocketMQ 版的消息过滤功能，可以帮助消费者更高效地过滤自己需要的消息集合，避免大量无效消息投递给消费者，降低下游系统处理压力。云消息队列 RocketMQ 版主要解决的单个业务域即同一个主题内不同消息子集的过滤问题...

Demo工程

本文介绍云消息队列 MQTT 版的Demo工程，包含各种应用场景的使用指导，请参见程序源码的文档注释进行理解。获取多语言Demo 示例代码全集请参见 mqtt-demo。下载完成后解压即可看到本地新增了 mqtt-demo-main 文件夹。其中一级文件夹是...

环境准备

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

权限策略

mq:QueryMqttMsgTransTrend 根据Topic查询消息的收发报表 mq:SendMqttMessageByConsole 控制台发消息测试控制台Group ID操作权限 Group ID的命名格式因云消息队列 MQTT 版实例是否有命名空间而异：有命名空间：acs:mq:*:*:{...

Serverless版实例计费

云消息队列 MQTT 版的Serverless实例购买成功后，默认为您预留固定规格的资源，若实际使用量超过预留规格，则按照实际使用量弹性计费，可以帮助您提高资源利用率并降低业务成本。重要 Serverless版实例购买后，无论是否使用实例都会开始按...

Demo工程

本文介绍云消息队列 MQTT 版的Demo工程，包含各种应用场景的使用指导，请参见程序源码的文档注释进行理解。获取多语言Demo 示例代码全集请参见 mqtt-demo。下载完成后解压即可看到本地新增了 mqtt-demo-main 文件夹。其中一级文件夹是...

鉴权概述

本文主要介绍云消息队列 MQTT 版客户端鉴权的原理和分类，以便您使用相应的鉴权功能。鉴权原理使用云消息队列 MQTT 版的客户端收发消息时，服务端会根据MQTT客户端设置的UserName和Password参数来进行鉴权。针对不同的权限验证场景，...

环境准备

重要推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为主力研发版本，和云消息队列 RocketMQ 版 5.x服务端完全兼容，提供了更全面的功能并支持更多增强特性。更多信息，请参见 5.x系列SDK。RocketMQ 4.x/3.x系列SDK和ONS系列SDK后续...

Topic管理

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

资源使用变更

云消息队列 MQTT 版从V2.x.x升级至V3.x.x实现了自身数据存储的能力，同时还去除了对云消息队列 RocketMQ 版的消息依赖，因此，云消息队列 MQTT 版的实例和Topic使用有变更。资源 V2.x.x使用说明 V3.x.x使用说明云消息队列 MQTT 版 ...

删除Group后仍然收到消息堆积的告警信息

问题现象使用阿里云云消息队列 Kafka 版时，删除 Group 后，仍然收到消息堆积的告警信息。可能原因发生消息堆积告警信息的原因如下：2.0.0以前的Kafka服务端版本，开源Kafka未提供删除 Group 和消费位点的OpenAPI，因此删除 Group，...

Workers

使用云消息队列 Kafka 版提供默认值的配置项：plugin.path rest.advertised.port topic.creation.enable listeners 不会传输至Kafka Connect的配置项。sasl.*ssl.*security.*rest.advertised.host.name rest.advertised.listener rest....

为什么不推荐使用Sarama Go客户端收发消息？

问题现象所有Sarama Go版本客户端存在...如果发生了位点重置，产生大量堆积，您可以使用云消息队列 Kafka 版控制台提供的重置消费位点功能，手动重置消费位点到某一时间点，无需改代码或换Consumer Group。具体操作，请参见重置消费位点。

实例管理

实例运维实例运行期间，您可以查看实例的数据统计信息，包括消息收发TPS、订阅关系数和客户端连接数，还可以设置实例报警，实时监控实例使用情况。查看实例的数据统计登录云消息队列 MQTT 版控制台，在顶部菜单栏选择实例所在地域。在...

QueryMqttTraceMessagePublish-查询消息发送轨迹

查询指定消息的发送轨迹。...变更历史变更时间变更内容概要操作暂无变更历史控制台操作除了调用 QueryMqttTraceMessagePublish 接口，您还可以通过微消息队列 MQTT 版控制台查看消息的发送轨迹。具体操作，请参见消息轨迹查询。

查询消息轨迹

当消息收发结果不符合预期或您需要对特定消息进行追踪时，您可通过查看消息轨迹获取指定消息在各个环节的处理状态。消息轨迹数据云消息队列 RocketMQ 版系统中，一条消息的完整链路包含生产者、服务端、消费者三个角色，每个角色处理消息...

使用AMQProxy解决PHP等客户端Connection复用问题

前提条件如果您要使用SSL连接AMQProxy和云消息队列 RabbitMQ 版，请确保您的客户端服务器已安装OpenSSL。更多信息，请参见 Downloads。重要 VPC环境下不支持使用SSL连接云消息队列 RabbitMQ 版。背景信息部分语言的客户端，例如PHP客户...

微消息队列MQTT版

本文介绍如何在云消息队列 RocketMQ 版控制台创建流入源为云消息队列 MQTT 版的消息流入任务。前提条件您已购买云消息队列 RocketMQ 版实例，且实例处于服务中状态。具体步骤，请参见创建资源。您已创建云消息队列 MQTT 版实例...

数据流入规则管理

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

新功能发布记录

新增开服地域服务接入点 2022-05-25 功能名称功能描述功能类型相关文档消息轨迹支持在云消息队列 RabbitMQ 版控制台查看消息轨迹。支持在云消息队列 RabbitMQ 版控制台实例详情页面查看秒级峰值TPS。新增实例管理消息轨迹 ...

数据流出规则管理

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

什么是消息队列RabbitMQ版？

云消息队列 RabbitMQ 版是一款基于高可用分布式存储架构实现的AMQP 0-9-1协议的消息产品。云消息队列 RabbitMQ 版兼容开源RabbitMQ客户端，解决开源各种稳定性痛点（例如消息堆积、脑裂等问题），同时具备高并发、分布式、灵活扩缩容等云...

领域模型概述

产品定位云消息队列 RocketMQ 版是一款典型的分布式架构下的中间件产品，使用异步通信方式和发布订阅的消息传输模型。通信方式和传输模型的具体说明，请参见下文通信方式介绍和消息传输模型介绍。云消息队列 RocketMQ 版产品具备异步...

上下线通知规则管理

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

消息存储和清理机制

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

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

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

消息队列RocketMQ版

本文介绍如何在云消息队列 RocketMQ 版控制台创建流出目标为云消息队列 RocketMQ 版的消息流出任务。前提条件您已购买云消息队列 RocketMQ 版实例，且实例处于服务中状态。具体步骤，请参见创建资源。创建消息流出任务登录云...

消息队列Kafka版

本文介绍如何在云消息队列 RocketMQ 版控制台创建流入源为云消息队列 Kafka 版的消息流入任务。前提条件您已购买云消息队列 RocketMQ 版实例，且实例处于服务中状态。具体步骤，请参见创建资源。您已购买并部署云消息队列 Kafka...

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

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

云消息队列 RabbitMQ 版系统权限策略参考

查看策略详情服务关联角色策略 AliyunServiceRolePolicyForAMQPNetwork 云消息队列 RabbitMQ 版使用服务关联角色 AliyunServiceRoleForAMQPNetwork 来访问您在其他云产品中的资源。AliyunServiceRolePolicyForAMQPNetwork 是 ...

云消息队列 RocketMQ 版

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

消息队列RabbitMQ版

本文介绍如何在云消息队列 RocketMQ 版控制台创建流出目标为云消息队列 RabbitMQ 版的消息流出任务。前提条件您已购买云消息队列 RocketMQ 版实例，且实例处于服务中状态。具体步骤，请参见创建资源。您已购买并部署云消息队列 ...

云消息队列 MQTT 版

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

消息队列Kafka版

本文介绍如何在云消息队列 RocketMQ 版控制台创建流出目标为云消息队列 Kafka 版的消息流出任务。前提条件您已购买云消息队列 RocketMQ 版实例，且实例处于服务中状态。具体步骤，请参见创建资源。您已购买并部署云消息队列 ...

快速使用MQTT的Java SDK收发消息（终端和云端消息收发...

本文介绍如何快速使用云消息队列 MQTT 版的Java SDK实现MQTT终端和云端服务的消息收发。前提条件创建资源获取AccessKey 安装 IDE。您可以使用IntelliJ IDEA或者Eclipse，本文以IntelliJ IDEA为例。下载安装 JDK。背景信息 MQTT终端和...

创建RocketMQ Source Connector

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

创建RabbitMQ Sink Connector

本文介绍如何在云消息队列 Kafka 版控制台创建消息流出任务，将云消息队列 Kafka 版的数据导出至云消息队列 RabbitMQ 版。前提条件您已购买并部署云消息队列 Kafka 版实例，且实例处于服务中状态。具体步骤，请参见步骤二：购买和...

MQTT和RocketMQ进行数据互通（跨产品数据流出）

如果您的云端应用需要使用云消息队列 RocketMQ 版产品的某些功能，例如顺序消息特性、事务消息特性等，您可以通过消息流入或流出规则将云消息队列 MQTT 版和云消息队列 RocketMQ 版数据进行流转。本文介绍如何将云消息队列 MQTT 版 ...

阿里云mq查看队列消息如何使用

新品推荐