我正在尝试以批处理方式使用 Spring Integration 处理一系列文件。我有这个非常旧的 xml,它试图将消息转换为作业
<int:transformer ref="messageToJobTransformer"/>
<batch-int:job-launching-gateway job-launcher="jobLauncher"/>
这messageToJobTransformer
是一个可以将 Message 转换为 Job 的类。问题是我不知道这个文件现在在哪里,我也不想要一个 xml 配置。我希望它是纯 Java DSL。这是我的简单配置。
return IntegrationFlows.from(Files.inboundAdapter(directory)
.preventDuplicates()
.patternFilter("*.txt")))
.handle(jobLaunchingGw())
.get();
这是我的网关 bean。
@Autowired
private JobLauncher jobLauncher;
@Bean
public MessageHandler jobLaunchingGw() {
return new JobLaunchingGateway(jobLauncher);
}
编辑:更新批处理配置类。
@Configuration
@EnableBatchProcessing
public class BatchConfig
{
@Autowired
private JobBuilderFactory jobs;
@Autowired
private StepBuilderFactory steps;
@Bean
public ItemReader<String> reader(@Value({jobParameters['input.file.name']}") String filename) throws MalformedURLException
{
FlatFileItemReader<String> reader = new FlatFileItemReader<String>();
return reader;
}
@Bean
public Job job() throws MalformedURLException
{
return jobs.get("job").start(step()).build();
}
@Bean
public Step step() throws MalformedURLException
{
return steps.get("step").<String, String> chunk(5).reader(reader())
.writer(writer()).build();
}
@Bean
public ItemWriter<String> writer(@Value("#{jobParameters['input.file.name']}")
{
FlatFileItemWriter writer = new FlatFileItemWriter();
return writer;
}
}