spring batch 5.0

---

layout : post
title : "spring batch 5.0"

category : Spring

spring boot 3.0에서 spring batch 5.0이 추가되었다.
spring batch 5.0 에서 기존에 아래와 같이 사용하던 방법이 deprecated 되었다.

1. 기존

@Configuration
@RequiredArgsConstructor
@Slf4j
public class MemberBatchJobConfig {
	private final JobBuilderFactory jobBuilderFactory;
    private final StepBuilderFactory stepBuilderFactory;
    private final MemberService memberService;
    
    @Value("${chunkSize:1000}")
    private int getChunkSize;
    
    @Bean
    public Job memberJob() {
    	return jobBuilderFactory.get("memberJob")
        		.start(memberStep())
                .build();
       	}
        
   @Bean
   @JobScope
   public Step memberStep() {
   		return this.stepBuilderFactory.get("memberStep")
        .<Member, Member>chunk(getChunkSize)
        .reader(this.memberReader())
        .writer(this.memberWireter())
        .build();
   }

   private ListItemReader<Member> memberReader() {
   		return new ListItemReader<>(this.memberService.findAll());
   }
   
   @Bean
   public ItemWriter<Member> memberWriter() {
   		return this::all;
   }
  
   private void all(final List<? extends Member> list) {
   		list.forEach(item -> {
        log.info(item);
   });
  }
 }

2. Spring Batch 5.0 에서의 방법

@EnableBatchProcessing
@Configuration
@EnableScheduling
public class Config {}

package com.moow.flexi.domain.user.instructor.entity;

@Configuration
@RequiredArgsConstructor
@Slf4j
public class CustomJobConfig extends DefaultBatchConfiguration {
  private final MemberService memberService;

  @Value("${chunkSize:1000}")
  private int getChunkSize;

  @Bean
  public Job job(final JobRepository jobRepository, final Step sendSmsStackStep) {
    return new JobBuilder("job", jobRepository).start(sendSmsStackStep).build();
  }

  @Bean
  public Step step(
      final JobRepository jobRepository, final PlatformTransactionManager transactionManager) {
    return new StepBuilder("step", jobRepository)
        .chunk(this.getChunkSize, transactionManager)
        .reader(this.memberReader())
        .writer(this.memberWriter())
        .build();
  }

  private ListItemReader<Member> memberReader() {
    return new ListItemReader<>(this.memberService.getAllMember());
  }

  @Bean
  public ItemWriter<Object> memberWriter() {
    return this::loggingAll;
  }

  private void loggingAll(final Chunk<?> objects) {
    objects.getItems().forEach(item -> log.info(item.toString()));
  }
}

3. 참고

import java.util.Map;

@Component
@RequiredArgsConstructor
public class JobScheduler {
  private final Job job;
  private final JobLauncher jobLauncher;

  @Scheduled(cron = "0 0 9 * * *", zone = "Asia/Seoul")
  public void nine() {
    this.schedulerRun(this.job);
  }

  private void schedulerRun(final Job job) {
    final Map<String, JobParameter<?>> stringJobParameterMap = new SoftHashMap<>();
    stringJobParameterMap.put("time", new JobParameter<>(System.currentTimeMillis(), Long.class));
    final JobParameters jobParameters = new JobParameters(stringJobParameterMap);
    try {
      this.jobLauncher.run(job, jobParameters);
    } catch (JobExecutionAlreadyRunningException
        | JobInstanceAlreadyCompleteException
        | JobParametersInvalidException
        | JobRestartException e) {
      e.printStackTrace();
    }
  }
}