「ファイルを一方のフォルダから他方のフォルダにコピーする」サンプルを例にとり、色々な方法でやってみる。

Javaで作成

以下のモデルをJavaで作成してみる。

ネットの情報を参考にJavaのみで書いてみる。

 public class Main {
         public static void main(String args[]) throws Exception {
                 File inboxDirectory = new File("/home/knoppix/Desktop/inbox");
                 File outboxDirectory = new File("/home/knoppix/Desktop/outbox");
                 outboxDirectory.mkdir();
                 File[] files = inboxDirectory.listFiles();
                 for (File source : files) {
                         //出力ファイル名の拡張子を日付に変える
                         Date date = new Date();
                         SimpleDateFormat sdf1 = new SimpleDateFormat("yyyyMMdd'-'HH'.'mm'.'ss");
 
                         String[] strArray = source.getName().split("\\.");
                         String destFileName ="";
                         for(int i=0; i<strArray.length-1;i++){
                                 destFileName +=destFileName.concat(strArray[i]);
                         }
                         destFileName += destFileName.concat("." + sdf1.format(date));
                         
                         File dest = new File(outboxDirectory.getPath() + File.separator
                                         + destFileName);
                         copyFile(source, dest);
                 }
         }
 
         private static void copyFile(File source, File dest) throws IOException {
                 OutputStream out = new FileOutputStream(dest);
                 byte[] buffer = new byte[(int) source.length()];
                 FileInputStream in = new FileInputStream(source);
                 
                 in.read(buffer);
                 try {
                         out.write(buffer);
                         System.out.println("Copy from " +source.getAbsolutePath() + " To " + dest.getAbsoluteFile());
                 } finally {
                         out.close();
                         in.close();
                 }
         }
 }

このような感じになる。後述するCamelを使う場合に比べ下記の問題がある。

フォルダが変更になったり、送信先が増えたり、プロトコルが変わったり(例えばFTP送信に変更)した場合、コードの変更が煩雑になり、要件が増えるにつれてコードが読みにくくなる
プログラム起動時に送信元フォルダにあったファイルだけが処理される。頻繁に送信元フォルダにファイルが置かれる場合、cron等を使って定期的にプログラムを起動する必要がある
エラーの場合、特殊ケースに対する処理が貧弱(というかない！)。様々なパターンを考慮したコードを追加する必要がある。
- 例えばフォルダがない場合、同一ファイルの扱い、途中でシステムダウンした場合…

Camelで作成

続いてCamelを使って同じことをやってみる。ここではCamelのルーティング言語の一つであるJavaDSLを利用。

送信元フォルダにあるファイルを送信先にコピーする Camel版

メイン

最初にメインコード

 import org.apache.camel.impl.DefaultCamelContext;
 
 public class Main {
         public static void main(String args[]) throws Exception {
                 // 1：最初にCamelContextを作成する
                 CamelContext context = new DefaultCamelContext();
                 RouteBuilder routeBuilder = new FileToFileRoute();
                 context.addRoutes(routeBuilder);
 
                 // 2:作成したCamelContextを開始し、60秒後に停止
                 context.start();
                 Thread.sleep(60000);
                 context.stop();
         }
 }

処理(ルーティング)

public class FileToFileRoute extends RouteBuilder {
	
	@Override
	public void configure() throws Exception {
		from("file:/home/knoppix/Desktop/inbox?noop=true&delay=5000")   //noop=true:処理後、
                                                                                //ファイルの削除をしない
		        .to("file:/home/knoppix/Desktop/outbox?fileName=${file:name.noext}.${date:now:yyyyMMdd-HH:mm:ss}");
	}
}

Camel＋Springで作成

Springを使ってCamelを動作させることも可能。Springを使うことでトランザクションマネージャに参加することができる。SpringDSLをつかって記述してみる。

送信元フォルダにあるファイルを送信先にコピーする Camel+Spring版

 public class Main {
 
         /**
          * @param args
          */
         public static void main(String args[]) throws Exception {
                 //　${CLASSPATH}/META-INF/spring/*.xmlファイルを探して実行する
                 //　ルーティングは${CLASSPATH}/META-INF/spring/myRoute.xmlで定義している
                 System.out.println("デスクトップのinbox内ファイルを置くとoutboxにコピーされます。");
                 System.out.println("DEBUGログはmylog.logを参照してください");
                 System.out.println("Ctrl-Cで終了してください。");
                 org.apache.camel.spring.Main.main(args);
         }
 }

META-INF/spring配下にルーティング用のXMLファイルを置く。名前は任意。

 <?xml version="1.0" encoding="UTF-8"?>
 
 <beans xmlns="http://www.springframework.org/schema/beans"
         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-3.0.xsd
 http://camel.apache.org/schema/spring
 http://camel.apache.org/schema/spring/camel-spring.xsd">
 
 <!-- Camel Contextのコンフィギュレーション -->
         <camelContext xmlns="http://camel.apache.org/schema/spring">
                 <route id="route_ファイル読み込んだ後に書込み">
                         <from uri="file:/home/knoppix/Desktop/inbox?noop=true&amp;delay=5000" />
                         <to uri="file:/home/knoppix/Desktop/outbox?fileName=${file:name.noext}.${date:now:yyyyMMdd-HH:mm:ss}" />
                 </route>
         </camelContext>
 </beans>

日本Apache Camelユーザ会

Javaで作成

Camelで作成

メイン

処理(ルーティング)

Camel＋Springで作成