如何让Spring Boot集成的Apache Camel处理完成后返回？

我完全懂你的痛点——用外部批处理调用Camel Spring Boot可执行Jar时，一旦开了camel.springboot.main-run-controller=true，进程就会一直挂着，外部脚本根本没法知道任务什么时候才算完成。下面给你几个实用的解决方案，帮你精准控制Camel完成指定任务（比如处理完目录下一批文件）后自动终止应用：

方法1：自定义事件触发优雅关闭 #

这个方案适合处理目录文件的场景，当最后一个文件处理完成后，主动触发应用关闭：

1. 先写一个处理器，在文件处理完成后检查目录是否还有待处理文件，有就发布自定义事件：

public class FileProcessingCompleteHandler implements Processor {
    private final ApplicationEventPublisher eventPublisher;
    private final File inboxDir;

    public FileProcessingCompleteHandler(ApplicationEventPublisher eventPublisher, @Value("${camel.file.inbox}") String inboxPath) {
        this.eventPublisher = eventPublisher;
        this.inboxDir = new File(inboxPath);
    }

    @Override
    public void process(Exchange exchange) throws Exception {
        // 这里根据你的文件过滤规则调整，比如只看.csv文件
        File[] remainingFiles = inboxDir.listFiles((dir, name) -> name.endsWith(".csv"));
        if (remainingFiles == null || remainingFiles.length == 0) {
            // 发布任务完成事件
            eventPublisher.publishEvent(new BatchProcessingCompleteEvent(this));
        }
    }
}

// 自定义事件类
class BatchProcessingCompleteEvent extends ApplicationEvent {
    public BatchProcessingCompleteEvent(Object source) {
        super(source);
    }
}

2. 再写一个事件监听器，收到完成事件后先关Camel路由，再关Spring Boot应用：

@Component
public class ShutdownOnBatchCompleteListener implements ApplicationListener<BatchProcessingCompleteEvent> {
    private final ConfigurableApplicationContext context;

    public ShutdownOnBatchCompleteListener(ConfigurableApplicationContext context) {
        this.context = context;
    }

    @Override
    public void onApplicationEvent(BatchProcessingCompleteEvent event) {
        try {
            // 优雅关闭Camel路由
            CamelContext camelContext = context.getBean(CamelContext.class);
            camelContext.stop();
            // 关闭Spring Boot应用
            context.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

3. 最后把处理器加到你的路由里：

from("file:{{camel.file.inbox}}?delete=true")
    .process("fileProcessingCompleteHandler")
    .to("file:{{camel.file.outbox}}");

方法2：手动控制Camel生命周期 #

如果不想依赖Spring Boot自动配置，可以在主类里手动启动Camel，轮询任务状态，完成后主动关闭：

@SpringBootApplication
public class CamelBatchApplication implements CommandLineRunner {
    @Autowired
    private CamelContext camelContext;
    @Value("${camel.file.inbox}")
    private String inboxDir;

    public static void main(String[] args) {
        SpringApplication.run(CamelBatchApplication.class, args);
    }

    @Override
    public void run(String... args) throws Exception {
        // 启动Camel路由
        camelContext.start();

        // 轮询检查目录是否还有待处理文件
        File inbox = new File(inboxDir);
        while (true) {
            File[] pendingFiles = inbox.listFiles((dir, name) -> name.endsWith(".csv"));
            if (pendingFiles == null || pendingFiles.length == 0) {
                // 留一点时间给最后一个文件的异步处理（可选，根据你的路由调整）
                Thread.sleep(2000);
                break;
            }
            Thread.sleep(1000);
        }

        // 优雅关闭Camel和Spring Boot应用
        camelContext.stop();
        SpringApplication.exit(context, () -> 0);
    }
}

方法3：用RoutePolicy监控路由状态 #

通过自定义路由策略，监控路由的活跃任务数，当没有正在处理的任务时触发关闭：

public class BatchRoutePolicy extends RoutePolicySupport {
    private final ConfigurableApplicationContext context;

    public BatchRoutePolicy(ConfigurableApplicationContext context) {
        this.context = context;
    }

    @Override
    public void onExchangeDone(Route route, Exchange exchange) {
        // 检查是否还有正在处理的任务
        if (route.getCamelContext().getInflightRepository().size() == 0) {
            // 新开线程执行关闭，避免阻塞当前路由
            new Thread(() -> {
                try {
                    route.getCamelContext().stop();
                    context.close();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }).start();
        }
    }
}

然后把这个策略绑定到路由上：

from("file:{{camel.file.inbox}}?delete=true")
    .routePolicy(new BatchRoutePolicy(context))
    .to("file:{{camel.file.outbox}}");

小提醒 #

• 如果用Camel 3.x及以上版本，一定要确保关闭操作是优雅的，别强制终止导致数据丢失
• 要是你的路由有异步处理逻辑，记得等待所有inflight的任务完成再关闭
• 可以通过camelContext.getInflightRepository().size()随时查看正在处理的任务数

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