领域模型概述
产品定位 云消息队列 RocketMQ 版 是一款典型的分布式架构下的中间件产品，使用异步通信方式和发布订阅的消息传输模型。通信方式和传输模型的具体说明，请参见下文 通信方式介绍 和 消息传输模型介绍。云消息队列 RocketMQ 版 产品具备异步...
顺序消息
顺序消息的使用范围是什么？顺序消息支持哪种消息发送方式？顺序消息是否支持集群消费和广播消费？顺序消息支持集群消费，不支持广播消费。同一条消息是否可以既是顺序消息，同时又支持定时消息和事务消息？不行。顺序消息、定时消息、事务...
中间件
比如使用Dubbo作为开发框架，Dubbo本身不是本文所说的 中间件，但是与Dubbo搭配使用的ZooKeeper，就是这里所谓的“中间件”。目前，平台提供的中间件相关的节点分成三类：阿里云节点：这些中间件，并不在这个方案中实际消耗云资源进行部署...
三方标准中间件对接
比如使用Dubbo作为开发框架，Dubbo本身不是本文所说的“中间件”，但是与Dubbo搭配使用的ZooKeeper，就是这里所谓的“中间件”。目前，平台提供的中间件相关的节点分成两类：三方节点：这些中间件来自于标准的开源中间件镜像，平台本身并不...
消息过滤
使用建议 合理划分主题和Tag标签 从消息的过滤机制和主题的原理机制可以看出，业务消息的拆分可以基于主题进行筛选，也可以基于主题内消息的Tag标签及属性进行筛选。关于拆分方式的选择，应遵循以下原则：消息类型是否一致：不同类型的消息...
什么是消息演练
消息演练概述 目前市面上有RocketMQ、Kafka、RabbitMQ等流行的消息中间件服务，消息演练功能将这些常见的中间件进行了统一抽离，为消息服务安排分配了精选后的演练最佳实践。您无需分析每种消息服务需要什么演练场景，仅需选择演练方案即可...
消息 Mesh
消息 Mesh 的价值 在传统的消息中间件领域，我们更关注的核心指标为：服务端的性能 服务可用性 数据可靠性等 有些能力与业务应用密切相关却表现不佳，主要包括：消息的流量控制：限流、熔断、灰度、着色、分组等。消息的服务治理：消息量级...
Topic 与 Tag
建议您从以下几个方面进行判断：消息类型是否一致：如普通消息、事务消息、定时或延时消息、顺序消息，不同的消息类型使用不同的 Topic。创建 Topic 时需要指定消息类型，无法通过 Tag 进行区分。业务是否相关联：没有直接关联的消息，如...
使用Spring Cloud框架收发消息
如果实例已开启ACL，请确保要使用的SASL用户为PLAIN类型且已授权收发消息的权限。具体信息，请参见 SASL用户授权。KafkaClient { org.apache.kafka.common.security.plain.PlainLoginModule required username="XXX"password="XXX;};进入/...
消息类型
使用方式 定时消息和延时消息的使用在代码编写上存在略微的区别：发送定时消息需要明确指定消息发送时间点之后的某一时间点作为消息投递的时间点。发送延时消息时需要设定一个延时时间长度，消息将从当前发送时间点开始延迟固定时间之后才...
组件编排
一个产品是由多个组件构成，包括用户组件和平台组件。同时，产品支持多个版本的迭代，一个产品版本，对应了一个完整的交付物。...服务组件：平台提供的各类开箱即用的中间件，可根据业务需要添加和配置，参考：如何集成中间件。
新建数据模版
当消息中间件作为数据源时，需要通过创建数据模版来解释消息中间件中消息的结构。本文介绍如何新建数据模版。操作步骤 登录 数据资源平台控制台。在页面左上角，单击 图标，选择 协同。在顶部菜单栏，单击 图标，选择目标工作组，单击 资产...
新建数据模版
当消息中间件作为数据源时，需要通过创建数据模版来解释消息中间件中消息的结构。本文介绍如何新建数据模版。操作步骤 登录企业数据智能平台。在页面左上角，单击 图标，选择 协同。在顶部菜单栏，单击 图标，选择目标工作组，单击 资产...
操作链路概述
创建工作空间 要使用消息队列，您需要确保 SOFAStack 控制台已创建至少一个工作空间。如 SOFAStack 未创建工作空间或您需要创建一个新的工作空间，可参见 添加工作空间。创建好工作空间后，将为您自动创建一个消息队列实例。创建 Topic ...
基本对象概念
正如在 Java 和 C++ 等编程语言中所了解的，面向对象的编程着重于对象的概念。对象是现实世界实体的表示形式，如个人、地点或事物。对特定对象（如个人）的统一描述或定义称为对象类型。特定的人（如“Joe”或“Sally”）就是所谓的对象...
功能与优势
上下游数据连接（Connector）涵盖阿里云产品和开源社区30+主流引擎，涉及数据库、消息中间件、数据仓库、湖格式、文件系统等多种上下游存储。支持特有数据模拟Connector贴近业务含义的测试数据。相对开源版本，Connector也有诸多易用性和...
现代IM系统中的消息系统—模型
Timeline是一个面向海量消息的数据模型，同时用于消息存储库和同步库，需要满足多种要求。支撑海量数据存储：对于消息存储库来说，如果需要消息永久存储，则随着时间的积累，数据规模会越来越大，需要存储库能应对长时间积累的海量消息数据...
OPT_PARAM Hints
enable_partitionwise_aggregate 允许或禁止查询规划器使用面向分区的分组或聚集，这使得在分区表上的分组或聚集可以在每个分区上分别执行。如果GROUP BY子句不包括分区键，只有部分聚集能够以基于每个分区的方式执行，并且finalization...
OPT_PARAM Hints
enable_partitionwise_aggregate 允许或禁止查询规划器使用面向分区的分组或聚集，这使得在分区表上的分组或聚集可以在每个分区上分别执行。如果GROUP BY子句不包括分区键，只有部分聚集能够以基于每个分区的方式执行，并且finalization...
基础术语
部署单元 Cell 使用独立的中间件服务，属于一个独立的物理可用区或者跨多个物理可用区。技术栈 Buildpack 在 SOFAStack 平台上，是指一个应用程序所依赖的全部框架及附属资源的集合，它定义了应用发布部署和运维时的依赖信息，主要包括操作...
业务流量隔离功能实践
具体需求内容包括：采用跟生产环境不同的中间件（微服务注册中心、MQ实例等），搭建一套常态化运行的安全生产环境，并建立统一的灰度发布流程，经过安全生产环境的灰度发布和观测验证后，才允许发布到生产环境。固定从生产环境引流1%的HTTP...
概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 消息集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据格式转换等...
概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 消息集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据格式转换等...
概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 消息集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据格式转换等...
SOFAMQ 常见问题
上述方式可以查询到消息的具体内容以及消费情况，如果需要追踪一条消息从生产者发出到被消费者消费的整个链路中各个相关节点的时间地点，可以使用消息队列最新的消息轨迹查询功能，具体使用方式请参考 查询消息轨迹。消息队列是否能保证...
同步 OceanBase 数据库的数据至 RocketMQ
背景信息 消息队列 RocketMQ 是阿里云基于 Apache RocketMQ 构建的低延迟、高并发、高可靠的分布式消息中间件。数据传输的数据同步功能可以帮助您实现 OceanBase 数据库的物理表和 RocketMQ 数据源之间的数据实时同步，扩展消息处理能力。...
功能特性
标准化交付部署能力 一键快速部署Kubernetes集群、各个依赖的中间件，以及业务应用自身的组件。提供IaaS解耦能力，加速国产化适配，支持GPU驱动管理。提供基于本地磁盘的增强能力，实现动态供应能力。本地运维能力 提供环境预检能力，实现...
产品优势
集成全套金融级中间件 提供各种默认配置，引入依赖无需额外部署，只需引入所需中间件的 Starter 就能直接使用所需的中间件。统一易用的编程接口 每一个 SOFA 中间件都是独立可插拔的组件，对集成的 SOFA 中间件提供统一易用的编程接口，...
如何集成中间件
本文描述如何在产品中集成平台提供的中间件。ADP应用交付平台提供了丰富的中间件，用于帮助产品解决在异构云、私有化场景下，对外部通用中间件服务的依赖问题。产品对中间件的集成，分3步：添加服务组件、配置参数、代码引用。1.添加服务...
集成概述
目前已打通日志、数据库、消息中间件等多种场景的数据接入。数据清洗/数据流出 Connector生态集成提供了强大的、界面化的数据ETL（Extract-Transform-Load）配置能力，方便快捷地对完成上报、进入到消息队列的数据进行清洗、格式化、数据...
什么是云原生应用交付平台ADP
ADP服务目录：提供可以基于ADP运行时进行部署和运维的中间件、数据库组件。核心能力 中间件集成 ADP平台提供了组件中心，用于方便应用集成中间件。服务中心提供了所有目前支持的中间件，您可以按需将中间件集成在自己的应用中。这些中间件...
消息查询
按 Topic 查询：即根据 Topic 和消息的发送时间范围，批量获取该时间范围内的所有消息，查询量大，不易匹配，一般用在 Message ID 和 Message Key 都无法获得的情况下。信息输入完毕后，单击 搜索。在 消息查询 页面，您可以查看到所有查询...
应用场景
通用分布式事务管理 提供通用的分布式事务管理能力，支持微服务框架（Spring Cloud、Dubbo 和 HSF）、数据库（DRDS、RDS、MySQL、Oracle等）、消息中间件（MQ）的组合使用，灵活方便。多业务场景：通过混合事务，GTS可以应用到金融、电信、...
概述
SOFAStack 消息队列（SOFAStack MQ，简称 SOFAMQ）是基于 Apache RocketMQ 构建的分布式消息中间件，并与金融分布式架构 SOFAStack 深度集成，为分布式应用系统提供异步解耦和削峰填谷的能力，支持事务消息、顺序消息、定时消息等多种消息...
阿里巴巴信用平台
芝麻信用 芝麻信用是蚂蚁金服旗下的芝麻信用管理有限公司推出的面向个人的一套信用服务体系。该系统收集来自政府、金融系统的数据，还会充分分析用户在淘宝、支付宝等平台的行为记录，运用方方面面的大数据和云计算技术客观呈现个人的信用...
死信队列
查询死信消息 消息队列提供以下两种查询死信消息的方式：按 Group ID 查询：根据 Group ID 和时间范围，批量获取符合条件的所有消息；查询量大，不易匹配。按 Message ID 查询：根据 Group ID 和 Message ID 可以精确定位任意一条消息。按 ...
创建和管理 Topic
Topic 是 SOFAStack 消息队列里对消息的一级归类，消息生产者将消息发送到 Topic，而消息消费者则通过订阅该 Topic 来获取和消费消息。创建 Topic 登录 SOFAStack 控制台。在左侧导航栏，选择 中间件>消息队列>Topic 管理。单击 创建 Topic...
查看消费者状态
实时消费速度：该 Group ID 下消费者群组接收消息的总 TPS，单位为“条/秒”。实时消息堆积量：该 Group ID 下消费者群组的未消费消息的总量。最近消费时间：该 Group ID 下消费者群组最近一次消费消息的时间。消息延迟时间：该 Group ID ...
查询消息轨迹
消费结果未返回：消费消息的方法尚未返回结果，或者被中断，导致本次消费结果未传回服务端。消费成功：该消息已被成功消费。消费失败：消费消息的方法主动返回失败标志，或者是消费方法抛异常。说明 如需删除某个查询任务，可在消息轨迹...
管理线下IDC的数据接入任务
参数 说明 请选择要监控的中间件 主机的中间件。包括：Spring、Tomcat、Nginx、Tengine、JVM、Redis、MySQL和其他。自定义中间件 自定义中间件的名称。当 请选择要监控的中间件 选择 其他 时，需要输入自定义中间件的名称。任务名 数据接入...
- 产品推荐
- 这些文档可能帮助您