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.xsd
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd
http://www.mulesoft.org/schema/mule/file http://www.mulesoft.org/schema/mule/file/current/mule-file.xsd
http://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>概念：连接器、端点、轮询器（队列轮询机制）控制台数据源

Mule开发,布布扣,bubuko.com