java - 计算驼峰并行分割成功处理消息的数量

Question

我正在研究 Camel ，以便并行处理大量记录。我有这样的东西:

     from(CAMEL_START_ROUTE_CTE)       
         .multicast().parallelProcessing()
            .to(CAMEL_PROCESS_DOMAINS_ROUTE)
            .to(CAMEL_PROCESS_OTHERS_ROUTE)
         .end()
         .onCompletion()
         .to(EndCamelRouteBuilder.CAMEL_ROUTE);

CAMEL_START_ROUTE_CTE 所在位置

timer:foo?delay=100&repeatCount=1

然后，CAMEL_PROCESS_DOMAINS_ROUTE 如下所示:

 from(CAMEL_PROCESS_DOMAINS_ROUTE)
         .setHeader("domains").constant(config.getDomains())
             .split(header("domains"))          
             .parallelProcessing()
                .to(ProcessDomainCamelRoute.CAMEL_ROUTE)

             .end()
         .end();

简单来说，domains 是一个 json 列表。

我想要实现的是一种计算消息数量并能够在路由 EndCamelRoute 中读取它的方法

我尝试过将exchange.setProperty放入处理器(使用CamelSplitSize)、setHeader等...但在读取时我总是得到一个空值。

有人知道如何实现这样的目标吗？某种......报告内容(失败、成功消息的数量)，但在不同的 route 消耗

Answer 1

我在使用 split 时遇到了类似的问题。最终得到了一个非常简单的 bean，其中包含一个 HashMap ，我在其中存储计数器。我正在调查MicroMeter Component但它仅限于消费者。