recursionftpspring-integrationadapterinbound

Spring Integration ftp inbound channel adapter recursive synchronization


With Spring Integration, is it possible to synchronize files (including subfolder's files) recursively using ftp inbound channel adapter?


Solution

  • No; but you can fetch a complete remote directory tree with recursive MGET with the outbound gateway...

    @SpringBootApplication
    @IntegrationComponentScan
    public class So42324318Application {
    
        public static void main(String[] args) {
            ConfigurableApplicationContext context = SpringApplication.run(So42324318Application.class, args);
            List<File> files = context.getBean(Gateway.class).fetchFiles("foo/*");
            System.out.println(files);
            context.close();
        }
    
        @MessagingGateway(defaultRequestChannel = "fetchRecursive")
        public interface Gateway {
    
            public List<File> fetchFiles(String remoteDir);
    
        }
    
        @Bean
        @ServiceActivator(inputChannel = "fetchRecursive")
        public FtpOutboundGateway gateway() {
            // Create a recursive MGET gateway that gets the remote directory from the payload
            FtpOutboundGateway gateway = new FtpOutboundGateway(sessionFactory(), "mget", "payload");
            gateway.setOptions("-R"); 
            gateway.setLocalDirectoryExpression(new SpelExpressionParser().parseExpression("#remoteDirectory"));
            return gateway;
        }
    
        @Bean
        public SessionFactory<FTPFile> sessionFactory() {
            return new CachingSessionFactory<>(ftpSF());
        }
    
        private SessionFactory<FTPFile> ftpSF() {
            DefaultFtpSessionFactory sf = new DefaultFtpSessionFactory();
            sf.setHost("10.0.0.3");
            sf.setUsername("ftptest");
            sf.setPassword("ftptest");
            sf.setClientMode(FTPClient.PASSIVE_LOCAL_DATA_CONNECTION_MODE);
            return sf;
        }
    
    }
    

    Result:

    2017-02-19 09:55:09.351  INFO 61921 --- [           main] o.s.integration.ftp.session.FtpSession   : File has been successfully transferred from: foo/bar.tx
    2017-02-19 09:55:09.353  INFO 61921 --- [           main] o.s.integration.ftp.session.FtpSession   : File has been successfully transferred from: foo/bar.txt
    2017-02-19 09:55:09.356  INFO 61921 --- [           main] o.s.integration.ftp.session.FtpSession   : File has been successfully transferred from: foo/bar/abc.txt
    2017-02-19 09:55:09.358  INFO 61921 --- [           main] o.s.integration.ftp.session.FtpSession   : File has been successfully transferred from: foo/baz.txt
    2017-02-19 09:55:09.362  INFO 61921 --- [           main] o.s.integration.ftp.session.FtpSession   : File has been successfully transferred from: foo/foo/bar/qux.txt
    2017-02-19 09:55:09.364  INFO 61921 --- [           main] o.s.integration.ftp.session.FtpSession   : File has been successfully transferred from: foo/foo/baz/fiz.txt
    [foo/bar.tx, foo/bar.txt, foo/bar/abc.txt, foo/baz.txt, foo/foo/bar/qux.txt, foo/foo/baz/fiz.txt]