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

本地IDC通过专线使用消息队列RocketMQ版处理消息

本文为您介绍本地IDC如何通过物理专线访问云上消息队列RocketMQ版，实现本地IDC使用消息队列RocketMQ版收发并处理消息。背景信息本文以下图场景为例，某企业在阿里云华北2（北京）地域部署了专有网络VPC（Virtual Private Cloud）和交换机...

如何快速使用消息队列RocketMQ版的TCP Java SDK收发...

本文提供使用 消息队列RocketMQ版的TCP Java SDK收发消息的快速入门视频。

如何快速使用消息队列RabbitMQ版的Java SDK收发消息

本文提供使用云消息队列 RabbitMQ 版的Java SDK收发消息的快速入门视频。

如何快速使用微消息队列MQTT版的Java SDK收发消息？

本文提供使用微消息队列MQTT版的Java SDK收发消息的快速入门视频。

如何快速使用云消息队列 Kafka 版的Java SDK收发消息

六分钟上手云消息队列 Kafka 版。文档教程快速入门

使用云消息队列 Kafka 版时出现消息堆积

使用云消息队列 Kafka 版时，可能会发现Group中出现消息堆积。本文介绍如何判断消息堆积是否属于正常情况，以及处理方法。客户端消费流程了解客户端消费流程，有助于理解消息是否堆积。一般情况下，客户端消费流程大致如下：判断消息...

使用云消息队列 Kafka 版时客户端的报错及解决方案

在使用云消息队列 Kafka 版时，客户端可能报错，您可以根据报错消息匹配对应的解决方案。详细信息报错信息对应的详细信息如下。报错信息客户端语言类型报错原因解决方案 TimeoutException Java 网络问题客户端鉴权（sasl.mechanisms）...

使用云消息队列 Kafka 版时出现“Not authorized to ...

问题描述使用云消息队列 Kafka 版时出现“Not authorized to access group”的错误信息。问题原因没有创建Consumer Group时会遇到此报错信息。解决方案您可以选择如下任意一种方式创建Consumer Group。在云消息队列 Kafka 版的控制台...

使用Debezium将PostgreSQL数据同步至消息队列Kafka版

本文介绍如何创建Debezium PostgreSQL Source Connector，将PostgreSQL的数据同步至云消息队列 Kafka 版。使用限制 Debezium PostgreSQL Source Connector只能配置一个Task用于消费源端的CDC数据，不支持并发消费配置。前提条件开通事件...

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

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

使用Kafka Connect将MySQL数据同步至云消息队列 Kafka...

本教程介绍如何使用Kafka Connect的Source Connector将MySQL的数据同步至云消息队列 Kafka 版。背景信息 Kafka Connect主要用于将数据流输入和输出云消息队列 Kafka 版。Kafka Connect主要通过各种Source Connector的实现，将数据从第三...

使用Kafka Connect将SQL Server数据同步至云消息队列 ...

本教程介绍如何使用Kafka Connect的Source Connector将SQL Server的数据同步至云消息队列 Kafka 版。前提条件在开始本教程前，请确保您已完成以下操作：已下载SQL Server Source Connector。具体信息，请参见 SQL Server Source ...

使用Debezium将PostgreSQL数据同步至消息队列Kafka版

本文介绍如何创建Debezium PostgreSQL Source Connector，将PostgreSQL的数据同步至云消息队列 Kafka 版。使用限制 Debezium PostgreSQL Source Connector只能配置一个Task用于消费源端的CDC数据，不支持并发消费配置。前提条件开通事件...

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

本文介绍如何创建Debezium MySQL Source Connector，将MySQL的数据同步至云消息队列 Kafka 版。前提条件已开通事件总线EventBridge并授权。已开通对象存储OSS服务并创建存储空间（Bucket）。更多信息，请参见控制台创建存储空间。已开通...

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

本文介绍如何创建Debezium MySQL Source Connector，将MySQL的数据同步至云消息队列 Kafka 版。前提条件已开通事件总线EventBridge并授权。已开通对象存储OSS服务并创建存储空间（Bucket）。更多信息，请参见控制台创建存储空间。已开通...

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

使用消息队列RocketMQ版消费端来处理MQTT客户端的上下线通知时，订阅的Topic为上下线通知Topic。final String parentTopic="GID_XXXX_MQTT;客户端状态数据，实际生产环境中建议使用数据库或者Redis等外部持久化存储来保存该信息，避免应用...

操作链路概述

创建工作空间要使用消息队列，您需要确保 SOFAStack 控制台已创建至少一个工作空间。如 SOFAStack 未创建工作空间或您需要创建一个新的工作空间，可参见添加工作空间。创建好工作空间后，将为您自动创建一个消息队列实例。创建 Topic ...

MQTT快速入门

现阶段要求每个云消息队列 MQTT 版实例（网关实例）必须绑定一个存储实例（云消息队列 RocketMQ 版实例）使用。消息存储实例目前只支持云消息队列 RocketMQ 版类型的后端存储实例。目前您在同一个地域（Region）可以创建有限数量的云...

使用限制

本文为您介绍云消息队列 MQTT 版对某些具体指标的约束和规范，您在使用云消息队列 MQTT 版时请不要超过相应的限制值，以免程序出现异常。具体的限制项和限制值请参见下表。如果您购买了铂金版的云消息队列 MQTT 版实例，则可按需定制...

快速入门概述

本文为您介绍如何快速使用云消息队列 RocketMQ 版实现消息收发。使用流程快速使用云消息队列 RocketMQ 版收发消息的流程如下图所示。使用说明权限说明若您的账号为RAM用户，则必须先为该RAM用户进行授权，才能访问云消息队列 ...

常见问题

本文汇总了使用云消息队列 RocketMQ 版时的常见问题。产品功能常见问题云消息队列 RocketMQ 版5.0系列相比4.0系列实例有什么优势？云消息队列 RocketMQ 版5.0系列实例兼容哪些版本客户端？云消息队列 RocketMQ 版支持哪些语言客户端？云...

使用限制

云消息队列 Kafka 版对某些具体指标进行了约束和规范，您在使用云消息队列 Kafka 版时注意不要超过相应的限制值，以免程序出现异常。重要若由于您的实例配置超出使用限制导致的任何不稳定情况，不在SLA承诺和赔偿范围内。云消息队列 ...

使用ACL功能进行访问控制

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

Spring集成

云消息队列 RocketMQ 版支持集成Spring框架的Java SDK收发消息，本文为您介绍如何使用云消息队列 RocketMQ 版提供的Spring框架的Demo工程。背景信息云消息队列 RocketMQ 版支持以下消息类型的生产者和消费者与Spring集成：普通消息的...

迁移Topic上云

本文介绍如何使用云消息队列 Kafka 版提供的迁移工具将自建Kafka集群的Topic迁移到云消息队列 Kafka 版实例。前提条件您已完成以下操作：下载JDK 8 下载迁移工具kafka-migration-assessment.jar 购买并部署云消息队列 Kafka 版实例...

签名鉴权模式

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

消费者分组（ConsumerGroup）

本文介绍云消息队列 RocketMQ 版中消费者分组（ConsumerGroup）的定义、模型关系、内部属性、行为约束、版本兼容性及使用建议。定义消费者分组是云消息队列 RocketMQ 版系统中承载多个消费行为一致的消费者的负载均衡分组。和消费者...

消息收发功能

本文提供单独使用云消息队列 MQTT 版收发消息以及与云消息队列 RocketMQ 版结合使用时需使用的代码示例的链接。单独使用云消息队列 MQTT 版收发消息语言链接 Java ...

资源使用变更

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

P2P消息收发模式（MQTT）

本文介绍P2P模式的概念、原理以及如何使用云消息队列 MQTT 版点对点收发消息。什么是P2P模式 P2P，顾名思义，是一对一的消息收发模式，即只有一个消息发送者和一个消息接收者。而Pub/Sub模式通常用于一对多或多对多的消息群发场景，即...

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

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

快速入门概述

本文为您介绍快速使用云消息队列 RabbitMQ 版进行消息收发的操作流程。操作流程后续步骤步骤一：（可选）RAM用户授权步骤二：创建资源步骤三：调用SDK收发消息

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

本文以Windows系统为例，介绍如何使用MQTT.fx模拟SDK接入云消息队列 MQTT 版并进行消息收发。前提条件下载并安装 MQTT.fx。背景信息云消息队列 MQTT 版最简单的使用场景即MQTT客户端消息的自发自收。如下图所示，您可以使用MQTT.fx...

云端开发概述

本文介绍云消息队列 MQTT 版提供的云端SDK和管控SDK的使用场景。使用说明使用云消息队列 MQTT 版的云端SDK收发消息时，需要和终端SDK搭配使用。例如，使用云端SDK发送消息，终端SDK接收消息；或使用终端SDK发送消息，云端SDK接收消息...

使用限制

云消息队列 RabbitMQ 版对集群、接口调用以及字符进行了限制，您在使用云消息队列 RabbitMQ 版时注意不要超过相应的限制值，以免程序出现异常。集群限制限制项 Serverless版专业版企业版铂金版单实例的Vhost数量 200 单实例的Vhost...

获取SDK

本文介绍如何获取和使用云消息队列 RabbitMQ 版多语言SDK。SDK下载云消息队列 RabbitMQ 版的多语言SDK的下载地址及说明文档如下。语言下载地址说明文档 Java Alibaba Cloud AMQP SDK for Java 开始使用 Go Alibaba Cloud AMQP SDK ...

JMS概述

本文介绍云消息队列 RabbitMQ 版 JMS库的相关概念、获取方式、使用限制和使用教程。背景信息 JMS是一种消息传递标准，允许基于Java EE（Java平台企业版）的应用程序组件创建、发送、接收、读取消息。JMS使分布式应用能够以松耦合、可靠、...

迁移Group上云

本文介绍如何使用云消息队列 Kafka 版提供的迁移工具将自建Kafka集群的 Group 迁移到云消息队列 Kafka 版实例。前提条件您已完成以下操作：下载JDK 8 下载迁移工具kafka-migration-assessment.jar 购买并部署云消息队列 Kafka 版 ...

MQTT客户端上下线事件数据流出

本文介绍客户端上下线通知的原理、应用场景、使用限制以及云消息队列 MQTT 版与其他阿里云产品的资源映射关系。基本原理在客户端上线和下线事件触发时，MQTT服务器会根据您配置的客户端上下线通知规则，向后端其他云产品推送一条上下线...

使用实例接入点收发消息

当使用应用程序与Kafka集群建立连接时，可通过实例接入点接入云消息队列 Kafka 版并收发消息。Kafka实例提供默认接入点、SSL接入点和SASL接入点，以满足您不同的连接和安全需求。默认接入点适用于在保密性较高的VPC环境收发消息；SASL接...

消息队列如何使用

新品推荐