[JAVA] Paramètres de lancement de tâche Spring Batch

Comment utiliser les paramètres de lancement de tâche spring-batch dans un environnement spring-boot

Code source etc.

build.gradle

build.gradle

plugins {
  id 'org.springframework.boot' version '2.2.6.RELEASE'
  id 'io.spring.dependency-management' version '1.0.9.RELEASE'
  id 'java'
}

configurations {
  developmentOnly
  runtimeClasspath {
    extendsFrom developmentOnly
  }
  compileOnly {
    extendsFrom annotationProcessor
  }
}


repositories {
  mavenCentral()
}

dependencies {
  implementation 'org.springframework.boot:spring-boot-starter-batch'

  compileOnly 'org.projectlombok:lombok'
  annotationProcessor 'org.projectlombok:lombok'
  testImplementation('org.springframework.boot:spring-boot-starter-test') {
    exclude group: 'org.junit.vintage', module: 'junit-vintage-engine'
  }
  testImplementation 'org.springframework.batch:spring-batch-test'
  implementation 'com.h2database:h2'
}

test {
  useJUnitPlatform()
}

Comment spécifier les paramètres de début de tâche

Lorsqu'il est utilisé avec spring-boot, s'il est spécifié comme argument de ligne de commande comme indiqué ci-dessous, il sera traité comme un paramètre de début de tâche de spring-batch.

java -jar springbatchsample.jar hoge.param001=hoge

Comment recevoir

Comment recevoir les paramètres de lancement de tâche en java. Il existe plusieurs variantes de cela. L'implémentation du lecteur est appropriée, alors sautez-la.

SpEL - jobParameters['hoge.param001'] Comment utiliser SpEL et @ Value ''. Si vous faites @ Value (" # {jobParameters ['hoge.param001']} ") comme indiqué ci-dessous, vous recevrez `` `hoge.param001 = hoge``` sur la ligne de commande ci-dessus.

import org.springframework.batch.core.configuration.annotation.StepScope;
import org.springframework.batch.item.ItemReader;
import org.springframework.batch.item.NonTransientResourceException;
import org.springframework.batch.item.ParseException;
import org.springframework.batch.item.UnexpectedInputException;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

@Component
@StepScope
public class MyReader implements ItemReader<Integer> {

  @Value("#{jobParameters['hoge.param001']}")
  String param001;

  @Override
  public Integer read() throws Exception, UnexpectedInputException, ParseException, NonTransientResourceException {
    System.out.println(param001);
    
    return null;
  }

}

Par précaution de cette méthode, il est nécessaire d'ajouter @ StepScope```. Voir https://terasoluna-batch.github.io/guideline/5.0.0.RELEASE/en/Ch04_JobParameter.html#Ch04_JobParameter_HowToUse_CLIArgs pour la raison, "La portée du bean qui fait référence aux JobParameters doit être la portée Step". ..

beforeStep Comment utiliser l'écouteur @ BeforeStep et obtenir le paramètre de démarrage du travail à partir de l'argument de méthode `` `` stepExecution.

@Component
public class MyReader2 implements ItemReader<Integer>  {
  
  @BeforeStep
  void beforeStep(StepExecution stepExecution) {
    String param001 = stepExecution.getJobParameters().getString("hoge.param001");
    System.out.println("##" + param001);
  }

  @Override
  public Integer read() throws Exception, UnexpectedInputException, ParseException, NonTransientResourceException {
    return null;
  }

}

En tant que variante de ce qui précède, il existe également un moyen d'implémenter le traditionnel `` StepExecutionListener '' au lieu d'annotations.

public class MyReader3 implements ItemReader<Integer>, StepExecutionListener  {

  @Override
  public void beforeStep(StepExecution stepExecution) {
    String param001 = stepExecution.getJobParameters().getString("hoge.param001");
    System.out.println("###" + param001);
  }
  
  @Override
  public Integer read() throws Exception, UnexpectedInputException, ParseException, NonTransientResourceException {
    return null;
  }

  @Override
  public ExitStatus afterStep(StepExecution stepExecution) {
    return stepExecution.getExitStatus();
  }

}