Spring Batch 6 で Listener を追加してﾛｸﾞを出す[ﾌﾟﾛｸﾞﾗﾐﾝｸﾞ]
(2026-07-13 23:33:36) by shinoda

< ﾍﾟｰｼﾞ移動: 1 2 >

Spring Batch で用意されている Event Listener も色々あるが､とりあえず Job の実行前後で起動する JobListener を使ってﾛｸﾞを吐いてみよう｡

｢一番ｼﾝﾌﾟﾙな Spring Batch 6 の Chunk 処理例｣で作ったﾊﾞｯﾁ処理に足してみる｡

■LogJobListener.java の作成

JobExecutionListener を実装した Job の前後にﾛｸﾞを吐くｸﾗｽ｡beforeJob に Job の前の処理を､afterJob に後の処理を書く｡

package com.netandfield.test.Listener;

import org.springframework.batch.core.job.JobExecution;
import org.springframework.batch.core.listener.JobExecutionListener;
import org.springframework.stereotype.Component;

import lombok.extern.slf4j.Slf4j;

@Component
@Slf4j
public class LogJobListener implements JobExecutionListener {

    @Override
    public void beforeJob(JobExecution jobExecution) {
        log.info("★Job started: " + jobExecution.getJobInstance().getJobName());
    }

    @Override
    public void afterJob(JobExecution jobExecution) {
        log.info("★Job finished: " + jobExecution.getJobInstance().getJobName() + " with status: " + jobExecution.getStatus());
    }

}


■BatchConfig.java

ﾊﾞｯﾁ設定に Listener をｾｯﾄする

import部に､

import org.springframework.batch.core.listener.JobExecutionListener;
import org.springframework.beans.factory.annotation.Autowired;

を追加｡

ﾒﾝﾊﾞ変数に jobListener を宣言｡

＜略＞
@Configuration
public class BatchConfig {

    private final JobRepository jobRepository;
    private final PlatformTransactionManager transactionManager;
    private final DataSource dataSource;

    @Autowired
    private JobExecutionListener jobListener;
＜略＞

Jobの定義に JobListener を追加する

    @Bean
    public Job exportJob() {
        return new JobBuilder("exportJob", jobRepository)
                .start(exportStep())
                .listener(jobListener) // JobExecutionListenerを追加
                .build();
    }


ここまでｿｰｽをを修正したら実行｡

これで､以下のようなﾛｸﾞが出力される(長いので頭の方を｢〜｣と略している)

< ﾍﾟｰｼﾞ移動: 1 2 >

ｺﾒﾝﾄ投稿
次の記事へ >
< 前の記事へ
TOPへ戻る

Powered by
MT4i 3.0.8