如何用camel sftp下载文件

Question

这是我必须做的：外部服务器定期生成3个文件：“FI.date.nnnnn”、“FS.date.nnnnn”和GO.date.nnnnn”。这三个文件与相同的日期和nnnnn（=序列号）相关联。每个“三元组”都是唯一的名称。当GO文件存在时，我必须下载这些文件。这个GO文件是空的。

我用骆驼这个路线：

from("sftp://user@url:port/OUTTEST-S?binary=true&connectTimeout=3000&delete=true&disconnect=true&include=GO.*&knownHostsFile=.ssh/known_hosts&privateKeyFile=../id_rsa.ppk&stepwise=false&strictHostKeyChecking=no&timeout=3000).bean(afterReceiveGo).to("...")

我使用“include=GO.*”来等待GO文件。

在我的AfterReceiveGo中，我使用了这样的ConsumerTemplate：

consumerTemplate.receiveBody(sftp://user@url:port/OUTTEST-S?binary=true&connectTimeout=3000&delete=true&disconnect=true&fileName=FO.20160810.00089&knownHostsFile=.ssh/known_hosts&privateKeyFile=../id_rsa.ppk&stepwise=false&strictHostKeyChecking=no&timeout=3000&useList=false, File.class)

因为我知道要下载的文件的名称，所以我使用“fileName=" and useList=false”。

但在日志中：

Will try again at next poll. Caused by: [org.apache.camel.component.file.GenericFileOperationFailedException - Cannot list directory: OUTTEST-S]: org.apache.camel.component.file.GenericFileOperationFailedException: Cannot list directory: OUTTEST-S
    at org.apache.camel.component.file.remote.SftpOperations.listFiles(SftpOperations.java:617)
    at org.apache.camel.component.file.remote.SftpConsumer.doPollDirectory(SftpConsumer.java:117)
    at org.apache.camel.component.file.remote.SftpConsumer.pollDirectory(SftpConsumer.java:79)
    at org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:131)
    at org.apache.camel.impl.ScheduledPollConsumer.doRun(ScheduledPollConsumer.java:175)
    at org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:102)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)
Caused by: 4: 
    at com.jcraft.jsch.ChannelSftp._stat(ChannelSftp.java:2208)
    at com.jcraft.jsch.ChannelSftp._stat(ChannelSftp.java:2215)
    at com.jcraft.jsch.ChannelSftp.ls(ChannelSftp.java:1565)
    at com.jcraft.jsch.ChannelSftp.ls(ChannelSftp.java:1526)
    at org.apache.camel.component.file.remote.SftpOperations.listFiles(SftpOperations.java:608)
    ... 12 more
Caused by: java.io.IOException: inputstream is closed
    at com.jcraft.jsch.ChannelSftp.fill(ChannelSftp.java:2884)
    at com.jcraft.jsch.ChannelSftp.header(ChannelSftp.java:2908)
    at com.jcraft.jsch.ChannelSftp._stat(ChannelSftp.java:2189)
    ... 16 more

我使用骆驼2.17.2，都是java配置，没有xml文件。

怎么了？有没有另一种（也是最好的）方法来做这件事？

第二个问题:我想在from("sftp ... "中使用cron表达式)每一小时执行一次，即。“我不能用吗？调度器=spring

cronScheduledRoutePolicy.startTime("cron expression");
from("sftp...").routePolicy(cronScheduledRoutePolicy).bean("...").to("...");

但是我在日志文件中每秒看到一个连接。我该怎么办？

Answer 1

Camel的sftp组件有选项来定义它自己的极化间隔。不需要配置/添加调度程序。这里有两个选项，引用自http://camel.apache.org/file2.htmlsignalDelay：在轮询文件/目录开始之前的毫秒。延迟：在下一次轮询文件/目录之前的毫秒。