FtpInboundFileSynchronizer.setDeleteRemoteFiles(true) 传输后不删除远程文件

Question

我正在尝试使用 spring boot，集成 ftp 示例（http://docs.spring.io/spring-integration/reference/html/ftp.html，15.5.1）。我能够从远程目录中读取文件，它不会删除带有标志 setDeleteRemoteFiles(true) 的文件。如果我缺少设置任何标志来删除远程文件，请告诉我。

@Bean
public SessionFactory<FTPFile> ftpSessionFactory() {
    DefaultFtpSessionFactory sf = new DefaultFtpSessionFactory();
    sf.setHost("localhost");
    sf.setPort(21);
    sf.setUsername("sudaredd");
    sf.setPassword("");
    return new CachingSessionFactory<FTPFile>(sf);
}

 @Bean
    public FtpInboundFileSynchronizer ftpInboundFileSynchronizer() {
        FtpInboundFileSynchronizer fileSynchronizer = new FtpInboundFileSynchronizer(ftpSessionFactory());
        fileSynchronizer.setDeleteRemoteFiles(true);
        fileSynchronizer.setRemoteDirectory("");
        fileSynchronizer.setFilter(new FtpSimplePatternFileListFilter("*"));
        return fileSynchronizer;
    }
  @Bean
    @InboundChannelAdapter(channel = "ftpChannel", poller = @Poller(fixedDelay = "5000"))
    public MessageSource<File> ftpMessageSource() {
        FtpInboundFileSynchronizingMessageSource source =
                new FtpInboundFileSynchronizingMessageSource(ftpInboundFileSynchronizer());
        source.setLocalDirectory(new File("ftp-inbound"));
        source.setAutoCreateLocalDirectory(true);
        source.setLocalFilter(new AcceptOnceFileListFilter<File>());
        return source;
    }

Answer 1

所有配置看起来都不错。

尝试为org.springframework.integration 类别打开DEBUG 以跟踪行为。

OTOH，请确保您的 FTP 服务器支持删除操作，并且您的用户确实有权执行该操作。

由于@InboundChannelAdapter 通过taskScheduler 执行其任务，您可能会错过日志中的错误。

如果您能够调试代码并在AbstractInboundFileSynchronizer.copyFileToLocalDirectory() 中放置断点以遵循逻辑并确定可能出现的问题，那就太好了。