spring batch ItemReader FlatFileItemReader将光标设置为从特定行开始读取，或将行设置为动态跳过

Question

在springbatch quartz设置中，我使用FlatFileItemReader读取CSV文件。我想设置读卡器的光标，以使用读卡器的给定参数启动下一个jobinstance。可能吗？

<bean id="cvsFileItemReader" class="org.springframework.batch.item.file.FlatFileItemReader" scope="step">
    <!-- Read a csv file -->
    <property name="resource" value="classpath:cvs/input/report.csv" />

    <property name="lineMapper">
        <bean class="org.springframework.batch.item.file.mapping.DefaultLineMapper">
            <property name="lineTokenizer">
                <bean
                    class="org.springframework.batch.item.file.transform.DelimitedLineTokenizer">
                    <property name="names" value="id,impressions" />
                </bean>
            </property>
            <property name="fieldSetMapper">
                <bean
                    class="org.springframework.batch.item.file.mapping.BeanWrapperFieldSetMapper">
                    <property name="prototypeBeanName" value="report" />
                </bean>
            </property>
        </bean>
    </property>

</bean>

这样做的目的是继续读取下一次执行中上次失败的文件。我为customWriter中写入的每一行输入一个整数'writecursor'。

public void write(List<? extends Report> items) throws Exception {

System.out.println("writer..." + items.size() + " > ");     
for(Report item : items){
    System.out.println("writing item id: " + item.getId());     
    System.out.println(item);

}
//getting stepExecution by implementing StepExecutionListener
this.stepExecution.getExecutionContext().putInt("writecursor", ++writecursor);

}

现在，在自定义ItemReadListener中，我想获取更新写库值，然后跳过顶部的行开始从写库读取

public class CustomItemReaderListener implements ItemReadListener<Report>, StepExecutionListener {

    ApplicationContext context = ApplicationContextUtils.getApplicationContext();
    private StepExecution stepExecution;
    @Override
    public void beforeRead() {
        //Skip lines somehow
    }

我看到的另一个可能的解决方案是在项目阅读器中动态设置linestoskip。这里有一个线程http://thisisurl.com/dynamic-value-for-linestoskip-in-itemreader但还没有回答。这里，http://forum.spring.io/forum/spring-projects/batch/100950-accessing-job-execution-context-from-itemwriter

Answer 1

实现要跳过的行的一个更简单的方法是：

在xml中创建一个读取器平面文件读取器，将读取器自动连接到步骤执行侦听器的beforstep，如下所示

public class CustomStepListener implements StepExecutionListener {

    @Autowired
    @Qualifier("cvsFileItemReader")
    FlatFileItemReader cvsFileItmRdr;

    @Override
    public void  beforeStep(StepExecution stepExecution) {
        System.out.println("StepExecutionListener -------- beforeStep");            
        cvsFileItmRdr.setLinesToSkip(4);
    }

    @Override
    public ExitStatus afterStep(StepExecution stepExecution) {
        System.out.println("StepExecutionListener - afterStep");
        return null;
    }

}

这对我来说很好。。。。。

Answer 2

使用FlatFileItemReader.linesToSkip属性设置注入作业参数值。

<bean id="myReader" class="org.springframework.batch.item.file.FlatFileItemReader" scope="step">
    <property name="linesToSkip" value="file:#{jobParameters['cursor']}" />
</bean>