Spring Integration Spring批处理Java配置

Question

我们正在处理一个Spring批处理项目（Spring Boot1.2.2.Release)，要求使用Spring SFTP集成以一定频率轮询从服务器位置读取文件。我们使用java config实现了Spring批处理，并在使用Spring Integration java config的过程中实现了Spring批处理。我找不到描述上述情况的例子。我浏览了各种链接，但看到的主要是XML配置示例。

http://spring.io/blog/2010/02/15/practice-use-of-spring-batch-and-spring-integration https://github.com/spring-projects/spring-integration-samples/tree/master/basic/sftp

是否可以使用spring integration java Config轮询文件？如有任何帮助/指导，将不胜感激。

@Configuration
public class SftpConfiguration {

    @Autowired
    SftpProperties sftpProperties;

    @Bean
    public SessionFactory<LsEntry> getSftpSessionFactory() {
        Resource resource = new FileSystemResource(
                sftpProperties.privateKeyLocation);
        DefaultSftpSessionFactory sftpSessionFactory = new DefaultSftpSessionFactory();
        sftpSessionFactory.setHost(sftpProperties.hostName);
        sftpSessionFactory.setPort(sftpProperties.port);
        sftpSessionFactory.setUser(sftpProperties.username);
        sftpSessionFactory.setPrivateKey(resource);
        return sftpSessionFactory;
    }

    @Bean
    @InboundChannelAdapter(value = "sftpChannel", poller = @Poller(fixedDelay = "1000", maxMessagesPerPoll = "1"))
    public MessageSource<File> sftp() {
        SftpInboundFileSynchronizingMessageSource source = null;
        SftpInboundFileSynchronizer sftpInboundFileSynchronizer = null;
        File localDirectory = new File(sftpProperties.localDirectory);

        try {
            sftpInboundFileSynchronizer = new SftpInboundFileSynchronizer(getSftpSessionFactory());
            sftpInboundFileSynchronizer.setFilter(new SftpSimplePatternFileListFilter(sftpProperties.fileNamePattern));
            sftpInboundFileSynchronizer.setRemoteDirectory(sftpProperties.remoteDirectory);
            sftpInboundFileSynchronizer.setPreserveTimestamp(Boolean.TRUE);
            sftpInboundFileSynchronizer.synchronizeToLocalDirectory(localDirectory);
            sftpInboundFileSynchronizer.setDeleteRemoteFiles(Boolean.FALSE);
            sftpInboundFileSynchronizer.setTemporaryFileSuffix(".copy");
            source = new SftpInboundFileSynchronizingMessageSource(sftpInboundFileSynchronizer);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return source;
    }
}

@SpringBootApplication
@EnableIntegration
@IntegrationComponentScan
public class SpringIntegrationApplication {

    public static void main(String[] args) {
        SpringApplication.run(SpringIntegrationApplication.class, args);
    }
}

该项目是一个spring boot starter项目。

release
UTF-8 com.spring.integration.test.springintegrationapplication 1.7 org.springframework.boot spring-boot-starter-integration org.springframework.integration spring-integration-sftp org.springframework.boot spring-boot-starter-web

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-tomcat</artifactId>
    <scope>provided</scope>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <scope>test</scope>
</dependency>
<dependency>
    <groupId>org.springframework.integration</groupId>
    <artifactId>spring-integration-sftp</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-batch</artifactId>
</dependency>
<dependency>
    <groupId>commons-collections</groupId>
    <artifactId>commons-collections</artifactId>
    </dependency>

<dependency>
    <groupId>org.scala-lang</groupId>
    <artifactId>scala-library</artifactId>
    <version>2.10.4</version>
</dependency>
<dependency>
    <groupId>org.neo4j</groupId>
    <artifactId>neo4j-cypher-compiler-2.1</artifactId>
    <version>2.1.5</version>
</dependency>

Answer 1

参见参考手册附录F。

@Bean
@InboundChannelAdapter( ... , poller = @Poller(...))
public MessageSource sftp() {
    SftpInboundFileSynchronizingMessageSource source = new ...;
    ...
    return source;
}

源代码需要一个SFTPInboundFileSynchronizerbean，它需要一个SessionFactory（通常是DefaultsFTPSessionFactory)。