在创建弹簧批处理bean时获取“范围'步骤'对于当前线程不活动”

Question

在我的 Spring 批处理配置中，我正在尝试设置一个分区步骤，该步骤从 JobParameters 访问值，如下所示：

@Bean
@Qualifier("partitionJob")
public Job partitionJob() throws Exception {

    return jobBuilderFactory
            .get("partitionJob")
            .incrementer(new RunIdIncrementer())
            .start(partitionStep(null))
            .build();
}

@Bean
@StepScope //I'm getting exception here - > Error creating bean 
public Step partitionStep(
        @Value("#{jobParameters[gridSize]}") String gridSize)
        throws Exception {

    return stepBuilderFactory
            .get("partitionStep")
            .partitioner("slaveStep", partitioner())
            .gridSize(
                    StringUtils.isEmpty(gridSize) ? 10 : Integer
                            .parseInt(gridSize))
            .step(slaveStep(50000))
            .taskExecutor(threadPoolTaskExecutor()).build();
}

@Bean
@StepScope
public Step slaveStep(int chunkSize) throws Exception {

    return stepBuilderFactory
            .get("slaveStep")
            .<Person,Person> chunk(chunkSize)
            .reader(jdbcPagingItemReader()),
            .writer(csvFileWriterParts())
            .listener(stepExecutionListener()).build();
}

我在我的 SpringBoot 应用程序中添加了@EnableBatchProcessing 注解。

因为我想在构建步骤时访问 JobParameters，所以我使用了@StepScope。我有一个工作正常的示例，没有 @StepScope 注释，但在这种情况下，我没有从上下文访问任何 JobParameters 或任何内容。

但是如果我在 partitionStep 上使用 StepScope 注释，我会得到 ​​p>

创建名为“scopedTarget.partitionStep”的 bean 时出错：范围 'step' 对当前线程无效；考虑定义一个 如果您打算从 单身人士；嵌套异常是 java.lang.IllegalStateException: No 可用于步骤范围的上下文持有者

但如果我将其更改为 JobScope，那么它会在 slaveStep() 处失败并显示相同的错误消息。

在这种情况下使用的正确范围是什么？如何解决我遇到的这个问题？

在配置 spring bean 时访问 JobParameters 的更好方法是什么？

异常堆栈如下

2018-05-25 21:07:32,075 错误 [主要] org.springframework.batch.core.job.AbstractJob ：遇到致命的 错误执行作业 org.springframework.beans.factory.BeanCreationException：错误 创建名为“scopedTarget.partitionStep”的bean：范围“step”是 对当前线程无效；考虑定义一个作用域代理 如果您打算从单例中引用此 bean；嵌套的 例外是 java.lang.IllegalStateException: No context holder 可用于步骤范围 org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:361) 在 org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:197) 在 org.springframework.aop.target.SimpleBeanTargetSource.getTarget(SimpleBeanTargetSource.java:35) 在 org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:192) 在 com.sun.proxy.$Proxy55.getName(Unknown Source) 在 org.springframework.batch.core.job.SimpleStepHandler.handleStep(SimpleStepHandler.java:115) 在 org.springframework.batch.core.job.AbstractJob.handleStep(AbstractJob.java:392) 在 org.springframework.batch.core.job.SimpleJob.doExecute(SimpleJob.java:135) 在 org.springframework.batch.core.job.AbstractJob.execute(AbstractJob.java:306) 在 org.springframework.batch.core.launch.support.SimpleJobLauncher$1.run(SimpleJobLauncher.java:135) 在 org.springframework.core.task.SyncTaskExecutor.execute(SyncTaskExecutor.java:50) 在 org.springframework.batch.core.launch.support.SimpleJobLauncher.run（SimpleJobLauncher.java:128） 在 sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 在 sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 在 sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 在 java.lang.reflect.Method.invoke(Method.java:498) 在 org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:333) 在 org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:190) 在 org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157) 在 org.springframework.batch.core.configuration.annotation.SimpleBatchConfiguration$PassthruAdvice.invoke(SimpleBatchConfiguration.java:127) 在 org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179) 在 org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:213) 在 com.sun.proxy.$Proxy54.run（未知来源） com.sample.main(ExtractApplication.java:58) 引起：java.lang.IllegalStateException：没有上下文持有者 可用于步骤范围 org.springframework.batch.core.scope.StepScope.getContext(StepScope.java:167) 在 org.springframework.batch.core.scope.StepScope.get(StepScope.java:99) 在 org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:346) ...省略了23个常用框架

如果我修改为 JobScope，我会在 slaveStep 上得到异常，这类似于上面的异常。

Answer 1

请尝试由 Manh 发布的 Spring batch scope issue while using spring boot 选项。我想它解决了这个问题。不幸的是，我无法再访问代码库，以确认我为修复所做的工作。