Spring Integration SFTP 每天获取但立即处理

Question

我想每天过滤和获取文件，然后立即处理所有过滤后的文件。

这是我的配置；

 @Bean
public SftpInboundFileSynchronizer sftpInboundFileSynchronizer() {
    SftpInboundFileSynchronizer fileSynchronizer = new SftpInboundFileSynchronizer(sftpSessionFactory());
    fileSynchronizer.setRemoteDirectory(remoteDirectory);
    fileSynchronizer.setFilter(new SftpSimplePatternFileListFilter(downloadFilter));
    return fileSynchronizer;
}

@Bean
@InboundChannelAdapter(channel = "sftpChannel", poller = @Poller(cron = "0 0 0 * * ?"))
public MessageSource<File> sftpMessageSource() {
    SftpInboundFileSynchronizingMessageSource messageSource = new SftpInboundFileSynchronizingMessageSource(sftpInboundFileSynchronizer());
    messageSource.setLocalDirectory(new File(localDirectory));
    messageSource.setAutoCreateLocalDirectory(true);
    return messageSource;
}

这是我的文件处理程序；

@ServiceActivator(inputChannel = "sftpChannel")
public void handle(File file) {
    log.info("file received . {}", file.getName());
}

它每天获取文件并等待一天为每个获取的文件调用我的处理程序。 我想立即使用获取的文件。 是否可以 ？ 我该怎么做？

Answer 1

在轮询器上增加 maxMessagesPerPoll - 默认为 1。

或 -1 表示无穷大（而未处理的文件仍然存在）。