Springバッチジョブを特定の順序（Spring Boot）で実行する方法は？

Question

私はSpring Batchを使ってSpring Bootを使って開発しています。

私はSpring Bootが提供する最小限の設定で、いくつかのジョブを定義しました（XML構成はまったくありません）。しかし、アプリケーションを実行すると、ジョブは任意の順序で順番に実行されます。

私は@Configuration注釈付きクラス内のジョブをこのように定義しています、春は残りを行います。

@Bean 
public Job requestTickets() { 
    return jobBuilderFactory.get(Config.JOB_REQUEST_TICKETS) 
      .start(stepRequestTickets()) 
      .build(); 
} 

はどのようにして、特定の順序でジョブを実行するためのフレームワークを指示することができますか？

編集：この警告はヒントを与えることができますか？ （おそらく何もない）

2016-12-29 17:45:33.320 WARN 3528 --- [main] o.s.b.c.c.a.DefaultBatchConfigurer: No datasource was provided...using a Map based JobRepository 

Answer 1

1.Youである - と仮定しApplicationContext ctx = SpringApplication.run(SpringBatchMain.class, args);メインクラスの名前はSpringBatchMain.javaです。

これは、ジョブを開始せずにコンテキストを初期化します。

あなたが行うことができ、コンテキストが初期化され3.Once、どちらか - JobLauncher jobLauncher = (JobLauncher) ctx.getBean("jobLauncher");またはメインクラスでこのJobLauncher BeanのAutowiredを行うと、jobLauncher.run(job, jobParameters)を呼び出すことによって、特定の順序で順次、特定のジョブを起動します。

あなたはいつもそこにあなたの仕事を入れて、そのコレクションを反復処理でジョブを起動するために任意の順序付きコレクションを使用することができ、ステップ＃2

で初期化されたコンテキストから特定のjobのインスタンスを取得することができます。

4。この上のテクニックは、JobLauncherが同期するように構成されている限り、すなわちメインスレッドがjobLauncher.run()呼び出しを完了するまで待っていれば動作します。これはjobLauncherのデフォルトの動作です。

asyncTaskExecutorを使用するようにjobLauncherを定義した場合、ジョブは並行して開始され、順番付けは維持されません。

希望すると助かります！

EDIT：ステファン・ニコルで指示し、唯一の仕事の順序付きコレクションを作成するには、あなたが反復処理し、そのためには、ジョブを起動することができることを助けるように見えるよう

は私が@Order注釈で実験されました。

コンポーネントの下にこれは、指定された順序で私に仕事を与える

@Component 
public class MyJobs { 
    @Autowired 
    private List<Job> jobs; 

    public List<Job> getJobs() { 
     return jobs; 
    } 
} 

と私は行うことができ、メインクラスでMyJobs myJobs = (MyJobs) ctx.getBean("myJobs");は、Beanが定義されて、

@Bean 
    public MyJobs myJobs() { 
     return new MyJobs(); 
    } 

私はmyJobsを反復処理すると、ジョブを起動することができます@Orderアノテーションで指定された順番で

Answer 2

を注文する。

@Bean 
@Order(42) 
public Job requestTickets() { 
    return jobBuilderFactory.get(Config.JOB_REQUEST_TICKETS) 
      .start(stepRequestTickets()) 
      .build(); 
} 

詳しくはを参照してください。

Answer 3

1つのジョブが2番目のジョブなどに依存する場合は、次のようにします。

@Configuration 
@EnableBatchProcessing 
@Import(DataSourceConfiguration.class) 
public class AppConfig { 

    @Autowired 
    private JobBuilderFactory jobs; 

    @Autowired 
    private StepBuilderFactory steps; 

    @Bean 
    public Job job(@Qualifier("step1") Step step1, @Qualifier("step2") Step step2) { 
     return jobs.get("myJob").start(step1).next(step2).build(); 
    } 

    @Bean 
    protected Step step1(ItemReader<Person> reader, ItemProcessor<Person, Person> processor, ItemWriter<Person> writer) { 
     return steps.get("step1") 
      .<Person, Person> chunk(10) 
      .reader(reader) 
      .processor(processor) 
      .writer(writer) 
      .build(); 
    } 

    @Bean 
    protected Step step2(Tasklet tasklet) { 
     return steps.get("step2") 
      .tasklet(tasklet) 
      .build(); 
    } 
} 

Answer 4

コメントするのに十分な担当者がいません。しかし、あなたはあなたが望む順番であなたの仕事を手作業で起動しようとしましたか？

application.propertiesにspring.batch.job.enabled = falseを設定して、ジョブが自動的に実行されないようにする必要があります。

その後、ランチャーを使って必要な順番でジョブを起動してください。ここで

@RunWith(SpringRunner.class) 
@SpringBootTest(classes = { TestConfiguration.class, TestDataSourceConfiguration.class, TestBatchConfig.class }) 
public class JobOrderTest { 

    @Autowired 
    JobLauncher jobLauncher; 

    @Mock 
    Job firstJob; 

    @Mock 
    Job secondJob; 

    @Mock 
    Job thirdJob; 

    @Mock 
    JobParametersValidator jobParametersValidator; 

    @Test 
    public void jobInOrderTest() throws JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException, JobParametersInvalidException { 

     when(firstJob.getName()).thenReturn(UUID.randomUUID().toString()); 
     when(secondJob.getName()).thenReturn(UUID.randomUUID().toString()); 
     when(thirdJob.getName()).thenReturn(UUID.randomUUID().toString()); 
     when(firstJob.getJobParametersValidator()).thenReturn(jobParametersValidator); 
     when(secondJob.getJobParametersValidator()).thenReturn(jobParametersValidator); 
     when(thirdJob.getJobParametersValidator()).thenReturn(jobParametersValidator); 

     jobLauncher.run(firstJob, new JobParameters()); 
     jobLauncher.run(secondJob, new JobParameters()); 
     jobLauncher.run(thirdJob, new JobParameters()); 
    } 

} 

が行う、最初 spring.batch.job.enabled=false でapplication.properties

2.Inあなたのメインクラスを指定することにより、ジョブの自動開始を無効に出力

2016-12-30 09:48:36.457 INFO 144860 --- [cTaskExecutor-1] o.s.b.c.l.support.SimpleJobLauncher  : Job: [firstJob] launched with the following parameters: ... 
2016-12-30 09:48:36.457 INFO 144860 --- [cTaskExecutor-1] o.s.b.c.l.support.SimpleJobLauncher  : Job: [firstJob] completed with the following parameters: ... 
2016-12-30 09:48:36.478 INFO 144860 --- [cTaskExecutor-2] o.s.b.c.l.support.SimpleJobLauncher  : Job: [secondJob] launched with the following parameters: ... 
2016-12-30 09:48:36.478 INFO 144860 --- [cTaskExecutor-2] o.s.b.c.l.support.SimpleJobLauncher  : Job: [secondJob] completed with the following parameters: ... 
2016-12-30 09:48:36.508 INFO 144860 --- [cTaskExecutor-3] o.s.b.c.l.support.SimpleJobLauncher  : Job: [thirdJob] launched with the following parameters: ... 
2016-12-30 09:48:36.508 INFO 144860 --- [cTaskExecutor-3] o.s.b.c.l.support.SimpleJobLauncher  : Job: [thirdJob] completed with the following parameters: ...