如何排查Apache Camel Route数据包内容及消息卡顿位置

1. 按需配置拦截日志，避免全量输出过载 #

不要全局调高日志级别，使用Camel自带的拦截器能力针对怀疑的路由做定向日志输出：

• 使用adviceWith动态修改目标路由，在指定节点前后插入日志输出逻辑，仅输出你需要的消息头、Body内容，还可以加条件过滤，只输出符合特征的消息：

// 示例：给ID为targetRoute的路由的所有节点前加自定义日志
camelContext.getRouteDefinition("targetRoute")
    .adviceWith(camelContext, new AdviceWithRouteBuilder() {
        @Override
        public void configure() throws Exception {
            // 所有节点处理前打印关键信息
            weaveByType(ProcessorDefinition.class).before()
                .log(LoggingLevel.INFO, "RouteDebug", "节点 ${nodeId} 收到消息，头ID：${header.CamelMessageId}，内容：${body}");
        }
    });

• 也可以用interceptSendToEndpoint只拦截特定端点的收发消息，进一步缩小日志范围。

2. 开启轻量路由跟踪与消息历史功能 #

不需要修改路由代码，通过Camel全局配置开启轻量跟踪能力：

• 开启消息历史：在CamelContext配置中设置setMessageHistory(true)，每个Exchange会记录经过的所有节点ID、处理耗时、出入时间，这些数据默认存在内存中，不会打日志，你可以通过JMX直接查询指定Exchange的流转路径。
• 启用可配置的Tracer：Camel自带的Tracer组件支持自定义输出格式、过滤规则，还可以配置环形缓冲区存储最近N条跟踪记录，不会持续写入磁盘，排查时直接读缓冲区内容即可。
• 通过JMX指标定位卡点：JBoss EAP v7默认开启JMX支持，只需配置好远程JMX访问端口即可用JConsole直接连接进程。每个路由的每个处理节点都有对应的JMX MBean，可查看各节点的ExchangesCompleted（已完成数）、ExchangesInflight（处理中数）、MinProcessingTime等指标，哪个节点的ExchangesInflight持续走高没有下降，就是消息卡住的位置，比Hawtio的展示更直接。

3. 利用Inflight仓库定位处理中消息 #

开启Camel的Inflight Repository功能，所有正在处理的Exchange都会被记录，包括当前停留的节点、入站时间、已经经过的路由节点列表：

• 默认的DefaultInflightRepository支持通过JMX直接查询所有待处理的Exchange信息，不需要额外存储，直接就能看到卡住的消息停在哪个节点。
• 可以配置仓库的最大容量，避免内存占用过高，排查完成后也可以随时关闭。

4. 临时排查的无侵入方案 #

如果不想修改代码或者配置重启服务，可以用以下临时方案：

• 通过JMX调用CamelContext MBean的startTrace()方法临时开启全局跟踪，排查完成后调用stopTrace()关闭，不会留下永久配置。
• 如果已经配置了死信队列（DLQ），可以给DLQ的消费者加逻辑，输出失败消息的完整上下文和异常堆栈，就能直接定位处理失败的位置。

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