CamelMain处理大文件并停止路由并退出JVM

Question

我需要使用以下两种情况来处理大文件：（1）从文件目录中拉取并推送到FTP（2）从一个FTP中拉取，推送到另一个FTP

我正在创建一个java maven依赖项目，它使用camel组件来处理上述文件传输用例，所以我决定使用org.apache.camel.main。主类开始我的路线，但问题是即使文件处理成功，我的程序也没有关闭。我在某个地方读到，使用“System.exit（）”可以解决问题，但问题仍然存在。

我的代码-

Main camelMain = new Main();
camelMain.enableHangupSupport();
camelMain.addRouteBuilder(getRouteBuilderLocaltoFTP());
camelMain.run();

路由器制造商

public void configure() throws Exception { 
    from(<File-Path>).routeId("local-to-ftp")
    .onCompletion().process(new Processor() {
                @Override
                public void process(Exchange exchange) throws Exception {
                    exchange.getContext().stop();       
                }
            })
            .toD(<FTP-Path>); 

也尝试使用控制总线。toF("controlbus:route？routeId=%s

但在这两种情况下，路由都会正常关闭，而不是关闭程序。

在这方面寻求帮助。

Answer 1

这里记录了Graceful关闭的各种方式。您可以尝试此代码来关闭特定路由

camelContext.getRouteController().stopRoute("routeId");
camelContext.removeRoute("routeId");

Answer 2

您可以在主服务器上配置为在X段时间后或处理N条消息后关闭应用程序。您可以将两者都设置为AFAIR，例如在2分钟后关闭，在处理1条消息后关闭。

只需检查< code>camelMain上的方法。请注意，这需要Apache Camel的最新版本。