Spring Integration - FTP должен синхронизироваться с локальной папкой

Question

У меня есть файлы местоположения ftp и есть локальная папка, в первый раз файлы копируются в локальные и при перезапуске сервера (в настоящее время он копирует уже скопированные файлы в локальную папку). не следует искать файлы, которые уже существуют в локальном, и он должен искать только новые файлы. Пожалуйста, дайте мне знать, можно ли достичь этого, используя Spring-Integration ftp? Я добавил фильтр также, но до сих пор он не работает, пожалуйста, дайте мне знать, где я неправильно,

@Bean 
@InboundChannelAdapter(value = "inputChannel", poller = @Poller(fixedDelay = "1000", maxMessagesPerPoll = "1")) 
public MessageSource<?> receive() { 
    FtpInboundFileSynchronizingMessageSource messageSource = new FtpInboundFileSynchronizingMessageSource(synchronizer()); 
    PropertiesPersistingMetadataStore metadataStore = new PropertiesPersistingMetadataStore(); 
    FileSystemPersistentAcceptOnceFileListFilter acceptOnceFilter = new FileSystemPersistentAcceptOnceFileListFilter(metadataStore,"*.xml"); 

    File Temp = new File(TEMP_FOLDER); 

    metadataStore.setBaseDirectory(TEMP_FOLDER); 
    messageSource.setLocalDirectory(Temp); 
    messageSource.setAutoCreateLocalDirectory(false); 

    messageSource.setLocalFilter(acceptOnceFilter); 

    return messageSource; 
} 

private AbstractInboundFileSynchronizer<FTPFile> synchronizer() { 
    folderCleanUp(); 
    AbstractInboundFileSynchronizer<FTPFile> fileSynchronizer = new FtpInboundFileSynchronizer(sessionFactory()); 
    fileSynchronizer.setRemoteDirectory(ftpFileLocation); 
    fileSynchronizer.setDeleteRemoteFiles(false); 
    Pattern pattern = Pattern.compile(".*\\.xml$"); 
    FtpRegexPatternFileListFilter ftpRegexPatternFileListFilter = new FtpRegexPatternFileListFilter(pattern); 
    fileSynchronizer.setFilter(ftpRegexPatternFileListFilter); 
    return fileSynchronizer; 
} 

Answer 1

Да, это так. Посмотрите на свойство local-filter, а FileSystemPersistentAcceptOnceFileListFilter - для отслеживания локальных файлов через внешний MetadataStore, например. Redis, MongoDb или любой другой, который сохраняет данные по перезапуску системы.

Answer 2

Для уточнения Artem's advice о реализации ваших пользовательских FileListFilter, вот пример такого фильтра (с целью, чтобы отфильтровать файлы старше данный момент):

@Component 
public class OldFilesFilter extends AbstractFileListFilter<FTPFile> { 
    // (oldFilesTimestamp field declaration and its source) 

    @Override 
    protected boolean accept(FTPFile file) { 
    String fileName = file.getName(); 
    long fileTimestamp = file.getTimestamp().getTimeInMillis(); 
    ZonedDateTime fileModTimestamp = ZonedDateTime.ofInstant(Instant.ofEpochMilli(fileTimestamp), ZoneId.systemDefault()); 
    boolean isFileAcceptable = fileModTimestamp.isAfter(oldFilesTimestamp); 
    if (log.isTraceEnabled()) { 
     log.trace("File {}:\n" + 
      "file timestamp : {};\n" + 
      "given timestamp: {};\n" + 
      "file is new : {}", 
      fileName, fileModTimestamp, oldFilesTimestamp, isFileAcceptable); 
    } 
    return isFileAcceptable; 
    } 
} 

Также отметим, что Spring Integration позволяет использовать несколько фильтров, которые должны применяться к одному источнику файла в одно и то же время. Это может быть достигнуто с помощью :

private CompositeFileListFilter<FTPFile> remoteFileFilter() { 
    FtpPersistentAcceptOnceFileListFilter persistentFilter = 
          new FtpPersistentAcceptOnceFileListFilter(metadataStore, "remoteProcessedFiles."); 
    return new CompositeFileListFilter<>(Arrays.asList(new FtpSimplePatternFileListFilter("*.zip"), 
                 persistentFilter, 
                 oldFilesFilter /*known from previous example*/)); 
    }