分布式队列-分布式队列文档介绍内容-阿里云

死信队列

当一条消息初次消费失败，消息队列会自动进行消息重试。达到最大重试次数后，若消费依然失败，则表明消费者在正常情况下无法正确地消费该消息。此时，消息队列不会立刻将消息丢弃，而是将其发送到该消费者对应的特殊队列中。在消息队列中，...

收发事务消息

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

使用限制

SOFAStack 消息队列对某些具体指标进行了约束和规范，在使用过程中请注意不要超过相应的限制值，以免程序出现异常。具体的限制项和限制值请参见下表。限制项限制值说明 Topic 名称长度 64 个字符 Topic 名称长度不得超过该限制，否则会...

领域模型概述

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

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

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

收发事务消息

云消息队列 RocketMQ 版提供类似XA或Open XA的分布式事务功能，通过云消息队列 RocketMQ 版事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的C#SDK收发事务消息的示例代码。背景信息事务消息的交互流程如下图所示。更多...

Demo 工程

本文以 TCP 协议下的 Java 为例，提供操作示例帮助您从零开始搭建消息队列测试工程，提供 Spring 和纯 Java 两种使用方式。Demo 工程包含普通消息、顺序消息、事务消息和定时、延时消息的配置以及测试代码。前提条件安装 IDE。您可以使用 ...

收发事务消息

云消息队列 RocketMQ 版提供类似XA或Open XA的分布式事务功能，通过云消息队列 RocketMQ 版事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的Node.js SDK收发事务消息的示例代码。背景信息事务消息的交互流程如下图所示...

收发事务消息

云消息队列 RocketMQ 版提供类似XA或Open XA的分布式事务功能，通过云消息队列 RocketMQ 版事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的Python SDK收发事务消息的示例代码。背景信息事务消息的交互流程如下图所示...

收发事务消息

云消息队列 RocketMQ 版提供类似XA或Open XA的分布式事务功能，通过云消息队列 RocketMQ 版事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的Java SDK收发事务消息的示例代码。背景信息事务消息的交互流程如下图所示。...

收发事务消息

云消息队列 RocketMQ 版提供类似XA或Open XA的分布式事务功能，通过云消息队列 RocketMQ 版事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的PHP SDK收发事务消息的示例代码。背景信息事务消息的交互流程如下图所示。更...

订阅消息

本文介绍如何通过 SOFAStack 消息队列的 Java SDK 订阅消息。订阅方式消息队列支持以下两种订阅方式：集群订阅同一个 Group ID 所标识的所有 Consumer 平均分摊消费消息。例如某个 Topic 有 9 条消息，一个 Group ID 有 3 个 Consumer ...

收发事务消息

云消息队列 RocketMQ 版提供类似XA或Open XA的分布式事务功能，通过云消息队列 RocketMQ 版事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的Go SDK收发事务消息的示例代码。背景信息事务消息的交互流程如下图所示。更...

收发事务消息

云消息队列 RocketMQ 版提供类似XA或Open XA的分布式事务功能，通过云消息队列 RocketMQ 版事务消息，能达到分布式事务的最终一致。本文提供使用HTTP协议下的C++ SDK收发事务消息的示例代码。背景信息事务消息的交互流程如下图所示。更...

在线教育视频直播

云消息队列 RocketMQ 版是由阿里巴巴自研并捐赠给Apache基金会，并与开源社区共建的消息中间件，该产品服务于阿里巴巴集团已超过13年，经过交易核心链路反复打磨与历年双十一高并发场景的严苛考验，是一个真正具备低延迟、高并发、高可用...

消息检索

例如，消息Key是“云消息队列 Kafka 版是阿里云提供的分布式、高吞吐、可扩展的消息队列服务。可以设置搜索关键词为“分布式”，或者“阿里云”和“分布式”组合。如果搜索关键字中包含星号（*）或问号?则采用通配符检索。星号（*）代表...

消息重试

本文介绍 SOFAStack 消息队列的消息重试机制和配置方式。顺序消息的重试对于顺序消息，当消费者消费消息失败后，消息队列会自动不断地进行消息重试（每次间隔时间为 1 秒），这时，应用会出现消息消费被阻塞的情况。因此，建议您使用顺序...

什么是消息服务MNS

阿里云消息服务MNS（Message Service）是一种高效、可靠、安全、便捷和可弹性扩展的分布式消息服务。消息服务MNS 能够帮助开发者在应用的分布式组件之间自由地传递数据、通知消息，从而构建松耦合系统。消息服务MNS 支持队列模型和主题...

基本概念

事务消息云消息队列 RocketMQ 版提供类似XA或Open XA的分布事务功能，通过云消息队列 RocketMQ 版的事务消息能达到分布式事务的最终一致。更多信息，请参见事务消息。顺序消息云消息队列 RocketMQ 版提供的一种按照顺序进行发布和...

收发事务消息

阿里云云消息队列 RocketMQ 版提供类似X/Open XA的分布式事务功能，通过阿里云云消息队列 RocketMQ 版事务消息，能达到分布式事务的最终一致。交互流程事务消息交互流程如下图所示。更多信息，请参见事务消息。前提条件安装CPP动态...

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

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

基本概念

Apache Kafka 一款开源的分布式数据流处理平台，可以实时发布、订阅、存储和处理数据流。更多信息，请参见 Apache Kafka。云消息队列 Kafka 版一款由阿里云提供的Apache Kafka全托管服务，具备免部署、免运维、低成本、高弹性、高可靠、高...

概述

分布式事务可以与服务框架（SOFABoot、Spring Cloud、Dubbo 等）、数据源（数据访问代理、RDS、MySQL、OceanBase 等）、消息队列等蚂蚁集团中间件产品配合使用，轻松实现服务链路级事务、跨库事务、消息事务及各种组合。分布式事务主要涉及...

消息过滤

本文描述 SOFAStack 消息队列的消费者如何根据 Tag 在消息队列服务端完成消息过滤，以确保消费者最终只消费到其关注的消息类型。Tag，即消息标签，用于对某个 Topic 下的消息进行分类。消息队列的生产者在发送消息时，已经指定消息的 Tag，...

集群消费和广播消费

由于消费者应用一般是分布式系统，以集群方式部署，因此消息队列约定以下概念：集群：使用相同 Group ID 的消费者属于同一个集群。同一个集群下的消费者消费逻辑必须完全一致（包括 Tag 的使用）。详情请参见订阅关系一致。集群消费：当...

定时/延时消息

典型场景一：分布式定时调度在分布式定时调度场景下，需要实现各类精度的定时任务，例如每天5点执行文件清理，每隔2分钟触发一次消息推送等需求。传统基于数据库的定时调度方案在分布式场景下，性能不高，实现复杂。基于云消息队列 ...

基本概念

事务消息事务消息是云消息队列 RocketMQ 版提供的一种高级消息类型，支持在分布式场景下保障消息生产和本地事务的最终一致性。定时/延时消息定时/延时消息是云消息队列 RocketMQ 版提供的一种高级消息类型，消息被发送至服务端后，在...

任务管理高级配置参数说明

1 子任务单机并发数并行计算内存网格网格计算 分布式模型，单台机器并发消费子任务的个数。5 子任务失败重试次数并行计算内存网格网格计算 分布式模型，子任务失败自动重试的次数。0 子任务失败重试间隔并行计算内存网格网格计算 ...

任务管理高级配置参数说明

1 子任务单机并发数并行计算内存网格网格计算 分布式模型，单台机器并发消费子任务的个数。5 子任务失败重试次数并行计算内存网格网格计算 分布式模型，子任务失败自动重试的次数。0 子任务失败重试间隔并行计算内存网格网格计算 ...

组件中心

中间件 分布式链路跟踪一款实时监控并管理企业应用性能和故障的云服务，其提供数字化性能管理解决方案，帮助企业在分布式架构下快速发现并准确定位应用全生命周期的性能问题。任务调度提供分布式任务调度框架，实现任务的分布式处理，并...

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

云端SDK可用于云端分布式应用部署，天然支持共享订阅，并提供消息收发、消息订阅、客户端上下线事件通知等能力，目前支持Java、Go语言的SDK。更多信息，请参见云端开发概述。云端SDK支持在云消息队列 MQTT 版服务端层面进行订阅发布，而...

查看订阅关系

对于大多数分布式应用来说，一个Group ID下通常会挂载多个Consumer实例。云消息队列 RocketMQ 版的订阅关系主要由Topic+Tag共同组成，即一个Group ID下所有的Consumer实例订阅的Topic以及这些Topic中的过滤规则Tag。同一个Group ID下所有...

队列（MessageQueue）

常见队列增加场景需要增加队列实现物理节点负载均衡云消息队列 RocketMQ 版每个主题的多个队列可以分布在不同的服务节点上，在集群水平扩容增加节点后，为了保证集群流量的负载均衡，建议在新的服务节点上新增队列，或将旧的队列迁移到...

JMS概述

JMS使分布式应用能够以松耦合、可靠、异步的方式进行通信。云消息队列 RabbitMQ 版 JMS库支持 JMS 1.1。云消息队列 RabbitMQ 版JMS库云消息队列 RabbitMQ 版 JMS库是云消息队列 RabbitMQ 版提供的JMS接口。JMS应用只需变更少量代码，...

应用场景

云消息队列 Kafka 版作为数据中转枢纽具备以下优势：高容量存储：能在商业硬件上存储高容量的数据，实现可横向扩展的分布式系统。一对多消费模型：发布/订阅模型，支持同份数据集能同时被消费多次。同时支持实时和批处理：支持本地数据...

什么是 SOFATracer

SOFATracer 是蚂蚁金服基于 OpenTracing 规范开发的分布式链路跟踪系统，其核心理念就是通过一个全局的 TraceId 将分布在各个服务节点上的同一次请求串联起来。通过统一的 TraceId 将调用链路中的各种网络调用情况以日志的方式记录下来，...

SOFAMQ 常见问题

作为一款分布式消息中间件，在网络抖动、应用处理超时等异常情况下，可以保证消息不丢失，但是无法保证消息不重复。控制台显示的消息堆积量是否包含了 Topic 下所有 Tag 的消息？是。消息生产者将所有类型的 Tag 都发送至同一个 Topic 中，...

使用Spring Cloud框架收发消息

Spring Cloud是用于构建消息驱动的微服务应用程序的框架，提供服务发现、配置管理、消息传递、负载均衡等微服务相关的解决方案，可以更容易地构建分布式系统和进行服务间通信。本文介绍如何使用Spring Cloud框架接入云消息队列 Kafka 版 ...

4.x和5.x版本差异及兼容性说明

云消息队列 RocketMQ 版是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布，阿里云云消息队列 RocketMQ 版将为您提供更加稳定可靠的服务端5...

4.x和5.x版本差异及兼容性说明

云消息队列 RocketMQ 版是阿里云基于Apache RocketMQ构建的低延迟、高并发、高可用、高可靠的分布式“消息、事件、流”统一处理平台。随着Apache RocketMQ 5.0版本的发布，阿里云云消息队列 RocketMQ 版将为您提供更加稳定可靠的服务端5...

分布式队列

新品推荐