1、概要:　　

　　本專案主要是通過在Spring平臺上配置Camel、FTP，實現定時從FTP伺服器下載檔案到本地、解析檔案、存入資料庫等功能。　　

2、搭建空專案:

　　Spring Boot有幾種自動生成空專案的機制：CLI、Spring tool suite、網站Spring Initializr，我們選擇第三個。

1. 訪問網站http://start.spring.io/，如下圖
   
2. 在dependencies新增依賴包的時候，在框中輸入camle、jdbc、mysql會自動彈出提示，確認即為選中，如下圖：
   
3. 點選 generate project按鈕，生成專案，並將其匯入到ecipse，在pom.xml中新增camel-ftp依賴，注意版本號選擇與camel-spring-boot-stater的相同
   

   <
    
   dependency>
       <groupId>org.apache.camel</groupId>
       <artifactId>camel-ftp</artifactId>
       <version>2.18.0</version>
   </dependency>

4. 完整版的pom.xml檔案如下：
   

   <dependencies>
       <dependency>
           <groupId>org.apache.camel</groupId>
           <
    
   artifactId>camel-spring-boot-starter</artifactId>
           <version>2.18.0</version>
       </dependency>
       <dependency>
           <groupId>org.apache.camel</groupId>
           <artifactId>camel-ftp</artifactId>
           <version>2.18.0</version>
    
   
       </dependency>
       <dependency>
           <groupId>org.springframework.boot</groupId>
           <artifactId>spring-boot-starter-jdbc</artifactId>
       </dependency>
       <dependency>
           <groupId>mysql</groupId>
           <artifactId>mysql-connector-java</artifactId>
           <scope>runtime</scope>
       </dependency>
       <dependency>
           <groupId>org.springframework.boot</groupId>
           <artifactId>spring-boot-starter-test</artifactId>
           <scope>test</scope>
       </dependency>
   </dependencies>

5. 待所有依賴jar下載到本地，基礎專案搭建完成

 3、配置Camel完成從ftp伺服器定時下載檔案到本地

1. 在application.properties中配置遠端FTP伺服器的地址、埠、使用者名稱和密碼等資訊
   

   ftp.server.info=sftp://172.16.20.133:22/../home/temp/data?username=root&password=root&delay=5s&move=done&readLock=rename
   
   ftp.local.dir=file:C:/ftp/test

   注意：sftp伺服器的檔案位置是相對於root登入後的相對地址（被這裡坑到了），delay=5s是每隔5秒鐘掃描ftp伺服器上是否有新檔案生成，如果有下載到本地，並將伺服器上的檔案轉移到done資料夾（/home/temp/data/done）,readLock=rename可以阻止camel讀取正在被寫入的檔案

2. 配置路由，完成檔案下載
   

   @Component
   public class DownloadRouteDemo extends RouteBuilder {
       
       private static Logger logger = LoggerFactory.getLogger( DownloadRouteDemo.class );
   
       @Value("${ftp.server.info}")
       private String sftpServer;
       @Value("${ftp.local.dir}")
       private String downloadLocation;
   
       @Override
       public void configure() throws Exception {
           from( sftpServer ).to(  downloadLocation ).log(LoggingLevel.INFO, logger, "Downloaded file ${file:name} complete.");
       }
   
   }

   注意：要繼承camel的RouteBulider，重寫configure方法，大意是從ftp伺服器下載檔案到本地，並輸出檔名（執行時所需必要資訊都配置在application.properties檔案中）

3. 為了讓java程序在後臺執行，需要在application.properties檔案中增加如下配置
   

   camel.springboot.main-run-controller=true

4. 從ftp伺服器下載檔案的所有工作都已完成，執行CamelFtpSpringApplication.java，如果你的ftp伺服器相應的位置上有檔案，就會下載到本地所配置的資料夾下

 4、通過camel定時解析本地檔案並儲存到資料庫

1. 在application.properties中增加如下配置
   

   route.parserfile.info = {{ftp.local.dir}}?delay=10s&move=done&readLock=rename
   route.parserfile.dir = {{ftp.local.dir}}/done

   注意兩個花括號是引用其他變數的配置

2. 編寫解析檔案、入庫程式等處理器
   

   @Component
   public class LocationFileProcessor implements Processor {
   
       private static Logger logger = LoggerFactory.getLogger( LocationFileProcessor.class );
       
       
       @Value("${ftp.local.dir}")
       private String fileDir;
   
       @Autowired
       OrderService orderService;//業務邏輯處理元件
       
       @Override
       public void process(Exchange exchange) throws Exception {
           GenericFileMessage<RandomAccessFile> inFileMessage = (GenericFileMessage<RandomAccessFile>) exchange.getIn();
           String fileName = inFileMessage.getGenericFile().getFileName();//檔名
           String splitTag = File.separator;//系統檔案分隔符
           logger.info(fileDir + splitTag + fileName);//檔案的絕對路徑
           orderService.process(fileDir + splitTag + fileName);//解析入庫等操作
           
       }
   
   }

   
   
   
3. 配置路由，完成業務邏輯的串聯
   

   @Component
   public class LocalTransformRoute  extends RouteBuilder {
   
       private static Logger logger = LoggerFactory.getLogger( LocalTransformRoute.class );
       
       @Value("${route.parserfile.info}")
       private String location;
       
       @Value("${route.parserfile.dir}")
       private String locationDir;
       
       @Autowired
       LocationFileProcessor locationFileProcessor;
       
       @Override
       public void configure() throws Exception {
           from( location ).process( locationFileProcessor ).to( locationDir ).log(LoggingLevel.INFO, logger, "tirans  file ${file:name} complete.");
       }
   
   }

   注意，比上面的路由多了process配置，即業務邏輯處理配置

4. 至此，所有工作都已完成，重新執行CamelFtpSpringApplication.java即可實現ftp檔案定時下載、業務處理等（其中省去了很多，例如入庫操作等）

備註：只是camle spring ftp的一個演示demo，要運用於生產，還有好多需要完善的地方