Apache Camel 3.4.0重试日志尝试顺序异常问题咨询
问题原因
你配置的asyncDelayedRedelivery()是核心问题——这个参数会把重试任务提交到Camel的异步调度线程池执行。线程池内的任务执行顺序不严格遵循提交顺序,哪个线程空闲就会优先执行对应的重试任务,因此日志里的交付尝试次数会出现乱序,比如"On delivery attempt: 3"会比"On delivery attempt: 2"先打印出来。
解决办法
根据你的需求,有两种可行方案:
方案一:关闭异步延迟重试(最简便)
直接移除asyncDelayedRedelivery()配置,改用同步延迟重试。这样所有重试操作会在同一个线程内按顺序执行,日志自然会保持升序。修改后的配置片段:.maximumRedeliveries(3) .redeliveryDelay(1000) .logRetryAttempted(true) .log(LoggingLevel.ERROR, "retry attempts exhausted") .end();注意:同步重试会阻塞当前线程直到重试完成,需要评估是否会对业务性能造成影响。
方案二:自定义单线程池(保留异步逻辑并解决乱序)
如果必须保留异步重试,可以使用单线程的ScheduledExecutorService,这样任务会严格按照提交顺序串行执行,日志就能保持升序。配置步骤如下:- 先定义单线程调度线程池:
ScheduledExecutorService singleThreadScheduler = Executors.newSingleThreadScheduledExecutor(); - 在路由配置中指定该线程池用于异步重试:
.maximumRedeliveries(3) .redeliveryDelay(1000) .asyncDelayedRedelivery(singleThreadScheduler) .logRetryAttempted(true) .log(LoggingLevel.ERROR, "retry attempts exhausted") .end();
注意:单线程池会限制重试任务的并行执行,所有重试都在同一线程处理,需要结合业务并发情况评估是否适用。
- 先定义单线程调度线程池:
内容的提问来源于stack exchange,提问作者Satish
相关产品推荐
相关产品推荐

