2

プロジェクトでスプリングバッチとクォーツを使用しようとしています。目的は、Quartzを使用してSpring-Batchジョブをスケジュールすることです。私は次の豆を持っています-

bean id="updateDataFeedJob"  class="package.UpdateDataFeedJob" />     

<bean id="UpdaterOnScheduleJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    <property name="targetObject" ref="updateDataFeedJob"/>
    <!-- the method to call inside of com.siemens.scr.schedule.UpdateDataFeedJob -->
    <property name="targetMethod" value="execute"/>
</bean> 

<bean id="cronTriggerId" class="org.springframework.scheduling.quartz.CronTriggerBean">
    <property name="jobDetail" ref="UpdaterOnScheduleJobDetail" />
    <!-- run every morning at 3AM -->
    <!--  <property name="cronExpression" value="0 0 3 * * ?" /> -->

    <!-- Fires every five minutes -->
    <property name="cronExpression" value="0 0/5 * * * ?" />
</bean>

<bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
    <property name="triggers">
        <list>
            <ref bean="cronTriggerId" />
        </list>
    </property>
</bean>

UpdateDataFeedJobは-

public class UpdateDataFeedJob  {   
  public void execute() throws Exception {
    System.out.println("Hello World. Running the job");
    CommandLineJobRunner.main(new String[]{"GetFleetUpdatesJob.xml", "getFleetUpdatesJob"});
  }  
}

サンプルの呼び出しは-

public class Client {
    public static void main(String[] args){
        //CommandLineJobRunner.main(new String[]{"GetFleetUpdatesJob.xml", "getFleetUpdatesJob"});
        new ClassPathXmlApplicationContext("GetFleetUpdatesJob.xml");
    }   
}

次の例外が発生し続けます-

ERROR - Job Terminated in error: A job execution for this job is already running: JobInstance: id=0, JobParameters=[{}], Job=[getFleetUpdatesJob]
org.springframework.batch.core.repository.JobExecutionAlreadyRunningException: A job execution for this job is already running: JobInstance: id=0, JobParameters=[{}], Job=[getFleetUpdatesJob]
    at org.springframework.batch.core.repository.support.SimpleJobRepository.createJobExecution(SimpleJobRepository.java:112)
    at org.springframework.batch.core.launch.support.SimpleJobLauncher.run(SimpleJobLauncher.java:98)
    at org.springframework.batch.core.launch.support.CommandLineJobRunner.start(CommandLineJobRunner.java:291)
    at org.springframework.batch.core.launch.support.CommandLineJobRunner.main(CommandLineJobRunner.java:448)
    at com.siemens.scr.schedule.UpdateDataFeedJob.execute(UpdateDataFeedJob.java:10)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
    at java.lang.reflect.Method.invoke(Method.java:597)
    at org.springframework.util.MethodInvoker.invoke(MethodInvoker.java:276)
    at org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean$MethodInvokingJob.executeInternal(MethodInvokingJobDetailFactoryBean.java:260)
    at org.springframework.scheduling.quartz.QuartzJobBean.execute(QuartzJobBean.java:86)
    at org.quartz.core.JobRunShell.run(JobRunShell.java:202)
    at org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:525)
4

3 に答える 3

1

私はこれを機能させました。私は正確な理由を知りません＆誰かがコメントすることができれば感謝します-

次のBean構成をapplicationContext.xmlに追加しました

<bean id="transactionManager" class="org.springframework.batch.support.transaction.ResourcelessTransactionManager"/>

今、私はその例外を取得していません＆クォーツは春のバッチジョブを呼び出すことができます

于 2011-08-15T18:02:58.293 に答える
1

Spring Batchは、提供されたJobパラメーターを使用して、同じジョブの異なる実行を区別します。

コードサンプルに見られるように、Jobパラメータを渡していないため、すべてのジョブの実行はSpring Batchに従って同じになり、実行状態でスタックしているインスタンスがあると、SpringBatchはJobAlreadyRunningExceptionをスローします。

于 2011-10-24T09:04:00.410 に答える
0

同じ問題がありました。誰かがクォーツウィンドウを締めるのではないかと心配しましたが、クォーツにはありませんScheduleExector.scheduleAtFixedDelay。shceduleAtFixedRateバッチジョブが重複する可能性があるため、次のようになります。

  1. ジョブパラメータを追加して、ジョブを一意にします
  2. フィールドを持つJavaクォーツトリガーに静的変数をisRunning配置して、期間が厳しすぎる場合に備えて、ジョブが1つのJVMで2つのインスタンスを実行しないようにします。
于 2012-05-24T18:58:59.943 に答える