Apache Camel之資料轉換
在做系統整合的時候,必不可少的任務就是將資料從一種格式轉換為另一種格式,再把轉換後的格式發到目標系統:
Camel提供的Message translator可以分為:
■ Using a Processor
■ Using beans
■ Using <transform>
1,利用processor的方式在Apache Camel框架入門示例 已經有個介紹.blog.csdn.net/kkdelta/article/details/7231640
通過實現Processor的方法process(Exchange exchange),通常要做的步驟是,從inbound訊息裡得到資料,轉換,再放到outbound的訊息裡.
XXX data = exchange.getIn().getBody(XXX.class);
//轉換
exchange.getOut().setBody(yyyObject);
2,利用bean的方式,寫一個java bean如下:public class OrderToCsvBean { public String map(String custom) { String id = custom.substring(0, 9); String customerId = custom.substring(10, 19); String date = custom.substring(20, 29); String items = custom.substring(30); String[] itemIds = items.split("@"); StringBuilder csv = new StringBuilder(); csv.append(id.trim()); csv.append(",").append(date.trim()); csv.append(",").append(customerId.trim()); for (String item : itemIds) { csv.append(",").append(item.trim()); } return csv.toString(); } }
在route裡的程式碼如下:
from("file:d:/temp/inbox1/?delay=30000").bean(new OrderToCsvBean()).to("file:d:/temp/outbox1");
Camel有一套演算法來選擇呼叫bean裡的什麼方法(比如說message的header裡是否通過CamelBeanMethodName設定了方法名稱,bean是否只有一個方法,某一個方法是否加了@Handler註解等等),這裡的bean只有一個map方法,Camel會呼叫這個方法.
3,用route中已經定義好的transform方法,一般用的較少.
from("direct:start").transform(body().regexReplaceAll("\n", "<br/>")).to("mock:result");
4,Camel整合對許多常用的資料格式的解析:通過呼叫unmarshal方法可以得到解析後的結果.
CSV:
from("file:d:/temp/inbox1/?delay=30000").unmarshal().csv().process(processor).to("file:d:/temp/outbox1");
processor裡可以直接得到解析後的資料:
public class CSVProcessor implements Processor {
@Override
public void process(Exchange exchange) throws Exception {
System.out.println("process...");
List csvData = (List) exchange.getIn().getBody();
StringBuffer strbf = new StringBuffer();
if (csvData.get(0).getClass().equals(String.class)) {//single line CSV
strbf.append(parseOrder(csvData));
} else {//multiple line CSV
for (List<String> csvOrder : (List<List<String>>) csvData) {
strbf.append(parseOrder(csvOrder));
}
}
exchange.getOut().setBody(strbf.toString());
}
private String parseOrder(List<String> csvData) {
System.out.println(csvData.get(0) + "--" + csvData.get(1)+"--" +csvData.get(2));
return csvData.get(0) + "--" + csvData.get(1)+"--" +csvData.get(2);
}
}