Camel的数据转换

2024-04-27 23:58

文章标签 数据转换 camel

本文主要是介绍Camel的数据转换，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

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);
   }
}