2

我收到了一个文件，其中包含由换行符 (" \n") 分隔的数字 ID：

123948
939904
129384
234049

等我想使用 Camel 将文件转换为以下 POJO 的实例：

public class IDFile {
    private String fileName;    // The name of the file
    private List<Long> ids;     // All the IDs in the file (123948, 939904, etc.)

    // Constructor, getters/setters, etc.
}

我正在尝试查看是否可以使用 Camel 的Splitter组件来执行此操作，但感觉就像我正在尝试将圆形钉子强行插入方孔：

<route>
    <from uri="file://input/idfile"/>
    <split streaming="true">
        <tokenize token="\n" />
        <to uri="bean://idfileProcessor?method=process"/>
    </split>
</route>

上面看起来它会将我的文件拆分为List<Long>，但我还需要与列表关联的文件名。有任何想法吗？

4

1 回答 1

4

交易所上有一个标题“CamelFileName”。您的处理器/bean 传递了对交换的引用，您可以从那里获取标头并将其与您被调用的令牌相关联。

您的路线可能如下所示：

<camel:route id="splitter_test">
    <camel:from uri="file:///home/steppra1/camel_test?delete=true&amp;idempotent=true" />
    <camel:to uri="bean:splitBean?method=init" />
    <camel:split streaming="true">
        <camel:tokenize token="\n" />
        <camel:to uri="bean:splitBean?method=addToken" />
    </camel:split>
    <camel:to uri="bean:splitBean?method=done" />
    <camel:log message="${in.body}" loggingLevel="INFO" logName="split_test" />
</camel:route>

您用来维护交换对象状态的 bean：

public class SplitBean {
    public Object init(Exchange exchange) {
        exchange.setProperty("splitTokens", new ArrayList<Integer>());
        return exchange.getIn().getBody();
    }

    public Object addToken(Exchange exchange) {
        ((List<Integer>)exchange.getProperty("splitTokens")).add(Integer.parseInt((String)exchange.getIn().getBody()));
        return null;
    }

    public Tuple done(Exchange exchange) {
        return new Tuple<String, List<Integer>>((String)exchange.getIn().getHeader("CamelFileName"), (List<Integer>)exchange.getProperty("splitTokens"));
    }
}

包含行的文件

1
2
3
5

馈送到名为 splitter.text 和 splitter_2.txt 的路由会产生以下日志输出：

2013-12-18 18:20:02,081 INFO  split_test - Tuple [first=splitter.txt, second=[1, 2, 3, 5]]
2013-12-18 18:20:46,610 INFO  split_test - Tuple [first=splitter_2.txt, second=[1, 2, 3, 5]]

高温高压

于 2013-12-18T15:49:24.930 回答