Apache Camel 的 Aggregator2 将 XML 文档聚合成单个大文档

Question

是否可以聚合多个小型 XML 文档：

<doc><field name="XXX">fieldValue</field><doc>

使用 aggregator2 (camel 2.7.0) 将其聚合为一个大文档，

<result><doc>...</doc><doc>...</doc><doc>...</doc>...<doc>...</doc></result>

而不使用某些自定义聚合器处理器？我已经成功地创建了自定义聚合器，但现在我正在简化我的代码，所以如果camel支持开箱即用的话，我想摆脱它。

我的自定义聚合器如下所示：

class DocsAggregator implements Processor {
  void process(Exchange exchange) {

    def builder = DocumentBuilderFactory.newInstance().newDocumentBuilder()
    def Document parentDoc = builder.parse(new ByteArrayInputStream("<?xml version='1.0'?><add></add>".toString().bytes));
    def groupedExchanges = exchange.properties.find {it.key == 'CamelGroupedExchange'}

    groupedExchanges.value.each { Exchange x ->
    def Document document = x.'in'.body

    def bos = new ByteArrayOutputStream()
    TransformerFactory.newInstance().newTransformer().transform(new DOMSource(document), new StreamResult(bos))
    def node = document.documentElement.childNodes.find { Node it -> it.nodeType == Node.ELEMENT_NODE}
    def cloned = parentDoc.adoptNode(node)
    parentDoc.documentElement.appendChild(cloned)
   }
   exchange.in.body = parentDoc
  }
}

Answer 1

自定义聚合器处理器是指自定义聚合策略吗？如果是这样的话，那就不行了。目前这是必需的。

我们的路线图是为聚合提供一个 pojo 模型，这样您就不需要使用 Camel API。因此，希望将来这会变得更简单。

Answer 2

好的，您正在使用分组交换选项。然后就有点不同了。数据作为属性存储在交换中的列表中。

您可以使用 POJO 并将参数绑定到属性，而不是处理器。但 List 仍然包含 Exchange 对象，因此您需要对其调用 getIn().getBody() 方法。但如果你这样做，你不需要在 POJO 中导入任何 Camel API。

public Document mergeMyStuff(@Property("CamelGroupedExchange") List grouped) {

    Document parent = ...
    for (int i = 0; i < grouped.size; i++) {
        Document doc = list.get(i).getIn().getBody(Documemt.class);
        .. add to parent doc
    }

    return parent;
}