Spring SFTP: невозможно переименовать файл .writing - PullRequest
Новая
       6

Spring SFTP: невозможно переименовать файл .writing

1 голос
/ 03 августа 2020

Я использую интеграцию Spring SFTP для передачи файла и много раз получал эту ошибку. Кажется, два потока пытаются передать один и тот же файл и конфликтуют друг с другом.

2020-08-03 08: 31: 55,766 INF [task-scheduler-8] osiftp.session.FtpSession - Файл имеет был успешно перенесен из: ./abc.ext.200803
2020-08-03 08: 31: 55,849 INF [task-scheduler-7] osiftp.session.FtpSession - Файл успешно перенесен из:. /abc.ext.200803
2020-08-03 08: 31: 55,850 INF [task-scheduler-7] .sifiFtpInboundFileSynchronizer - Невозможно переименовать /local/download/abc.ext.200803. запись «в локальный файл» /local/download/abc.ext.200803 после удаления. Локальный файл может быть занят каким-то другим процессом.

Есть ли способ, чтобы оба потока не мешали друг другу?

Я использую следующий код - 

@Bean
public SftpInboundFileSynchronizer ftpInboundFileSynchronizer() {
    isFTPSessionOK();
    SftpInboundFileSynchronizer fileSynchronizer = new SftpInboundFileSynchronizer(sftpSessionFactory());

    fileSynchronizer.setPreserveTimestamp(true);
    fileSynchronizer.setRemoteDirectory(remoteDirectory);
    fileSynchronizer.setDeleteRemoteFiles(false);

    fileSynchronizer.setFilter(new SFTPLastModifiedFileFilter(remoteFileFilter));
    return fileSynchronizer;
}

private boolean isFTPSessionOK() {
    try {
        SessionFactory<LsEntry> ftpSessionFactory = sftpSessionFactory();
        boolean open = ftpSessionFactory.getSession().isOpen();
        LOG.info("FTPSession is good ? " + open);
        return open;
    } catch (Exception e) {
        LOG.error("FTPSession is not good because of error : " + e);
    }
    return false;
}

@Bean
public SessionFactory<LsEntry> sftpSessionFactory() {
    DefaultSftpSessionFactory sf = new DefaultSftpSessionFactory();
    sf.setHost(server);
    sf.setPort(port);
    sf.setUser(username);
    sf.setPassword(password);
    sf.setAllowUnknownKeys(true);
    return new CachingSessionFactory<LsEntry>(sf);
}

@Bean
@InboundChannelAdapter(channel = "sftpChannel", poller = @Poller(fixedDelay = "${${project.name}.ftp.poller.delay:600000}", maxMessagesPerPoll = "1"))
public MessageSource<File> ftpMessageSource() {
    SftpInboundFileSynchronizingMessageSource source = new SftpInboundFileSynchronizingMessageSource(ftpInboundFileSynchronizer());
    source.setLocalDirectory(new File(localFtpDirectory));
    source.setAutoCreateLocalDirectory(true);       
    return source;
}

@Bean
@ServiceActivator(inputChannel = "sftpChannel")
public MessageHandler ftpHandler() {
    return new MessageHandler() {

        @Override
        public void handleMessage(Message<?> message) throws MessagingException {
            LOG.info("File '{}' is ready for reading after SFTP", message.getPayload());
        }
    };
}

1 Ответ

1 голос
/ 03 августа 2020

У вас есть только это для фильтрации: 

fileSynchronizer.setFilter(new SFTPLastModifiedFileFilter(remoteFileFilter));

, но как насчет фильтра, который будет предотвращать дублирование при последующем опросе?

См. AcceptOnceFileListFilter. И вместе с этим SFTPLastModifiedFileFilter вы должны использовать ChainFileListFilter.

См. Дополнительную информацию в документации:

https://docs.spring.io/spring-integration/docs/current/reference/html/sftp.html#sftp -inbound

https://docs.spring.io/spring-integration/docs/current/reference/html/file.html#file -чтение

...