MultiResourceItemReader上的Spring-batch失败

Question

我正在尝试创建一个处理上一步保存的文件的作业.

作业定义如下:

<bean id="downloadCatalogTasklet" class="DownloadCatalogTasklet" scope="step" />

<bean id="customItemReader" class="CustomItemReader" scope="step"/>

<bean id="itemWriter" class="NoOpItemWriter" scope="step"/>

<bean id="multiResourceReader" class="org.springframework.batch.item.file.MultiResourceItemReader" scope="step">
        <property name="strict" value="true" />
        <property name="resources" value="file://C:/temp/unzipped/*.txt" />
        <property name="delegate" ref="customItemReader" />
    </bean>

<batch:job id="importCatalog">
   <batch:step id="downloadCatalog">
      <batch:tasklet ref="downloadCatalogTasklet" />
      <batch:next on="COMPLETED" to="processCatalog" />
      <batch:fail on="FAILED"/>
   </batch:step>
   <batch:step id="processCatalog">
      <batch:tasklet>
         <batch:chunk reader="multiResourceReader" writer="itemWriter" commit-interval="1" />
      </batch:tasklet>
   </batch:step>
</batch:job>

第一步工作正常.目录已下载并正确解压缩.但是,当spring批量尝试执行步骤processCatalog时,它会抛出以下错误(只是):

2016-08-23 09:45:31 ERROR AbstractStep:229 - Encountered an error executing step processCatalog in job importCatalog
java.lang.IllegalArgumentException: Name must be assigned for the sake of defining the execution context keys prefix.
    at org.springframework.util.Assert.hasText(Assert.java:162)
    at org.springframework.batch.item.util.ExecutionContextUserSupport.getKey(ExecutionContextUserSupport.java:59)
    at org.springframework.batch.item.ItemStreamSupport.getExecutionContextKey(ItemStreamSupport.java:71)
    at org.springframework.batch.item.support.AbstractItemCountingItemStreamItemReader.update(AbstractItemCountingItemStreamItemReader.java:183)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:497)
    at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:317)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:190)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157)
    at org.springframework.aop.support.DelegatingIntroductionInterceptor.doProceed(DelegatingIntroductionInterceptor.java:133)
    at org.springframework.aop.support.DelegatingIntroductionInterceptor.invoke(DelegatingIntroductionInterceptor.java:121)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
    at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:207)
    at com.sun.proxy.$Proxy7.update(Unknown Source)
    at org.springframework.batch.item.file.MultiResourceItemReader.update(MultiResourceItemReader.java:209)

这是我第一次使用MultiResourceItemReader.我不知道我是否遗漏了什么.我正在使用带有java 1.7的spring-batch 3.0.7.

我似乎应该为ExecutionContext指定一个名称,但我不知道该怎么做.

Answer 1

您需要在配置中为ItemReaders 指定一个名称,以便ExecutionContext可以为其中的值添加前缀,因此每个读取器的值是唯一的.如下配置您的读者,他们应该工作:

<bean id="multiResourceReader" class="org.springframework.batch.item.file.MultiResourceItemReader" scope="step">
      <property name="name" value="myMultiResourceItemReader"/>
      <property name="strict" value="true" />
      <property name="resources" value="file://C:/temp/unzipped/*.txt" />
      <property name="delegate" ref="customItemReader" />
</bean>