首页 > 代码库 > Mule开发

Mule开发

每个项目的都有各自的场景,但是其实往小处说,场景的处理基本都是很相似,之前做copy文件的程序,其实就是一种很常见的ETL的过程(转移文件,异构系统通过文件系统交换数据,存在数据同步)。

了解一下ETL:就是数据转移的一个处理过程(A库与B库之间进行数据抽取)---最重要就是格式的转换。

了解一下ESB,专门的数据处理中心的平台系统(建立一个数据中心,对外提高数据服务)。

开源ESB平台:Mule,Spring Intergation

       数据源:DB,FTP,File,Socket,HTTP,JMS

==============================================================================================

mule例子:拷贝文件

File数据源:
<?
xml version="1.0" encoding="UTF-8"?><mule xmlns:file="http://www.mulesoft.org/schema/mule/file" xmlns:tracking="http://www.mulesoft.org/schema/mule/ee/tracking" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation" xmlns:spring="http://www.springframework.org/schema/beans" version="EE-3.4.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsdhttp://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsdhttp://www.mulesoft.org/schema/mule/file http://www.mulesoft.org/schema/mule/file/current/mule-file.xsdhttp://www.mulesoft.org/schema/mule/ee/tracking http://www.mulesoft.org/schema/mule/ee/tracking/current/mule-tracking-ee.xsd"> <file:connector name="FileConnector" streaming="true" pollingFrequency="5000"> <file:expression-filename-parser /> </file:connector> <model name="FileDataChange"> <service name="fileService"> <inbound> <file:inbound-endpoint path="c:/data/snapshot" /> </inbound> <outbound> <pass-through-router> <file:outbound-endpoint path="c:/data/archive" outputPattern="#[message.inboundProperties[‘originalFilename‘]]"/> </pass-through-router> </outbound> </service> </model></mule>
概念:连接器、端点、轮询器(队列轮询机制)
控制台数据源