Apache Camel Split组件内捕获异常并继续执行的最佳实践

问题核心原因 #

你之前的配置不生效，核心是两个默认机制的限制：

1. Camel的Split组件在并行处理模式下，只要任意分片抛出未处理的异常，默认会中断所有剩余分片的执行
2. Split生成的子分片Exchange默认使用独立的UnitOfWork，全局定义的onException默认无法捕获子分片内的异常

最佳实践配置 #

方案1：使用全局异常处理器

仅需要给你的Split配置添加两个参数即可，原有onException逻辑无需修改：

.split(body(), eventListAggregationStrategy)
    .parallelProcessing()
    .stopOnException(false) // 显式指定单个分片异常不终止其他分片
    .shareUnitOfWork() // 让子分片复用父路由的工作单元，使全局异常处理器可以捕获子分片异常
    .process(rawEventTransformationProcessor)
.end()

原有onException中的handled(true)已经保证异常处理完毕后不会向上回抛，不会触发Split的终止逻辑。

方案2：子分片内局部处理异常（更推荐）

如果不想影响全局异常规则，可以直接在Split内部通过doTry/doCatch处理异常，无需配置shareUnitOfWork和全局onException：

.split(body(), eventListAggregationStrategy)
    .parallelProcessing()
    .stopOnException(false)
    .doTry()
        .process(rawEventTransformationProcessor)
    .doCatch(RawEventTransformationException.class)
        .to("log:RawEventTransformationException?showAll=true&multiline=true&level=ERROR")
        .process(exchange -> {
            RawEventTransformationException cause = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, RawEventTransformationException.class);
            exchange.getIn().setBody(cause.getFailedEvent());
        })
        .marshal().json(JsonLibrary.Jackson, RawEvent.class)
        .to("rabbitmq://errors?queue=transformed-data-fails&routingKey=transformed-data-fails&autoDelete=false")
    .endDoTry()
.end()

这种方案的异常处理逻辑完全限定在当前Split的分片内，不会对其他路由产生干扰，也不需要在Processor中手动调用ProducerTemplate发送异常消息，减少冗余代码。

补充说明 #

如果你的聚合策略需要区分正常分片和异常分片，可以在聚合逻辑中判断Exchange是否存在Exchange.EXCEPTION_CAUGHT属性，自行决定异常分片的结果是否要计入最终聚合值。

内容的提问来源于stack exchange，提问作者karazy