Camel路由处理文件发生异常时如何配置重投递延迟策略

问题根因 #

你当前配置不生效的核心原因是：Camel的onException重投递规则默认仅作用于路由内部的消息处理流程，若异常最终未被处理、透传回File消费端点时，File组件会直接将消费失败的文件放回源目录，立刻触发下一次拉取，不会使用你配置的重投递延迟。

正确配置方案 #

方案1：路由内部重投递（推荐短周期重试场景） #

在RouteBuilder中完善异常处理规则，配置完整的重投递策略，同时标记异常已处理，避免透传回File端点触发立刻拉取：

// 可配置为全局异常处理，或绑定到指定路由
onException(Exception.class)
    .maximumRedeliveries(3) // 按需调整最大重投递次数
    .redeliveryDelay(10000) // 每次重投递间隔10秒
    .handled(true); // 标记异常已处理，不会透传回File消费端点
    // 若重投递耗尽后需要处理失败文件，可追加.deadLetterUri("file:/error_dir") 把失败文件移动到指定目录

// 原有路由逻辑保持不变
from("file:/mydir?delete=true")
    .bean(MyProcessor.class);

该方案的重投递逻辑在同一次文件消费周期内完成，重试过程中文件不会被放回源目录。

方案2：File消费端退避配置（推荐长周期重试场景） #

如果不需要在路由内部做重投递，希望由File组件控制消费失败后的拉取间隔，可直接配置File端点的退避参数：

from("file:/mydir?delete=true&backoffErrorThreshold=1&backoffInitialDelay=10000&backoffMultiplier=1")
    .bean(MyProcessor.class);

参数说明：

• backoffErrorThreshold：连续消费失败达到该阈值后开启退避延迟，配置为1表示首次失败就开启退避
• backoffInitialDelay：首次退避的延迟时间，单位毫秒，示例配置为10秒
• backoffMultiplier：后续每次失败的延迟乘数，配置为1表示每次重试间隔都是10秒，按需调整即可

该方案消费失败后文件会保留在源目录，到期后才会被再次拉取，适合重试间隔长、次数多的场景。

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