在 Spring Integration 中将文件上传到 SFTP 时创建侦听器

如何解决在 Spring Integration 中将文件上传到 SFTP 时创建侦听器

我当前的项目基于 Spring Integration。我正在使用 spring Boot 开发这个项目。

我的目标是使用 Spring Integration 来完成以下任务。

1.我想在 spring 集成中创建侦听器，以了解文件何时上传到 SFTP 服务器。

想弄清楚我们为什么使用 SftpInboundFileSynchronizer？

Logger logger = LoggerFactory.getLogger(SftpConfig.class);

    @Bean
    public SessionFactory<ChannelSftp.LsEntry> sftpSessionFactory() {
        DefaultSftpSessionFactory factory = new DefaultSftpSessionFactory(true);
        factory.setHost(sftpHost);
        factory.setPort(sftpPort);
        factory.setUser(sftpUser);
        if (sftpPrivateKey != null) {
            factory.setPrivateKey(sftpPrivateKey);
            factory.setPrivateKeyPassphrase(privateKeyPassphrase);
        } else {
            factory.setPassword("sftpPassword");
        }
        factory.setAllowUnkNownKeys(true);
        return new CachingSessionFactory<ChannelSftp.LsEntry>(factory);
    }


@Bean
    public SftpInboundFileSynchronizer sftpInboundFileSynchronizer() {
        SftpInboundFileSynchronizer filesynchronizer = new SftpInboundFileSynchronizer(sftpSessionFactory());
        filesynchronizer.setDeleteRemoteFiles(false);
        filesynchronizer.setRemoteDirectory(sftpRemoteDirectoryDownload);
        filesynchronizer.setFilter(new SftpSimplePatternFileListFilter(sftpRemoteDirectoryDownloadFilter));
        return filesynchronizer;

    }

好吧，我参考了一些 stackoverflow 帖子，了解如何使用 spring 集成。由于我是 Spring Integration 的新手，这是我要创建一个监听器和读取文件的正确方法吗？

请提供一些如何创建侦听器的示例代码，它会检测文件何时上传到 SFTP？

解决方法

有类似的事件可以从远程 SFTP 服务器侦听。到目前为止，我们建议的是被动轮询方法。因此，特定的 SourcePollingChannelAdapter 端点通过一些预配置的定时触发器向资源请求数据。另一方面，该端点提供了一些 MessageSource 实现，在 SFTP 的情况下是 SftpInboundFileSynchronizingMessageSource，如果您要在处理文件之前依赖与本地目录的同步。

请通过文档查阅更多说明和详细信息：https://docs.spring.io/spring-integration/docs/current/reference/html/sftp.html#sftp-inbound

您可以在这里找到一些示例：https://github.com/spring-projects/spring-integration-samples