日本Apache Camelユーザ会
edit「ファイルを一方のフォルダから他方のフォルダにコピーする」サンプルを例にとり、色々な方法でやってみる。
= Javaで作成 =
以下のモデルをJavaで作成してみる。
[[Thumb(fileToFileJava.png, size=large, caption=送信元フォルダにあるファイルを送信先にコピーする Java版)]]
ネットの情報を参考にJavaのみで書いてみる。
{{{ code 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を利用。
[[Thumb(fileToFileCamel.png, size=large, caption=送信元フォルダにあるファイルを送信先にコピーする Camel版)]]
=== メイン ===
最初にメインコード
{{{ code java
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をつかって記述してみる。
[[Thumb(fileToFileCamelSpring.png, size=large, caption=送信元フォルダにあるファイルを送信先にコピーする Camel+Spring版)]]
{{{ code java
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ファイルを置く。名前は任意。
{{{ code html
<?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&delay=5000" />
<to uri="file:/home/knoppix/Desktop/outbox?fileName=${file:name.noext}.${date:now:yyyyMMdd-HH:mm:ss}" />
</route>
</camelContext>
</beans>
}}}