达梦数据总线用户手册：消息路由与交换

"DMETL_Databus - 达梦数据总线用户手册" 达梦数据总线（DMETL_Databus）是达梦数据库有限公司提供的一种数据交换平台，主要用于在网络环境中连接各种异构系统和数据源，实现数据的安全、可靠传输。DM数据交换平台的核心特点是采用消息中间件技术，通过内嵌的消息服务器和数据总线服务器（DataBusServer）进行消息的路由转发。 1.1 概述 DMETL_Databus的运作机制是：在每个ETL（Extract, Transform, Load）内部集成一个消息服务器，消息服务器上设有发布队列和订阅队列。当需要进行数据交换时，源ETL将消息推送到其内嵌的发布队列，而目标ETL则从订阅队列接收消息。数据总线服务器作为中介，负责从源ETL的发布队列获取消息并转发至目标ETL的订阅队列，支持一对一和一对多的路由模式。 1.2 数据（消息）交换流程 数据交换流程可以概括为以下步骤： 1. 源ETL服务器将消息发送到源消息服务器的发布队列。 2. 数据总线服务器（DataBusServer）接收发布队列中的消息。 3. DataBusServer根据预设的路由规则将消息转发至目的消息服务器的订阅队列。 4. 目的ETL服务器从订阅队列接收消息，进行进一步处理或存储。 2.1 数据总线路由的使用概述 使用DMETL_Databus进行数据交换涉及三个主要步骤： 1. ETL创建发布和订阅数据集：在ETL中定义数据集的同时，会在对应的消息服务器上创建相应的发布或订阅队列。 2. ETL创建发布和订阅流程：发布流程负责推送数据至发布队列，订阅流程则从订阅队列获取数据并进行清洗转换。 3. 配置DataBusServer的路由信息：定义ETL间发布队列到订阅队列的路由规则，使DataBusServer能够根据这些规则进行消息转发。 2.2 创建发布、订阅数据集与流程 创建发布数据集意味着在ETL内部创建一个数据源，这个数据源将被推送到发布队列。订阅数据集则是ETL接收数据的目标，它会从订阅队列中获取数据。发布流程和订阅流程分别用于处理发送和接收数据的逻辑。 2.3 数据总线路由配置 2.4.1 数据总线配置文件：包含ETL服务器之间的路由信息，定义了哪些发布队列应将消息转发至哪些订阅队列。 2.4.2 数据总线路由引擎：负责解析配置文件并执行实际的消息路由操作，确保消息正确无误地传递到目的地。 DMETL_Databus通过高效的消息中间件技术和路由机制，为异构系统间的大量数据交换提供了稳定且可扩展的解决方案。无论是简单的数据同步还是复杂的数据转换，都能够借助此平台实现。