应用程序服务器上的Spring批处理：在afterJob侦听器上找不到

Question

我对Spring批处理和Spring一般都是新手。我正在开发一个将在WebSphere Application Server上运行的批处理作业。到目前为止，我只是用一些假的台阶搭建了一个骷髅。我还有一个监听器，用于在作业结束时更新一些Oracle DB表。以下是我的AppContext的一部分：

<batch:job id="spedizioneJob" restartable="true" parent="bankitJob">
        <batch:step id="verifyInputStep" next="technicalPropertiesEnforcementStep">
            <batch:tasklet ref="verifyInput" />
        </batch:step>
        <batch:step id="technicalPropertiesEnforcementStep" next="protocolAndProbatoryStep">
            <batch:tasklet ref="technicalPropertiesEnforcement" />
        </batch:step>
        <batch:step id="protocolAndProbatoryStep" next="exdiSendingStep">
            <batch:tasklet ref="protocolAndProbatory" />
        </batch:step>
        <batch:step id="exdiSendingStep">
            <batch:tasklet ref="exdiSending" />
        </batch:step>
        <batch:listeners merge="true">
            <batch:listener ref="spedizioneJobListener" />
        </batch:listeners>
    </batch:job>

下面是afterJob代码段的开头：

public void afterJob(JobExecution jobExecution) {

    // get params
    String iref = jobExecution.getJobParameters().getString("APPL_REQ_ID");
    SpedizioneInput spInput=(SpedizioneInput)jobExecution.getExecutionContext().get("input");

奇怪的是，在我的一些测试运行中（Rational Application Developer上的本地测试环境，但同样的情况发生在WAS的服务器上），通常不是第一次，没有找到作业执行，我得到了这个异常：

[03/10/14 12.47.48:505 CEST] 0000003a AbstractJob   E org.springframework.batch.core.job.AbstractJob execute Encountered fatal error executing job
                                 org.springframework.batch.core.repository.dao.NoSuchObjectException: Invalid JobExecution, ID 224 not found.
    at org.springframework.batch.core.repository.dao.JdbcJobExecutionDao.updateJobExecution(JdbcJobExecutionDao.java:218)
    at org.springframework.batch.core.repository.support.SimpleJobRepository.update(SimpleJobRepository.java:160)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:48)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
    at java.lang.reflect.Method.invoke(Method.java:600)
    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.transaction.interceptor.TransactionInterceptor$1.proceedWithInvocation(TransactionInterceptor.java:98)
    at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:262)
    at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:95)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
    at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:207)
    at $Proxy36.update(Unknown Source)
    at org.springframework.batch.core.job.AbstractJob.updateStatus(AbstractJob.java:416)
    at org.springframework.batch.core.job.AbstractJob.execute(AbstractJob.java:299)
    at org.springframework.batch.core.launch.support.SimpleJobLauncher$1.run(SimpleJobLauncher.java:135)
    at java.lang.Thread.run(Thread.java:736)

我不知道这是不是和我处理工作的方式有关....我配置了这样一种发射器：

<bean id="jobLauncher"
    class="org.springframework.batch.core.launch.support.SimpleJobLauncher">
    <property name="jobRepository" ref="jobRepository" />
    <property name="taskExecutor">
        <bean class="org.springframework.core.task.SimpleAsyncTaskExecutor" />
    </property>
</bean>

try {
            System.out.println("Before launching spedizione job");
            JobExecution jexec=jobLauncher.run(job, jpb.toJobParameters());
            System.out.println("After launching spedizione job "+jexec.getJobConfigurationName()+" status "+jexec.getStatus().toString());

Answer 1

正如Michael所建议的，问题出在我所使用的事务管理器上。当我切换到WebSphereUowTransactionManager时，我解决了我的问题。http://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/transaction/jta/websphereuowtransactionmanager.html