Apache Camel如何在onCompletion中检测链式路由首尾路由

首先明确核心结论：
Apache Camel 没有内置自动识别跨路由逻辑链路首尾节点的能力，你全局配置的onCompletion默认是路由级生效，会绑定到每一个路由上，每个路由执行完成后都会触发回调，这是符合组件设计预期的行为。
尤其你的链路里用了quartz、activemq topic这类异步端点，前一个路由把消息发到topic之后就已经执行结束了，和后面消费topic的路由使用的是完全独立的Exchange实例、运行在不同线程中，框架层面根本无法自动感知这几个路由属于同一条逻辑链路，自然也没法自动判定哪个是最后一个节点。

推荐实现方案 #

方案1：给最后一个路由单独配置路由级onCompletion（最优） #

这是逻辑最清晰、无额外判断成本、性能最好的实现方式，完全不需要在回调里做节点判断。
Camel支持路由级别的onCompletion配置，只要把onCompletion定义在具体路由的from之后、业务逻辑之前，就只会对当前路由生效，不会影响其他路由。
示例代码如下：

// 前两个路由保持原有逻辑即可，不需要改动
from("quartz://key_123?cron=0+0/10+*+*+*+?+*")
    // 你的原有业务逻辑
    .to("activemq:topic:key_345");

from("activemq:topic:key_345")
    // 你的原有业务逻辑
    .to("direct:key_678");

// 最后一个路由单独绑定onCompletion
from("direct:key_678")
    .onCompletion().onCompleteOnly()
        .process(exchange -> {
            // 只有key_678路由执行完成才会走到这里
            MDC.remove("correlation_id");
        })
    .end()
    // 你的原有key_678路由业务逻辑
    .log("处理key_678逻辑")
    .to("你的最终目标端点");

方案2：全局onCompletion配合自定义链路标记（适合必须用全局配置的场景） #

如果因为架构规范要求必须使用全局onCompletion，可以手动透传链路标记来识别尾节点：

1. 链路起点（key_123路由）在Exchange消息头中设置自定义标记，比如exchange.getIn().setHeader("MY_TRACE_IS_LAST", false)，同时把correlation_id也放到消息头里——因为MDC是线程绑定的，跨MQ、跨线程异步执行时MDC不会自动传递，必须靠消息头透传。
2. 在最后一个key_678路由的业务逻辑开头，把这个标记设为true：exchange.getIn().setHeader("MY_TRACE_IS_LAST", true)
3. 在全局onCompletion的回调中，只在判断到该头为true时，才执行MDC移除操作：

onCompletion().onCompleteOnly()
.process(exchange -> {
    Boolean isLast = exchange.getIn().getHeader("MY_TRACE_IS_LAST", Boolean.class);
    if (Boolean.TRUE.equals(isLast)) {
        MDC.remove("correlation_id");
    }
});

注意事项 #

你原有代码中获取CamelContext运行状态、服务状态的逻辑，和判断是否为链路尾节点没有任何关系——这两个接口返回的是整个Camel容器的运行状态，和当前路由在逻辑链路中的位置完全无关。
另外不要尝试通过当前路由的输出端点来判断是否为尾节点：这种方式只在全链路都是同步direct端点的场景下勉强可用，一旦用到MQ、定时任务、SEDA这类异步端点，前序路由根本感知不到后续有哪些消费节点，判断逻辑会完全失效。

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