Я уже перешел по ссылке: Передать JobParameters и ExecutionContext в @Bean Tasklet? , но проблема по-прежнему возникает при передаче значения jobParameters
в tasklet
.
.разработан код, подобный приведенному ниже:
JobConfiguration.java
@Component
public class JobConfiguration implements ApplicationContextAware{
@Autowired
private JobBuilderFactory jobBuilderFactory;
@Autowired
private StepBuilderFactory stepBuilderFactory;
@Autowired
private JobExplorer jobExplorer;
@Autowired
private JobRepository jobRepository;
@Autowired
private JobRegistry jobRegistry;
private ApplicationContext applicationContext;
@Override
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
this.applicationContext = applicationContext;
}
@Bean
@StepScope
public Tasklet tasklet(@Value("#{jobParameters['name']}") String name) {
System.out.println("NAME VALUE = "+name);
return (contribution, chunkContext) -> {
System.out.println(String.format("The job run for %s", name));
return RepeatStatus.FINISHED;
};
}
@Bean
public Job job() {
return jobBuilderFactory.get("job")
.start(stepBuilderFactory.get("step1")
.tasklet(tasklet(null))
.build())
.build();
}
}
JobLaunchingController.java
@RestController
public class JobLaunchingController {
@Autowired
private JobLauncher jobLauncher;
@Autowired
private Job job;
@PostMapping("/")
@ResponseStatus(value = HttpStatus.ACCEPTED)
public void launch(@RequestParam("name") String name) throws JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException, JobParametersInvalidException {
JobParameters jobParameters = new JobParametersBuilder()
.addString("name", name)
.toJobParameters();
JobExecution jobExecution = this.jobLauncher.run(job, jobParameters);
System.out.println("STATUS = "+jobExecution.getStatus());
}
}
Журналы:
2018-12-13 23:09:35.930 INFO 20004 --- [nio-8080-exec-1] o.a.c.c.C.[Tomcat].[localhost].[/] : Initializing Spring DispatcherServlet 'dispatcherServlet'
2018-12-13 23:09:35.930 INFO 20004 --- [nio-8080-exec-1] o.s.web.servlet.DispatcherServlet : Initializing Servlet 'dispatcherServlet'
2018-12-13 23:09:35.938 INFO 20004 --- [nio-8080-exec-1] o.s.web.servlet.DispatcherServlet : Completed initialization in 8 ms
2018-12-13 23:09:55.046 INFO 20004 --- [nio-8080-exec-1] o.s.b.c.l.support.SimpleJobLauncher : Job: [SimpleJob: [name=job]] launched with the following parameters: [{name=foo}]
2018-12-13 23:09:55.414 INFO 20004 --- [nio-8080-exec-1] o.s.batch.core.job.SimpleStepHandler : Executing step: [step1]
The job run for null
2018-12-13 23:09:55.672 INFO 20004 --- [nio-8080-exec-1] o.s.b.c.l.support.SimpleJobLauncher : Job: [SimpleJob: [name=job]] completed with the following parameters: [{name=foo}] and the following status: [COMPLETED]
STATUS = COMPLETED
StartingAJobApplication.java
@SpringBootApplication
@EnableBatchProcessing
public class StartingAJobApplication {
public static void main(String[] args) {
SpringApplication.run(StartingAJobApplication.class, args);
}
}
CURL:
curl --data 'name = foo' localhost: 8080