引入 SOFA 中间件
为了在 SOFABoot 应用中引入 SOFA 中间件，需要在工程文件中进行以下配置：application.properties 文件中添加 properties 配置项。在主 pom.xml 文件中 引入相关中间件服务的 starter。properties 配置项 在 Web 项目的 app/web/src/main/...
新功能发布记录
本文介绍 消息服务MNS 的产品功能动态及对应的文档。...新增 JMS SDK 2021-02-12 功能名称 功能描述 功能类型 相关文档 控制台 控制台交互改版，为您提供更好的体验以快速使用 消息服务MNS。优化 队列模型 主题模型 事件通知 日志管理
服务关联角色
您在 云消息队列 RabbitMQ 版 控制台首次使用消息日志时，系统会提示您完成AliyunServiceRoleForAmqpLogDelivery的自动创建。更多信息，请参见 配置消息日志。权限策略 AliyunServiceRoleForAmqpMonitoring的权限策略如下：{"Version":"1",...
获取MQTT客户端在线状态
异步上下线事件通知 该方式使用消息通知，在客户端上线和下线事件触发时，MQTT服务端支持将上下线消息直接推送到部署在阿里云服务器上的云端应用。该方式属于异步感知客户端的状态，且感知到的是上下线事件，而非在线状态，云端应用需要...
基础术语
本文主要对 SOFAStack 消息队列涉及的专有名词及术语进行定义和解析，方便您更好地理解相关概念并使用消息队列。中文 英文 释义 消息主题 Topic 消息主题，一级消息类型，通过 Topic 对消息进行分类。详情请参见 Topic 与 Tag。消息 ...
发布者最佳实践
本文介绍 云消息队列 Kafka 版 发布者的最佳实践，帮助您降低发送消息的错误率。本文最佳实践基于Java客户端。对于其他语言的客户端，其基本概念与思想是相通的，但实现细节可能存在差异。发送消息 发送消息的示例代码如下：Future...
订阅者最佳实践
本文主要介绍 云消息队列 Kafka 版 订阅者的最佳实践，帮助您减少消费消息出错的可能性。消费消息基本流程 云消息队列 Kafka 版 订阅者在订阅消息时的基本流程为：Poll数据→执行消费逻辑→再次Poll数据，详情参见下图。负载均衡 每个 ...
什么是消息服务MNS
消息投递 消息服务MNS 支持消息推送到队列：推送到队列 广播拉取消息模型 消息投递保障 在消息有效期内，保证发布到主题中的消息会按照指定的策略和格式推送给用户端程序。推送策略包括：退避重试（BACKOFF_RETRY）重试3次。每次重试的间隔...
监控数据相关问题
一般情况下，您只需关注以下指标项：实例消息生产流量 Topic消息生产流量 Group未消费消息总数 其他指标项（如实例/Topic消息生产条数、实例/Topic消息生产发送次数、实例/Topic消息消费次数等）数据在流量比较小或客户端版本比较低时，会...
数据流入规则管理
云消息队列 RocketMQ 版 实例版本 仅4.0系列实例支持 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 通过消息流入或消息流出规则进行数据互通时，云消息队列 RocketMQ 版 仅4.0系列实例支持消息流入或流出规则，5.0系列实例不支持。...
名词解释
在使用 云消息队列 MQTT 版 前，需理解该产品和MQTT协议所涉及的基本概念和术语。基本概念 实例（Instance）创建购买 云消息队列 MQTT 版 服务的实体单元，每个 云消息队列 MQTT 版 实例都对应一个全局唯一的服务接入点URL。使用 云消息...
迁移上云操作
和开源Apache RocketMQ相比，阿里云 云消息队列 RocketMQ 版 具有更高的稳定性、安全性及更完善的运维体系。您可以将开源RocketMQ集群迁移到 云消息队列 RocketMQ 版 上以获得更好的业务体验。本文为您介绍如何使用 云消息队列 RocketMQ 版...
消息处理时长自适应
本文介绍如何使消息处理时长自适应。背景信息 消息服务MNS 的规范中，每条消息都有个默认的VisibilityTimeout，Worker在接收到消息后，Timeout就开始计时了。如果Worker在Timeout时间内没能处理完消息，那么消息就有可能被其他Worker接收到...
订阅关系（Subscription）
本文介绍 云消息队列 RocketMQ 版 中订阅关系（Subscription）的定义、模型关系、内部属性及使用建议。定义 订阅关系是 云消息队列 RocketMQ 版 系统中消费者获取消息、处理消息的规则和状态配置。订阅关系由消费者分组动态注册到服务端...
迁移上云概述
提供以下体系化容灾方案：同城双活 异地容灾 迁移方案原理 方案基本要求 RocketMQ广泛应用于订单交易、在线支付等核心链路场景，消息收发的上下游链路对消息服务的稳定性要求比较严格，因此RocketMQ集群的迁移和替换必须慎重，迁移方案的...
应用调研
在上云实施阶段，应用调研的目标，是为了解应用的应用架构以及使用的技术组件，以制定云上目标详细方案，包含云上应用架构设计，产品选型及容量评估、迁移方案以及割接方案，所以这一阶段调研的信息比较详细。应用架构及依赖 应用架构 应用...
示例代码
云消息队列 RocketMQ 版 5.x版本实例可兼容4.x/3.x SDK客户端接入，您可以使用4.x/3.x版本的SDK接入5.x实例进行消息收发。本文为您介绍4.x/3.x版本下的C++ SDK消息收发示例代码。重要 推荐您使用最新的RocketMQ 5.x系列SDK，5.x系列SDK作为...
MQTT和RocketMQ进行数据互通（客户端上下线通知）
使用消息队列RocketMQ版消费端来处理MQTT客户端的上下线通知时，订阅的Topic为上下线通知Topic。final String parentTopic="GID_XXXX_MQTT;客户端状态数据，实际生产环境中建议使用数据库或者Redis等外部持久化存储来保存该信息，避免应用...
OnsRegionList-获取地域信息列表
在您使用 SDK 接入云消息队列 RocketMQ 版服务并进行管控操作时，需要依次指定两个地域的信息，第二个地域的信息才是通过 OnsRegionList 接口获取。具体场景如下：将您的应用接入云消息队列 RocketMQ 版服务：根据您的应用的部署地域选择...
上下线通知规则管理
云消息队列 RocketMQ 版 实例版本 仅4.0系列实例支持 云消息队列 MQTT 版 和 云消息队列 RocketMQ 版 通过消息流入或消息流出规则进行数据互通时，云消息队列 RocketMQ 版 仅4.0系列实例支持消息流入或流出规则，5.0系列实例不支持。...
元数据导入
本文介绍如何在 云消息队列 Kafka 版 控制台创建元数据导入任务，将元数据迁移至 云消息队列 Kafka 版 已有实例。前提条件 下载JDK 8 购买并部署云消息队列 Kafka 版实例：购买并部署VPC实例 购买并部署公网/VPC实例 说明 购买实例的规格可...
用户身份识别
为提高数据安全性，云消息队列 RocketMQ 版 服务端会在客户端接入时对客户端进行身份验证，仅通过验证的客户端才能连接服务端进行消息收发。同时 云消息队列 RocketMQ 版 支持ACL身份识别，您可以按需为指定ACL用户赋予具体的Topic或Group...
迁移自建Kafka集群至新实例
本文介绍如何在 云消息队列 Kafka 版 控制台创建并启动迁移任务。前提条件 下载JDK 8 安装Tsar 为了更准确的获取执行机器的配置，推荐您提前安装Tsar软件。您也可以在运行迁移工具时通过指定-installTsar 参数自动安装Tsar软件，但自动安装...
通过元数据文件迁移上云
本文介绍如何在 云消息队列 Kafka 版 控制台创建迁移任务，将元数据迁移至 云消息队列 Kafka 版 已有实例。前提条件 下载JDK 8 购买并部署 云消息队列 Kafka 版 实例：购买并部署VPC实例 购买并部署公网/VPC实例 背景信息 Kafka集群元数据...
中间件产品总览
Spring Boot 自研的开发框架 集成 SOFA 中间件，且中间件可插拔 服务网格 将传统微服务和 Service Mesh 进行融合 对接经典应用服务和容器应用服务 提供丰富的服务治理功能 消息队列 基于 Apache RocketMQ 构建的分布式消息中间件 ...
集群资源规格评估
对于 云消息队列 Confluent 版 集群来说，影响资源使用的因素众多，包括使用的业务场景、业务应用程序性能等，本文结合一般场景给出 云消息队列 Confluent 版 集群资源评估参考建议，帮助您在购买创建集群时评估集群规模。在集群创建完成后...
在线教育视频直播
部署架构图 选用的产品 云消息队列 RocketMQ 版 云消息队列 RocketMQ 版 是由阿里巴巴自研并捐赠给Apache基金会，并与开源社区共建的消息中间件，该产品服务于阿里巴巴集团已超过13年，经过交易核心链路反复打磨与历年双十一高并发场景的...
产品概述
平台组件：是指产品对平台提供的服务目录的依赖项，例如：一个办公软件，依赖MQ消息中间件，如果用户希望由ADP平台提供该中间件，则他应该在产品依赖中，声明对该MQ组件的依赖。用户组件：是指用户自身代码构建的业务应用，打包上传至ADP...
版本说明
0.6（2020-01-10）发布 SOFAStack 消息队列，是基于 Apache RocketMQ 构建的分布式消息中间件，并与金融分布式架构 SOFAStack 深度集成。支持多种消息类型：普通消息、定时消息、分区顺序消息、事务消息。详见 消息类型。提供专业、可靠、...
创建和管理 Topic
Topic 是 SOFAStack 消息队列里对消息的一级归类，消息生产者将消息发送到 Topic，而消息消费者则通过订阅该 Topic 来获取和消费消息。创建 Topic 登录 SOFAStack 控制台。在左侧导航栏，选择 中间件>消息队列>Topic 管理。单击 创建 Topic...
集成概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 Connector生态集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据...
概述
云消息队列 Kafka 版 快速入门操作流程 操作步骤 具体操作步骤如下：步骤一：获取访问授权 步骤二：购买和部署实例 VPC接入 公网和VPC接入 步骤三：创建资源 步骤四：使用SDK收发消息 默认接入点收发消息 SSL接入点PLAIN机制收发消息 视频...
资源使用变更
云消息队列 MQTT 版 从V2.x.x升级至V3.x.x实现了自身数据存储的能力，同时还去除了对 云消息队列 RocketMQ 版 的消息依赖，因此，云消息队列 MQTT 版 的实例和Topic使用有变更。资源 V2.x.x使用说明 V3.x.x使用说明 云消息队列 MQTT 版 ...
定时和延时消息
本文主要介绍 云消息队列 RocketMQ 版 的定时消息和延时消息的概念、适用场景以及使用过程中的注意事项。概念介绍 定时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是推迟到在当前时间点...
什么是消息演练
消息演练概述 目前市面上有RocketMQ、Kafka、RabbitMQ等流行的消息中间件服务，消息演练功能将这些常见的中间件进行了统一抽离，为消息服务安排分配了精选后的演练最佳实践。您无需分析每种消息服务需要什么演练场景，仅需选择演练方案即可...
消息轨迹
消息轨迹是指一条消息从生产者发送到 云消息队列 RabbitMQ 版 服务端，再到消费者消费，整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整链路信息。如果消息收发不符合预期，您可以通过查询消息轨迹，快速分析和定位问题，及时...
死信队列
对于消费失败且重试后依然失败的消息，云消息队列 RocketMQ 版 不会立丢弃，而是将消息转发至指定的队列中，即死信队列，这些消息即为死信消息。当消费失败的原因排查并解决后，您可以重发这些死信消息，让消费者重新消费；若您暂时无法...
快速入门
如果您是首次使用 云消息队列 RocketMQ 版，您可以参考快速入门文档，了解如何购买实例并接入 云消息队列 RocketMQ 版 服务端完成基本的消息收发流程。使用流程 快速使用 云消息队列 RocketMQ 版 收发消息的流程如下图所示。详细操作，请...
概述
SOFAStack 消息队列（SOFAStack MQ，简称 SOFAMQ）是基于 Apache RocketMQ 构建的分布式消息中间件，并与金融分布式架构 SOFAStack 深度集成，为分布式应用系统提供异步解耦和削峰填谷的能力，支持事务消息、顺序消息、定时消息等多种消息...
消息存储和清理机制
本文为您介绍 云消息队列 RocketMQ 版 中消息的存储机制，包括消息的存储粒度、判断依据及后续处理策略等。背景信息 参考 云消息队列 RocketMQ 版 中 队列 的定义，消息按照达到服务器的先后顺序被存储到队列中，理论上每个队列都支持无限...
- 产品推荐
- 这些文档可能帮助您