彈簧批量集成文件輪詢器

Question

我想構建一個只有在文件進入目錄後才能啓動作業的spring批處理應用程序。對於我需要一個文件輪詢和類似的東西在Spring參考手冊中的片段：

public class FileMessageToJobRequest { 
    private Job job; 
    private String fileParameterName; 

    public void setFileParameterName(String fileParameterName) { 
     this.fileParameterName = fileParameterName; 
    } 

    public void setJob(Job job) { 
     this.job = job; 
    } 

    @Transformer 
    public JobLaunchRequest toRequest(Message<File> message) { 
     JobParametersBuilder jobParametersBuilder = 
     new JobParametersBuilder(); 

     jobParametersBuilder.addString(fileParameterName, 
     message.getPayload().getAbsolutePath()); 

     return new JobLaunchRequest(job, jobParametersBuilder.toJobParameters()); 
    } 
} 

我想管理與配置類的一切，但我真的不能弄清楚如何使它發揮作用。

Answer 1

你的問題不清楚。最好是有一些可行的，然後是一些你自己的PoC或試圖完成任務。

但無論如何，看起來像你想避免XML配置，並且只能用Java &註釋配置。

爲此，我建議你看看到Reference Manual，找到在File Support章此示例，也：

@Bean 
@InboundChannelAdapter(value = "fileInputChannel", poller = @Poller(fixedDelay = "1000")) 
public MessageSource<File> fileReadingMessageSource() { 
    FileReadingMessageSource source = new FileReadingMessageSource(); 
    source.setDirectory(new File(INBOUND_PATH)); 
    source.setFilter(new SimplePatternFileListFilter("*.txt")); 
    return source; 
}