使用Apache Camel的自动启动功能,可以在应用程序启动时自动启动路由。
下面是一个示例代码,展示了如何配置并启动Apache Camel路由:
import org.apache.camel.CamelContext;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.DefaultCamelContext;
public class CamelRouteAutoStartExample {
public static void main(String[] args) throws Exception {
// 创建CamelContext对象
CamelContext context = new DefaultCamelContext();
// 添加路由
context.addRoutes(new RouteBuilder() {
@Override
public void configure() throws Exception {
// 定义路由逻辑
from("file:inputFolder")
.to("file:outputFolder");
}
});
// 启动路由
context.start();
// 等待一段时间,让路由运行一段时间
Thread.sleep(5000);
// 停止路由
context.stop();
}
}
在上述示例代码中,我们创建了一个DefaultCamelContext
对象,并添加了一个简单的文件传输路由。该路由从inputFolder
目录读取文件,并将其复制到outputFolder
目录中。
然后,我们调用start()
方法启动路由,并使用Thread.sleep()
方法让路由运行一段时间。最后,我们调用stop()
方法停止路由。
当应用程序运行时,路由将自动启动并开始处理文件传输任务。