2

我已经关注了链接：Pass JobParameters and ExecutionContext to @Bean Tasklet? ，但在将jobParameters值传递给tasklet.

我开发了如下代码：

作业配置.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

启动AJobApplication.java

@SpringBootApplication
@EnableBatchProcessing
public class StartingAJobApplication {

    public static void main(String[] args) {
        SpringApplication.run(StartingAJobApplication.class, args);
    }
}

卷曲：

curl --data 'name=foo' localhost:8080

4

2 回答 2

1

这很正常，因为您自己将 tasklet 传递给作业并且它具有空参数。

为了使用@StepScop 功能，您需要使用创建的 bean spring

    @Bean
    public Job job(Tasklet tasklet) {
        return jobBuilderFactory.get("job")
                .start(stepBuilderFactory.get("step1")
                        .tasklet(tasklet)
                        .build())
                .build();
    }
于 2018-12-13T18:45:58.830 回答
0

当你实现“execute”方法时，你有 SetpContribution 和 ChunkContext 作为参数。您必须使用 ChunkContext 来获取 jobParameter。

  @Override
  public RepeatStatus execute(StepContribution stepContribution, ChunkContext chunkContext) throws Exception {

    JobParameters jobParameters = chunkContext.getStepContext().getStepExecution().getJobParameters();

      ...
}
于 2020-02-17T10:31:47.777 回答