在spring批处理中使用StepScope注释时的WriterNotOpenException

Question

我有一个定制的作家，它很好用；但是，我想通过JobParameters来设置我的输出文件的名称，而不是在我的配置中使用固定的字符串。为了做到这一点，我添加了@stepscope注释和参数，就像我对ItemReader所做的那样。

ItemWriter声明

@Bean
@StepScope
public ItemWriter<CityProcessed> writer(@Value("#{jobParameters[inputFile]}") String inputFile, @Value("#{jobParameters[outputFile]}") String outputFile) {
    // String inputFile = "D:/cities.csv";
    // String outputFile = "D:/compterendu.csv";
    FlatFileItemWriter<CityCRE> writer = new FlatFileItemWriter<CityCRE>();
    FileSystemResource isr;
    isr = new FileSystemResource(new File(outputFile));
    writer.setResource(isr);
    DelimitedLineAggregator<CityCRE> aggregator = new DelimitedLineAggregator<CityCRE>();
    aggregator.setDelimiter(";");
    BeanWrapperFieldExtractor<CityCRE> beanWrapper = new BeanWrapperFieldExtractor<CityCRE>();
    beanWrapper.setNames(new String[]{
        "nom", "pays", "identifiantBase", "c/m"
    });
    aggregator.setFieldExtractor(beanWrapper);
    writer.setLineAggregator(aggregator);
    CityItemWriter itemWriter = new CityItemWriter();
    writer.setFooterCallback(itemWriter);
    writer.setHeaderCallback(itemWriter);
    itemWriter.setDelegate(writer);
    itemWriter.setInputFileName(inputFile);
    return itemWriter;
}

步骤声明

@Bean
public Step stepImport(StepBuilderFactory stepBuilderFactory, ItemReader<CityFile> reader, ItemWriter<CityProcessed> writer, ItemProcessor<CityFile, CityProcessed> processor) {
    return stepBuilderFactory
        .get("step1")
        .<CityFile, CityProcessed> chunk(10)
        .reader(reader(null))
        .processor(processor)
        .writer(writer(null, null))
        .build();
}

这段代码不起作用，我得到一个WriterNotOpenException是因为我使用FlatFileItemWriter作为委托。

当我尝试为ItemReader使用JobParameters时，我遇到了同样的错误，我不得不将返回类型更改为“FlatFileItemReader”（而不是ItemReader）。我不能在这里做同样的事情，因为我需要我的自定义ItemWriter，而不是一个简单的FlatFileItemWriter。

我不明白为什么当我添加@stepscope时会出现这个错误，而我的阅读器没有它就没有问题。我做错了什么？

其他信息：

• 我的配置在使用inputFile和outputFile字符串时起作用。
• 添加@stepscope批注（即使没有添加JobParameters作为writer参数）时似乎出错。

Answer 1

您必须将委托writer注册为Stream；这样，SB将以正确的方式管理流生命周期。