中间件产品总览
Spring Boot 自研的开发框架 集成 SOFA 中间件，且中间件可插拔 服务网格 将传统微服务和 Service Mesh 进行融合 对接经典应用服务和容器应用服务 提供丰富的服务治理功能 消息队列 基于 Apache RocketMQ 构建的分布式消息中间件 ...
在线教育视频直播
部署架构图 选用的产品 云消息队列 RocketMQ 版 云消息队列 RocketMQ 版 是由阿里巴巴自研并捐赠给Apache基金会，并与开源社区共建的消息中间件，该产品服务于阿里巴巴集团已超过13年，经过交易核心链路反复打磨与历年双十一高并发场景的...
产品概述
平台组件：是指产品对平台提供的服务目录的依赖项，例如：一个办公软件，依赖MQ消息中间件，如果用户希望由ADP平台提供该中间件，则他应该在产品依赖中，声明对该MQ组件的依赖。用户组件：是指用户自身代码构建的业务应用，打包上传至ADP...
版本说明
0.6（2020-01-10）发布 SOFAStack 消息队列，是基于 Apache RocketMQ 构建的分布式消息中间件，并与金融分布式架构 SOFAStack 深度集成。支持多种消息类型：普通消息、定时消息、分区顺序消息、事务消息。详见 消息类型。提供专业、可靠、...
什么是云消息队列 MQTT 版
云消息队列 MQTT 版 是阿里云推出的一款面向移动互联网以及物联网领域的轻量级消息中间件。如果说传统的消息队列中间件一般应用于微服务之间，那么适用于物联网的 云消息队列 MQTT 版 则实现了端与云之间的消息传递和真正意义上的万物互联...
领域模型概述
消息传输模型介绍 主流的消息中间件的传输模型主要为点对点模型和发布订阅模型。点对点模型 点对点模型也叫队列模型，具有如下特点：消费匿名：消息上下游沟通的唯一的身份就是队列，下游消费者从队列获取消息无法声明独立身份。一对一通信...
消息 Mesh
消息 Mesh 经过蚂蚁消息中间件团队大半年的打磨和沉淀，已经迈出了坚实的一大步：在开源社区迟迟未在消息 Mesh 上取得实质性进展时，蚂蚁团队已经为蚂蚁内部主流消息中间件打通了数据平面。同时，依赖消息的精细化流量调度，预期可以发掘出...
什么是云消息队列 RocketMQ 版？
削峰填谷提高稳定性 传统消息中间件仅满足业务的异步化需求，而 云消息队列 RocketMQ 版 诞生于在线互联网和交易业务场景，除了满足异步能力，还将削峰填谷作为消息的基础能力。通过削峰填谷不仅能够提高系统稳定性，还能大幅降低业务成本...
什么是消息演练
消息演练概述 目前市面上有RocketMQ、Kafka、RabbitMQ等流行的消息中间件服务，消息演练功能将这些常见的中间件进行了统一抽离，为消息服务安排分配了精选后的演练最佳实践。您无需分析每种消息服务需要什么演练场景，仅需选择演练方案即可...
概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 消息集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据格式转换等...
概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 消息集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据格式转换等...
概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 消息集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据格式转换等...
概述
消息队列 SOFAStack 消息队列是基于 Apache RocketMQ 构建的分布式消息中间件，并与金融分布式架构 SOFAStack 深度集成，为分布式应用系统提供异步解耦和削峰填谷的能力，支持事务消息、顺序消息、定时消息等多种消息类型，并具备高可靠、...
SOFAMQ 常见问题
作为一款分布式消息中间件，在网络抖动、应用处理超时等异常情况下，可以保证消息不丢失，但是无法保证消息不重复。控制台显示的消息堆积量是否包含了 Topic 下所有 Tag 的消息？是。消息生产者将所有类型的 Tag 都发送至同一个 Topic 中，...
消费重试
云消息队列 RocketMQ 版 作为金融级的可靠业务消息中间件，在消息投递处理机制的设计上天然支持可靠传输策略，通过完整的确认和重试机制保证每条消息都按照业务的预期被处理。了解 云消息队列 RocketMQ 版 的消息确认机制以及消费重试策略...
消息（Message）
系统默认的消息最大限制如下：普通和顺序消息：4 MB 事务和定时或延时消息：64 KB 使用建议 单条消息不建议传输超大负载 作为一款消息中间件产品，云消息队列 RocketMQ 版 一般传输的是都是业务事件数据。单个原子消息事件的数据大小需要...
概述
SOFAStack 消息队列（SOFAStack MQ，简称 SOFAMQ）是基于 Apache RocketMQ 构建的分布式消息中间件，并与金融分布式架构 SOFAStack 深度集成，为分布式应用系统提供异步解耦和削峰填谷的能力，支持事务消息、顺序消息、定时消息等多种消息...
集成概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 Connector生态集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据...
使用Spring Cloud框架收发消息
spring.cloud.stream.bindings.MyOutput.destination=${kafka.output.topic.name} spring.cloud.stream.bindings.MyOutput.contentType=text/plain spring.cloud....MyInput.contentType=text/plain#Binder是Spring Cloud对消息中间件的封装模块...
消息过滤
应用场景 云消息队列 RocketMQ 版 作为发布订阅模型的消息中间件广泛应用于上下游业务集成场景。在实际业务场景中，同一个主题下的消息往往会被多个不同的下游业务方处理，各下游的处理逻辑不同，只关注自身逻辑需要的消息子集。使用 云...
附录一：运维服务产品清单
性能测试 pts 云计算基础 互联网中间件 消息服务 mns 云计算基础 互联网中间件 全局事务服务 txc 云计算基础 互联网中间件 应用配置管理 acms 云计算基础 互联网中间件 消息队列Kafka alikafka 云计算基础 互联网中间件 应用高可用服务 ...
查看订阅关系
在左侧导航栏，选择 中间件>消息队列>Topic 管理。单击目标 Topic 进入详情页，即可看到所有订阅该 Topic 的在线 Group ID 及其消费模式。此外，您还可以单击任一 Group ID 操作列的 消费状态，查看该 Group ID 的消息消费详情。详见 查看...
开源版和商业版介绍
SOFABoot 目前对外开放的有...支持 中间件（消息）MsgBroker 不支持 支持 中间件（数据）DTX 支持 说明 支持 TCC、FMT 模式。支持异库事务日志存储。支持 说明 支持 TCC、FMT 模式。支持异库事务日志存储。支持同城双活。支持共享版中间件。
Demo 工程
在左侧导航栏，选择 中间件>消息队列>消息查询。在 消息查询 页面，您可单击 按 Topic 查询。单击目标 Topic 名称进行查询，可以看见消息已经发送至 Topic。接收消息。接收普通消息：以纯 Java 方式接收普通消息：运行 SimpleConsumer 类。...
操作链路概述
在左侧导航栏，选择 中间件>消息队列>Topic 管理。单击 创建 Topic，然后在 创建 Topic 对话框配置 Topic 信息：参数 是否必填 说明 Topic 必填 Topic 格式要求如下：Topic 只能包含英文、数字、短横线（-）和下划线（_），其中英文和数字...
重置消费位点
在左侧导航栏，选择 中间件>消息队列>Group 管理。单击目标 Group ID 操作列的 重置消费位点，然后在 重置消费位点 对话框配置以下信息：Topic：选择重置消费位点针对的 Topic。重置类型：清除所有堆积消息，从最新位点开始消费：若选择...
消息查询
在左侧导航栏，选择 中间件>消息队列>消息查询。在 消息查询 页面，您可单击以下任一页签，然后按页面提示输入相应信息。按 Message ID 查询：Message ID 是由服务端生成的 32 位字符串，用于标识一条消息。按 Message ID 查询，即根据 ...
消息路由
在左侧导航栏，选择 中间件>消息队列>消息路由。单击 创建路由任务，然后在 创建路由任务 对话框配置任务信息：源 Topic：输入需要同步的消息所属 Topic 名称。目标单元：选择消息将被同步到的 Topic 所属单元。目标 Topic：输入消息将被...
死信队列
在左侧导航栏，选择 中间件>消息队列>死信队列。单击 按 Group ID 查询。在 Group ID 的输入框中，输入关键词搜索想要查找的 Group ID，然后选中，或直接在下拉列表中选择想要查找的 Group ID。单击时间选择框，选择想要查询的时间范围的...
查看消费者状态
在左侧导航栏，选择 中间件>消息队列>Group 管理。单击目标 Group ID 进入详情页。单击 消费者状态，即可查看到消费者群组所有相关的状态信息。在线状态：只要该 Group ID 下有一个消费者实例在线，就显示在线。若该 Group ID 下所有消费者...
查询消息轨迹
在左侧导航栏，选择 中间件>消息队列>消息轨迹。单击 创建查询任务，您可选择以下查询维度，然后按页面提示输入相应信息。按 Message ID 查询：该方式属于精确查询，速度快，精确匹配，推荐使用。按 Message Key 查询：该方式属于模糊查询...
创建和管理 Topic
在左侧导航栏，选择 中间件>消息队列>Topic 管理。单击 创建 Topic，然后在 创建 Topic 对话框配置 Topic 信息：Topic：Topic 名称。Topic 只能包含英文、数字、短横线（-）和下划线（_），其中英文和数字必须要有一种，短横线（-）和...
接入点设置说明
在左侧导航栏，选择 中间件>消息队列>概览。在页面底部的 接入配置 找到 内网接入点 及 实例 ID。将该 TCP 协议内网接入点 配置到客户端 SDK 代码的 ENDPOINT 参数。将该 实例 ID 配置到客户端 SDK 代码的 INSTANCE_ID 参数。
资源大盘
在左侧导航栏，选择 中间件>消息队列>资源大盘。选择或自定义时间范围，默认范围是最近 1 小时，支持的最长时间间隔为 1 天。单击 刷新，即可获取并查看目标时间范围内的各项资源数据：资源统计数据 Topic 生产报表 Group 消费报表 资源...
创建和管理 Group ID
在左侧导航栏，选择 中间件>消息队列>Group 管理。单击 创建 Group ID，然后在 创建 Group ID 对话框配置 Group ID 信息：Group ID：必填。命名以“GID_”或者“GID-”开头。只能包含字母、数字、短横线和下划线。长度限制在 7-64 字符之间...
可观测性体系概述
作为一款典型的分布式中间件产品，云消息队列 RocketMQ 版 被广泛应用于业务核心链路中，每条消息都关联着核心业务数据的变化，通过可观测能力及时发现问题、定位问题、解决问题对于业务运行是一项重要的保障能力。本文介绍 云消息队列 ...
概述
分布式事务可以与服务框架（SOFABoot、Spring Cloud、Dubbo 等）、数据源（数据访问代理、RDS、MySQL、OceanBase 等）、消息队列等蚂蚁集团中间件产品配合使用，轻松实现服务链路级事务、跨库事务、消息事务及各种组合。分布式事务主要涉及...
开通消息服务MNS并授权
步骤一：开通消息服务MNS 登录 阿里云官网，选择 产品>中间件>云消息队列>消息服务 MNS。在产品页，单击 立即开通。请仔细阅读 消息服务MNS服务协议，选中 消息服务MNS服务协议，然后单击 立即开通。页面显示 恭喜，开通成功！步骤二：...
快速入门
本文将向您描述如何使用 SOFABoot 框架创建一个Web 工程，实现本地运行或部署到云端运行，以及如何引入中间件服务。主要步骤如下：创建 Web 工程 将 Web 工程导入 IDE 实现本地编译和运行 实现云端运行 引入中间件服务 说明 Core 工程 与 ...
- 产品推荐
- 这些文档可能帮助您