1

我正在尝试每天在 16:15 从 FTP 服务器读取带有日期戳的文件。为了了解如何执行此操作，我尝试连接到 FTP 服务器，每分钟一次，每次都增加文件号。

到目前为止，我编写的代码是：

private String readFtp = "quartz2://exchange/readFtp?cron=";
private String cronExpression = "1 * * * * ?";

private int i=0;

@Override
public void configure() throws Exception {
    from(readFtp+cronExpression).process(new Processor() {
        @Override
        public void process(Exchange exchange) throws Exception {

            System.out.println("Triggered the process");

            from(getFtpServerUrl())
                    .bean(RateServiceImpl.class, "update")
                    .log("Downloaded file ${file:name} complete.");
        }
    });
}

private String getFtpServerUrl() {

    i++;
    System.out.println("Here with i=" + i);
    return String.format("ftp://%s:21/%s?username=%s&password=%s&fileName=%s", ftpServer, ftpPath, ftpUsername, ftpPassword, "rate"+i+".xml");
}

当我运行它时，它"Triggered the process"每分钟打印一次。它也在呼唤getFtpServerUrl。

它不是在召唤RateServiceImpl.update。它没有记录"Downloaded file ${file:name} complete."。

  • 我会以错误的方式解决这个问题吗？
  • 有没有更简单的方法来每分钟构造文件名？
  • 为什么不RateServiceImpl.update叫？
4

1 回答 1

0

你这样做是错误的。要从处理器添加路由，您需要将路由添加到camelContext并且不使用错误的父类RouteBuilder。

ftp 使用者内置了对 cron 表达式的支持，因此您可以将其配置为每天下午 4:15 运行。然后你需要使用文件过滤器来过滤它找到的文件，并且只选择你想要的文件。

过滤器记录在

cron在这里也有点

我写了一篇关于它的博客

于 2015-06-16T11:53:52.907 回答