通过Spring-Integration下载FTP文件？

debugcn 发表于 Dev

成员之声

我想定期从ftp服务器下载文件（仅当文件已更改时）。因此，我想使用Spring-Integration4.0。

以下设置的基于注释的配置等效于int-ftp什么？

<int-ftp:inbound-channel-adapter id="ftpInbound"
            channel="ftpChannel"
            session-factory="ftpClientFactory"
            filename-pattern="*.txt"
            auto-create-local-directory="true"
            delete-remote-files="false"
            remote-directory="/">
    <int:poller fixed-rate="1000"/>
</int-ftp:inbound-channel-adapter>

我开始与以下，但不知道我怎么能与它的属性，如配置通道session-factory，remote-directory等等。

@Configuration
@EnableIntegration
public class Application {
    @Bean
    public SessionFactory<FTPFile> sessionFactory() {
        DefaultFtpSessionFactory ftp = new DefaultFtpSessionFactory();
        ftp.setHost("ftp.test");
        ftp.setPort(21);
        ftp.setUsername("anonymous");
        ftp.setPassword("anonymous");
        return ftp;
    }

    @InboundChannelAdapter(value = "ftpChannel", poller = @Poller(fixedDelay = "1000", maxMessagesPerPoll = "1"))
    public String connect() {
        // return the ftp file
    }

    @ServiceActivator(inputChannel = "ftpChannel")
    public void foo(String payload) {
        System.out.println("paylod: " + payload);
    }

}

加里·罗素

（S）FTP入站适配器在更复杂的一面；我们正在DSL中进行工作，以使其变得更容易，但是目前，您需要进行@Bean FtpInboundFileSynchronizer连接并连接适当的属性，并将其注入

然后

@Bean
@InboundChannelAdapter(value = "ftpChannel", poller = @Poller(fixedDelay = "1000", maxMessagesPerPoll = "1"))
public MessageSource receive() {
    FtpInboundFileSynchronizingMessageSource messageSource = new FtpInboundFileSynchronizingMessageSource(synchronizer());
    ...
    return messageSource;
}

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。