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

SDK下载

在使用云消息队列 MQTT 版客户端（下文简称MQTT客户端）收发消息前，需根据云消息队列 MQTT 版所支持的开发语言下载对应SDK。云消息队列 MQTT 版默认支持标准的MQTT 3.1.1协议，理论上能够适配所有的MQTT客户端，但不排除部分MQTT客户...

关于TCP内网接入点设置的公告

为了进一步提升云消息队列 RocketMQ 版服务的稳定性，并以此保障您应用的稳定性，针对部署在某地域（Region）的应用，如果您使用的是TCP协议下的SDK，则需使用该地域的云消息队列 RocketMQ 版服务的TCP内网接入点。本文提供对应地域的...

名词解释

本文主要对云消息队列 RabbitMQ 版涉及的专有名词及术语进行定义和解析，方便您更好地理解相关概念并使用云消息队列 RabbitMQ 版。A Alternate Exchange 备份Exchange，简称AE，用于接收配置了备份Exchange的Exchange路由失败的消息。...

实例管理

使用云消息队列 RocketMQ 版进行消息收发，必须先创建云消息队列 RocketMQ 版实例。本文介绍如何在云消息队列 RocketMQ 版控制台上创建、删除、更新和查看实例详情。背景信息云消息队列 RocketMQ 版实例按照规格分为标准版和企业...

SDK下载

在使用云消息队列 MQTT 版客户端（下文简称MQTT客户端）收发消息前，需根据云消息队列 MQTT 版所支持的开发语言下载对应SDK。云消息队列 MQTT 版默认支持标准的MQTT 3.1.1协议，理论上能够适配所有的MQTT客户端，但不排除部分MQTT客户...

创建资源

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

消息队列RabbitMQ版是否支持顺序消息？

不支持。与开源RabbitMQ的单机部署天然支持顺序消息不同，阿里云云消息队列 RabbitMQ 版为自研产品，分布式部署，暂不支持顺序消息。

版本说明

0.6（2020-01-10）发布 SOFAStack 消息队列，是基于 Apache RocketMQ 构建的分布式消息中间件，并与金融分布式架构 SOFAStack 深度集成。支持多种消息类型：普通消息、定时消息、分区顺序消息、事务消息。详见消息类型。提供专业、可靠、...

创建资源

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

使用限制

云消息队列 RocketMQ 版对某些具体指标进行了约束和规范，您在使用云消息队列 RocketMQ 版时注意不要超过相应的限制值，以免程序出现异常。限制项限制值说明 Topic名称长度 64个字符 Topic名称长度不得超过该限制，否则会导致无法发送...

迁移Group上云

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

收发事务消息

消息队列提供类似 X/Open XA 的分布式事务功能，通过消息队列事务消息，能达到分布式事务的最终一致。说明对于新手用户，建议在正式收发消息前，阅读 Demo 工程来了解搭建消息队列工程的具体步骤。交互流程事务消息交互流程如下图所示。...

收发事务消息

云消息队列 RocketMQ 版提供类似XA或Open XA的分布式事务功能，通过云消息队列 RocketMQ 版事务消息，能达到分布式事务的最终一致。交互流程事务消息交互流程如下图所示。更多信息，请参见事务消息。前提条件您已完成以下操作：下载C...

权益分发

方案架构因为云消息队列 RocketMQ 版具有重试功能且能保证消息不丢失，所以推出此方案来确保DB和缓存数据的强一致性，即在DB和缓存间使用云消息队列 RocketMQ 版，架构如下图所示。方案优势云消息队列 RocketMQ 版有以下优势：巨大的...

Dashboard

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

签名鉴权模式

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

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

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

实例化支持

本文提供相关更新说明，帮助您更顺畅地使用云消息队列 RocketMQ 版。说明为兼容新老资源配置，建议您将ons-client客户端升级到最新版本。资源隔离优化（实例化支持）云消息队列 RocketMQ 版开放实例化功能，解决多租户之间的隔离问题，...

发布者最佳实践

本文介绍云消息队列 Kafka 版发布者的最佳实践，帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端，其基本概念与思想是相通的，但实现细节可能存在差异。发送消息发送消息的示例代码如下：Future...

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

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

Group管理

使用云消息队列 RocketMQ 版进行消息收发，您需要创建Group ID用于标识同一类生产者实例或者同一类消费者实例。本文介绍如何在云消息队列 RocketMQ 版控制台上创建、删除和查询Group。使用限制单实例下最多创建1000个Group，建议您...

联系我们

如果您准备使用或正在使用云消息队列 MQTT 版，有任何疑问和建议，欢迎您搜索钉钉群号 35228338加入钉钉群与我们交流。

从自建MySQL同步至云消息队列 Kafka 版

背景信息云消息队列 Kafka 版是阿里云提供的分布式、高吞吐、可扩展的消息队列服务，针对开源的Apache Kafka提供全托管服务，彻底解决开源产品长期以来的痛点，您只需专注于业务开发，无需部署运维。云消息队列 Kafka 版广泛用于日志...

步骤五：到控制台验证

基于开发单元化应用中的转账与积分场景，在完成相应的转账或存款等操作后，您可以前往各个产品控制台验证单元化效果：分布式链路跟踪：查看单元间流量走向 分布式事务：查看事务执行情况 消息队列：查看消息轨迹微服务：按单元推送动态...

事务消息

事务消息为云消息队列 RocketMQ 版中的高级特性消息，本文为您介绍事务消息的应用场景、功能原理、使用限制、使用方法和使用建议。应用场景 分布式事务的诉求 分布式系统调用的特点为一个核心业务逻辑的执行，同时需要调用多个下游业务...

OpenOnsService-开通服务

调用OpenOnsService开通云消息队列 RocketMQ 版服务。接口说明注意阿里云提供的 OpenAPI 属于管控类 API，用于管理和查询阿里云服务的相关资源。仅推荐在管控链路集成，消息收发的核心数据链路中严禁依赖 OpenAPI 实现，否则可能会导致...

资源使用变更

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

联系我们

如果您准备使用或正在使用云消息队列 RabbitMQ 版，有任何产品相关疑问和建议，欢迎自行搜索以下群号加入钉钉群与我们交流。钉钉群号：31735582

如何处理消息堆积

问题现象在使用云消息队列 RocketMQ 版实例时收到消息堆积告警，登录云消息队列 RocketMQ 版控制台后发现了下列现象：在 Group 详情页面，看到Group ID的实时消息堆积量的值高于预期。导航栏中选择消息轨迹，单击创建查询任务，...

签名鉴权模式

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

RBAC授权

本文介绍如何在云消息队列 Confluent 版控制台中进行RBAC授权。背景信息 RBAC的全称是Role Based Access Control。RBAC的授权方式是基于角色进行授权的，而ACL是基于权限进行授权。因此，RBAC比ACL更适合批量授权以及权限回收。RBAC授权...

快速入门概述

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

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

您可通过配置云消息队列 MQTT 版的客户端上下线通知规则，将获取的MQTT客户端上下线事件数据导出至其他阿里云产品。该方法为异步上下线通知。本文介绍客户端上下线通知的原理、应用场景、使用限制以及云消息队列 MQTT 版与其他阿里云...

迁移上云操作

本文为您介绍如何使用云消息队列 RocketMQ 版的迁移工具将开源自建的Apache RocketMQ迁移至阿里云云消息队列 RocketMQ 版。前提条件创建消息队列RocketMQ版5.0系列实例创建服务关联角色角色名称：AliyunServiceRoleForRMQMigration ...

JMS概述

云消息队列 RabbitMQ 版提供JMS库供JMS客户端接入云消息队列 RabbitMQ 版。本文介绍云消息队列 RabbitMQ 版 JMS库的相关概念、获取方式、使用限制和使用教程。背景信息 JMS是一种消息传递标准，允许基于Java EE（Java平台企业版）的应用...

什么是云消息队列 MQTT 版

根据以上两种消息收发模型，可以将使用云消息队列 MQTT 版的开发人员分为终端和云端两大类。两类开发人员所需的二次开发内容请分别参见终端开发指南和云端开发指南。产品优势无缝迁移兼容任何支持MQTT 3.1.1协议的SDK，支持...

查看Rebalance详情

当消费客户端出现Rebalance时，您可以查看Rebalance的详情，包括Rebalance的时间、耗时、次数、原因以及...后续步骤当客户端频繁出现Rebalance时，您可以参考以下文档解决此问题：使用云消息队列 Kafka 版时消费客户端频繁出现Rebalance。

什么是云消息队列 Kafka 版？

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

基于Flink的资讯场景实时数仓

部署架构图选用的产品云消息队列 Kafka 版云消息队列 Kafka 版是阿里云基于Apache Kafka构建的高吞吐量、高可扩展性的分布式消息队列服务，广泛用于日志收集、监控数据聚合、流式数据处理、在线和离线分析等，是大数据生态中不可或缺的...

HTTP SDK错误码列表

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

阿里云分布式消息队列如何使用

新品推荐