使用@stepscope时Spring批重新启动功能不工作

Question

我想使用Spring批处理(V3.0.9)重新启动功能，以便在jobinstance重新启动时，流程步骤从上一个失败的块点向前读取。只要不对myBatisPagingItemReaderbean方法使用@stepscope批注，我的重新启动就可以正常工作。
我使用了@stepscope以便在我的myBatisPagingItemReaderbean方法@value（“#{jobParameters['run-date']}”）
如果对myBatisPagingItemReader()bean方法使用@stepscope

我用下面的例子解释了这个问题。

@Configuration
@EnableBatchProcessing
public class BatchConfig {
    @Bean
    public Step step1(StepBuilderFactory stepBuilderFactory,
        ItemReader<Model> myBatisPagingItemReader,
        ItemProcessor<Model, Model> itemProcessor,
         ItemWriter<Model> itemWriter) {

         return stepBuilderFactory.get("data-load")
            .<Model, Model>chunk(10)
            .reader(myBatisPagingItemReader)
            .processor(itemProcessor)
             .writer(itemWriter)
             .listener(itemReadListener())
             .listener(new JobParameterExecutionContextCopyListener())
             .build();
   }
   @Bean
   public Job job(JobBuilderFactory jobBuilderFactory, @Qualifier("step1") 
               Step step1) {
           return jobBuilderFactory.get("load-job")
            .incrementer(new RunIdIncrementer())
            .start(step1)
            .listener(jobExecutionListener())
            .build();
   }
   @Bean
   @StepScope
   public ItemReader<Model> myBatisPagingItemReader(
         SqlSessionFactory sqlSessionFactory,
         @Value("#{JobParameters['run-date']}") String runDate) 
  {
     MyBatisPagingItemReader<Model> reader = new 
     MyBatisPagingItemReader<>();
     Map<String, Object> parameterValues = new HashMap<>();
     parameterValues.put("runDate", runDate);
     reader.setSqlSessionFactory(sqlSessionFactory);
     reader.setParameterValues(parameterValues);
     reader.setQueryId("query");
     return reader;
   }
}

重新启动示例当我将@stepscope注释使用到MyBatiSpagingItemReader()时，读取器正在获取5条记录，而我将块大小（commit-interval）设置为3。

作业实例-01-作业参数-01/02/2019。
块-1:
-进程记录-1
-进程记录-2
-进程记录-3
写入器-写入所有3条记录
块-1提交成功

块2:
进程记录-4
进程记录-5-抛出和异常
作业完成并设置为“失败”状态

现在使用相同的作业参数再次重新启动作业。
作业实例-01-作业参数-01/02/2019。
chunk-1:
进程记录-1
进程记录-2
进程记录-3
writer-写入所有3条记录
chunk-1提交成功

块2:
进程记录-4
进程记录-5-抛出和异常
作业完成并设置为“失败”状态

MyBatiSpagingItemReader()bean方法上的@stepscope注释创建了一个新实例，请参阅下面的日志消息。
在scope=step,name=ScopedTarget中创建对象。MyBatiSpagingItemReader
在scope=step,name=ScopedTarget中注册了销毁回调。MyBatiSpagingItemReader
因为是新实例，所以它从start开始进程，而不是从Chunk-2开始。

如果不使用@stepscope，它将从块-2重新启动，因为重新启动的作业步骤集-mybatispagingitemreader.read.count=3。

Answer 1

这里的问题是，您返回的是ItemReader而不是完全限定类(MyBatispagingItemReader)或至少是ItemStreamReader。当您使用Spring Batch的step范围时，我们会创建一个代理来允许后期初始化。代理基于方法的返回类型（在您的示例中为itemreader)。您遇到的问题是，因为代理是itemreader，所以Spring Batch不知道您的bean也实现了itemstream，而正是该接口启用了可重启性。默认情况下，Spring批处理将自动为您注册itemstream类型的所有bean（您也可以自己显式注册bean，但通常不需要）。

要解决您的问题，以下方法应该起作用（注意返回类型中的更改）：

   @Bean
   @StepScope
   public MyBatisPagingItemReader<Model> myBatisPagingItemReader(
         SqlSessionFactory sqlSessionFactory,
         @Value("#{JobParameters['run-date']}") String runDate) {

     MyBatisPagingItemReader<Model> reader = 
         new MyBatisPagingItemReader<>();

     Map<String, Object> parameterValues = new HashMap<>();
     parameterValues.put("runDate", runDate);

     reader.setSqlSessionFactory(sqlSessionFactory);
     reader.setParameterValues(parameterValues);
     reader.setQueryId("query");

     return reader;
   }

这就是为什么我建议在可能的情况下，当使用@bean注释方法时，应该返回尽可能具体的类型，以允许Spring尽可能地提供帮助。