开源消息队列Java实现-开源消息队列Java实现文档介绍内容-阿里云

消息收发流程变更

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

接口和参数说明

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

日志配置

Java SDK 1.7.8.Final及以上版本：默认支持，无需设置云消息队列 RocketMQ 版的Java SDK 1.7.8.Final已内置了日志实现，您无需在客户端应用中添加日志实现依赖即可打印云消息队列 RocketMQ 版的客户端日志。针对Java SDK 1.7.8.Final...

队列（MessageQueue）

本文介绍云消息队列 RocketMQ 版中队列（MessageQueue）的定义、模型关系、内部属性、版本兼容性及使用建议。定义队列是云消息队列 RocketMQ 版中消息存储和传输的实际容器，也是云消息队列 RocketMQ 版消息的最小存储单元。云消息...

日志配置

Java SDK 1.7.8.Final及以上版本：默认支持，无需设置云消息队列 RocketMQ 版的Java SDK 1.7.8.Final已内置了日志实现，您无需在客户端应用中添加日志实现依赖即可打印云消息队列 RocketMQ 版的客户端日志。针对Java SDK 1.7.8.Final...

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

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

消息收发功能

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

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

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

名词解释

在使用云消息队列 MQTT 版前，需理解该产品和MQTT协议所涉及的基本概念和术语。基本概念实例（Instance）创建购买云消息队列 MQTT 版服务的实体单元，每个云消息队列 MQTT 版实例都对应一个全局唯一的服务接入点URL。使用云消息...

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

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

开源RabbitMQ迁移上云

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

概述

请按需参见以下文档实现社区版SDK访问阿里云云消息队列 RocketMQ 版：社区版TCP协议Java SDK接入说明社区版TCP协议C++ SDK接入说明暂不支持通过社区版TCP协议的Go SDK和Python SDK访问阿里云云消息队列 RocketMQ 版，推荐您使用商业版...

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

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

在Knative上实现Kafka消息推送

Knative已支持Kafka事件源，您可将Knative与云消息队列 Kafka 版对接，在Knative上实现Kafka消息推送。前提条件部署Knative 购买并部署云消息队列 Kafka 版实例重要云消息队列 Kafka 版实例和Knative必须处于同一VPC内。云消息队列...

Topic使用变更

云消息队列 MQTT 版从V2.x.x升级至V3.x.x后，实现了独立存储，Topic资源不再依赖于云消息队列 RocketMQ 版，因此两个产品的Topic将完全彼此独立。本文介绍两个版本中Topic资源控制台操作的差异并提供相应控制台截图进行对比。变更说明 ...

快速入门概述

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

实例使用变更

云消息队列 MQTT 版从V2.x.x升级至V3.x.x后，不再需要与云消息队列 RocketMQ 版的实例进行绑定。本文介绍两个版本之间的控制台实例相关操作的具体差异，并提供控制台截图进行对比。变更说明由于V3.x.x版本的云消息队列 MQTT 版实现了...

消息收发功能

消息收发为云消息队列 MQTT 版最基本的功能，云消息队列 MQTT 版支持终端和云端服务接入云消息队列 MQTT 版服务器，实现终端和终端、终端和云端的消息通信。本文介绍消息收发功能的基本场景和示例代码。背景信息云消息队列 MQTT 版 ...

V2.x.x到V3.x.x的升级公告

V3.x.x版本除了独立存储之外，还对V2.x.x版本实现的云消息队列 MQTT 版和云消息队列 RocketMQ 版互通的功能进行抽象，使得云消息队列 MQTT 版的数据可以根据您配置相应规则转发到其他阿里云产品，也可以配置规则从其他阿里云产品导入...

开源SDK接入（主子账号授权）

阿里云的云消息队列 RabbitMQ 版支持AMQP 0-9-1协议，兼容开源的RabbitMQ客户端，您可以使用开源的客户端SDK接入云消息队列 RabbitMQ 版服务端进行消息收发。前提条件创建实例创建Vhost 背景信息借助访问控制RAM的RAM用户，您可以...

音视频通信解决方案（MQTT）

数据交互数据流所展示的是基于云消息队列 MQTT 版和音视频通信RTC实现一次音视频通话会议的调用流程，其中灰色部分为您的自建开发程序或服务，蓝色部分是云消息队列 MQTT 版、云消息队列 RocketMQ 版以及音视频通信RTC所提供的服务。...

什么是消息队列RabbitMQ版？

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

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

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

开源SDK接入（跨云账号授权）

本文以调用Java SDK为例，介绍在RAM角色跨账号授权场景，通过开源SDK实现消息收发的操作过程，帮助您更好地理解消息收发的完整过程，其他语言或框架的SDK消息收发过程相似。前提条件创建实例创建Vhost 背景信息当您需要通过RAM STS角色...

延时消息

方案对比云消息队列 RabbitMQ 版无需进行代码改造，即可实现开源RabbitMQ的所有延时消息方案，详情请参见下表：项目开源RabbitMQ 云消息队列 RabbitMQ 版死信Exchange+Queue的消息存活时间支持支持死信Exchange+消息的消息存活时间 ...

资源使用变更

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

云存储网关利用MQTT服务实现统一管控

通过云消息队列 MQTT 版所提供的服务，可采用统一的框架，即云控制台，来管理不同部署模式的云存储网关CSG（Cloud Storage Gateway），并实现安全合规的公网和私网穿透，以此提供一致的用户体验。名词解释 MQTT 一种物联网和移动互联网...

访问控制概述

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

云消息队列 MQTT 版

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

云消息队列 RabbitMQ 版

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

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

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

SDK参考概述

SDK兼容性说明云消息队列 RocketMQ 版服务端版本和客户端SDK版本的兼容情况如下：服务端版本客户端版本兼容性约束限制 5.x版本实例 RocketMQ 5.x SDK 兼容云消息队列 RocketMQ 版 5.x版本实例的所有功能完全支持。RocketMQ 4.x/3.x ...

使用须知

HTTP协议的迭代版本所支持的功能与TCP协议功能对比说明，请参见：Java SDK版本说明 Go SDK版本说明 Python SDK版本说明 Node.js SDK版本说明 PHP SDK版本说明 C#SDK版本说明 C++ SDK版本说明注意事项支持HTTP协议SDK接入为云消息队列 ...

功能发布列表

功能名称功能描述变更类型相关文档 5.x系列实例自建RocketMQ集群迁移上云提供开源RocketMQ集群迁移上云工具，支持分批次将元数据迁移至阿里云云消息队列 RocketMQ 版的实例中，并支持按Topic粒度对客户端读写流量进行切换实现业务...

什么是云消息队列 Kafka 版？

云消息队列 Kafka 版是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。云消息队列 Kafka 版广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等大数据领域，已成为大数据生态中不可或缺的部分。产品优势云消息队列 ...

云消息队列 Kafka 版

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

消息队列Kafka版

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

云消息队列 RabbitMQ 版

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

迁移上云操作

和开源Apache RocketMQ相比，阿里云云消息队列 RocketMQ 版具有更高的稳定性、安全性及更完善的运维体系。您可以将开源RocketMQ集群迁移到云消息队列 RocketMQ 版上以获得更好的业务体验。本文为您介绍如何使用云消息队列 RocketMQ 版...

示例代码

无访问云原生大数据计算服务 MaxCompute[python3]无无访问云原生大数据计算服务 MaxCompute[java11]向消息队列 Kafka 投递消息[node.js14]向消息队列 Kafka 投递消息[python3]无向消息队列 Kafka 投递消息[go1]向消息队列 Kafka 投递...

开源消息队列Java实现

新品推荐