使用属性文件中配置的endpoint在运行时添加骆驼路由

Question

我拥有一个spring应用程序，希望在应用程序启动期间动态添加骆驼路由。endpoint在属性文件中配置，并在运行时加载。使用Java DSL,我使用for循环创建所有路由,

for(int i=0;i<allEndPoints;i++)
  {
  DynamcRouteBuilder route = new 
   DynamcRouteBuilder(context,fromUri,toUri) 
camelContext.addRoutes(route)

}
private class DynamcRouteBuilder extends RouteBuilder {
    private final String from;
    private final String to;

    private MyDynamcRouteBuilder(CamelContext context, String from, String to) {
        super(context);
        this.from = from;
        this.to = to;
    }

    @Override
    public void configure() throws Exception {
        from(from).to(to);
    }
}

无法创建路由file_routeDirect：在:at:>>>onException[[class org.apache.camel.component.file.GenericFileOperationFailedException]->[log[Exception trap${Exception.class}]，processor[processor@0x0]]]<<<<在route:route(File_routeDirection:)[[from[direction:...]中，因为必须在：processor[processor@0x0]\n\ta上指定ref

不确定--有什么问题？有没有人能对此有什么建议或解决办法。谢谢

Answer 1

要在迭代中创建路由，最好有一个对象为一条路由保存不同的值。让我们将其称为routeConfiguration，这是一个简单的POJO，具有用于from、to和routeID的字符串字段。

我们使用YAML文件来配置这些东西，因为您有一个真正的列表格式，而不是在属性文件中使用“平面列表”(路由[0].from,路由[0].to)。

如果使用Spring，可以使用@configurationproperties直接将这样的“对象配置列表”转换为对象集合

当您能够创建这样的值对象集合时，您可以简单地对其进行迭代。下面是一个非常简化的示例。

@Override
public void configure() {
    createConfiguredRoutes();
}

void createConfiguredRoutes() {
    configuration.getRoutes().forEach(this::addRouteToContext);
}

// Implement route that is added in an iteration
private void addRouteToContext(final RouteConfiguration routeConfiguration) throws Exception {
    this.camelContext.addRoutes(new RouteBuilder() {
        @Override
        public void configure() throws Exception {
            from(routeConfiguration.getFrom())
                .routeId(routeConfiguration.getRouteId())
                ...
                .to(routeConfiguration.getTo());
        }
    });
}