如何在不停止应用程序的情况下使用驼峰路由或重新启动路由中的动态自

Question

我有现有的Spring Boot应用程序，它使用Camel框架从不同的文件夹获取数据。所有路由以类似的方式轮询数据：

from(fileUriWithCurrentDay(path, config.getParams())).routeId(ROUTE_ID)

其中，方法定义如下：

public static String fileUriWithCurrentDay(String path, Map<String, String> params) {
path = path.endsWith(SEPARATOR) ? path : path + SEPARATOR;
return "file:" + path + currentDayPath() + fileParams(params);
}

并根据日期返回类似的内容：

c:/test/data/2021/242?noop=true&idempotent=false&autoCreate=false&includeExt=xml&scheduler=spring&scheduler.cron = "0 0 13 ? * *"

cron设置为每天启动一次。当到达cron时间时，路由开始执行其工作并正确完成它。但是在第二天，它开始轮询同一个文件夹，例如242，但应该是243。

所以问题是：从endpoint开始应该在其开始时动态计算。

我在Camel中读过关于dynamic from:的文章，但没有发现任何信息表明这种选项是现成的。我尝试使用计算的头使用pollRich（）选项，但它似乎不支持动态endpoint，因为返回下一个错误：

org.apache.camel.不允许使用${}占位符的动态表达式。使用fileName选项设置动态表达式。

路由启动后，如何刷新起始endpoint？

我也看到了两种可能的解决方案，但不知道它是否有用：

1. 重新启动从endpointuri重新计算的路由。
2. 重新启动整个Camel上下文。目前所有路由都标记为Spring@Component。

Answer 1

仅使用来自endpoint的URI无法查看File组件的留档。

我建议在URI中使用一个通用的基本目录并创建一个GenericFileFilter的实现，您可以将其与from-endpoint一起使用。它允许在实现哪些文件被处理和哪些文件未被处理的逻辑方面有很大的自由度。

要从base/path/2021读取文件，请创建如下内容：

@Component
public class FileFilter<T> implements GenericFileFilter<T> {
    @Override
    public boolean accept(GenericFile<T> file) {
        if (file.isDirectory()) {
            return "2021".equals(file.getFileName());
        }
        return file.getFileName().startsWith("2021/");
    }
}

endpointURI如下所示：

file://base/path?recursive=true

在实现GenericFileFilter时，您应该注意，目录也会调用accept（）。

Answer 2

与其他EIP组件不同，routeId和from endpoint中的字符串在创建路由后是固定的（除非使用另一个from endpoint url重新创建路由）。因此，有两个可能的前进方向。一种方法是使用new from endpoint url重新创建路由，另一种方法是在组件中查找参数以支持您的操作。

>

在相同的CamelContext中使用相同的routeId重新创建消费者路由

• 每天在行动下方触发（例如使用计时器路线）
• 使用RouteBuilder构建路由配置（使用相同的用户路由id和新的来自endpointurl）
• 使用带有新路由配置的CamelContext类的addRoutes方法重新创建路由

利用文件组件中的过滤器目录

• 设置文件路径到公共根文件夹（即c：/test/data）
• 启用递归查找子目录
• 使用filterDirectory基于简单语言过滤目录
  • 从简单语言留档，简单语言的日期命令使用java.text.SimpleDateFormat
  • 从Oracle文档中，SimpleDateFormat确实支持年份和年份日（假设您的示例中的242和243是年份日）

  免责声明

  我以前没有使用过filterDirectory，方法2是从Camel文档推导出来的。