[JAVA] Créez un lot à la demande simple avec Spring Batch

Abstrait

Créez un Spring Batch simple et lancez-le par lots à partir d'une requête Web.

environnement

• Java SE 8 (jdk-8u181)
• Spring Boot 2.1.0

Procédure détaillée

Création de projet

Ajoutez spring-boot-starter-batch à la dépendance pour utiliser SpringBatch. De plus, étant donné que DB est utilisé pour la gestion des travaux, un JDBC approprié est également ajouté.

pom.xml

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-batch</artifactId>
</dependency>
<dependency>
  <groupId>org.postgresql</groupId>
  <artifactId>postgresql</artifactId>
  <scope>runtime</scope>
</dependency>

Création de lots

** Fondamentalement créé en faisant référence à ici **

Traitement réel par lots

Créez une classe de traitement appropriée en tant que @ Service

@Service
public class MyBatchService {

	public void execute(Long id, String name, Date reqDate) throws InterruptedException {
		//Traitement par lots approprié
		Thread.sleep(5000);
	}
}

Paramétrage des lots

Le cœur du traitement par lots. Cette fois, créez facilement une tâche (tasklet) en une seule étape. Défini dans la classe de configuration Java.

@Configuration
@EnableBatchProcessing //(1)
public class BatchConfig {

	@Autowired
	private JobBuilderFactory jobBuilderFactory; //(2)
	@Autowired
	private StepBuilderFactory stepBuilderFactory; //(2)

	@Autowired
	private MyBatchService service;

	@Bean
	public JobLauncher jobLauncher1(JobRepository jobRepository) { //(2),(3)
		ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
		//Le nombre d'exécutions simultanées est de 3.Attendez plus de files d'attente.
		taskExecutor.setCorePoolSize(3); //(4)
		// java.lang.IllegalStateException: ThreadPoolTaskExecutor not initialized
		taskExecutor.initialize(); //(5)

		SimpleJobLauncher jobLauncher = new SimpleJobLauncher();
		jobLauncher.setJobRepository(jobRepository);
		jobLauncher.setTaskExecutor(taskExecutor);

		return jobLauncher;
	}

	@Bean
	public Job job(Step step1) { //(6)
		return jobBuilderFactory.get("batchjob")
					.incrementer(new RunIdIncrementer())
					.start(step1)
					.build();
	}

	@Bean
	public Step step1(Tasklet tasklet1) { //(6)
		return stepBuilderFactory.get("step1")
					.tasklet(tasklet1)
					.build();
	}

	@Bean
	@StepScope //(7)
	public Tasklet tasklet1( //(6)
			@Value("#{jobParameters['id']}") Long id, //(8)
			@Value("#{jobParameters['name']}") String name,
			@Value("#{jobParameters['reqDate']}") Date reqDate
			) {
        //(9)
		MethodInvokingTaskletAdapter tasklet = new MethodInvokingTaskletAdapter();
		tasklet.setTargetObject(service);
		tasklet.setTargetMethod("execute");
		tasklet.setArguments(new Object[] {id, name, reqDate});

		return tasklet;
	}
}

Appel par lots

@Service
public class MyServletService {

	@Autowired
	private JobLauncher jobLauncher1;
	@Autowired
	private Job job;

	public void request(Long id, String name) throws JobExecutionException {
		// (10)
		JobParameters params = new JobParametersBuilder()
								.addLong("id", id)
								.addString("name", name)
								.addDate("reqDate", Calendar.getInstance().getTime())
								.toJobParameters();

		jobLauncher1.run(job, params);
	}
}

Paramètres de démarrage

Ajoutez des paramètres à application.yml.

application.yml

spring:
  datasource: # (11)
    url: jdbc:postgresql://localhost:5432/kurukuruz1
    username: u-s-e-r
    password: p-a-s-s
    driver-class-name: org.postgresql.Driver
  batch:
    initialize-schema: always # (12)
    job:
      enabled: false # (13)

Site de référence

Réintroduction de Spring Batch - J'ai essayé d'organiser comment l'utiliser moi-même - Qiita BLOG.IK.AM - Paramètres ThreadPoolTaskExecutor mal compris Exemple de code Spring Batch (Java / Gradle) --Qoosky [Spring Batch] Ne pas exécuter automatiquement la méthode de contrôle du travail lorsque des travaux autres que le travail spécifié sont exécutés automatiquement --Qiita Kojioniruku-Hello World à Spring Boot Batch