Spring批量重启

Question

@Bean
    @Qualifier("dataTransferJob")
    public Job dataJob() {

        return jobBuilderFactory.get("data-transfer-job")
                .listener(jobExecutionListener())
                .flow(step()).end().build();
    }

    @Bean
    public Step step() {
        return stepBuilderFactory.get("data-transfer-step")
                .<TestData, TestDataVO>chunk(100)
                .reader(reader())
                .processor(process())
                .writer(writer)
                .taskExecutor(threadPool)
                .transactionManager(transactionManager)
                .listener(stepExecutionListener())
                .listener(chunkListener())
                .throttleLimit(10)
                .build();
    }

    @PersistenceContext
    private EntityManager em;

    @Bean(destroyMethod="")
    public ItemReader<TestData> reader() {
        JpaPagingItemReader<TestData> itemReader = new JpaPagingItemReader<>();
        try {
            String sqlQuery = "SELECT * FROM TEST_DATA";
            JpaNativeQueryProvider<TestData> queryProvider = new JpaNativeQueryProvider<TestData>();
            queryProvider.setSqlQuery(sqlQuery);
            queryProvider.setEntityClass(TestData.class);
            queryProvider.afterPropertiesSet();

            itemReader.setEntityManagerFactory(em.getEntityManagerFactory());

            itemReader.setPageSize(100);
            itemReader.setQueryProvider(queryProvider);
            itemReader.afterPropertiesSet();
            itemReader.setSaveState(true);
        }
        catch (Exception e) {
            System.out.println("BatchConfiguration.reader() ==> error " + e.getMessage());
        }
        return itemReader;    

    }

使用CommandLineRunner处理工作

    @Autowired
    JobLauncher jobLauncher;

    @Autowired
    @Qualifier("dataTransferJob")
    Job dataJob;

    JobParametersBuilder paramsBuilder = new JobParametersBuilder();
    paramsBuilder.addString("date", LocalDateTime.now().toString());

    JobExecution jobExecution=jobLauncher.run(dataJob, paramsBuilder.toJobParameters());

Answer 1

在Spring Batch中，作业实例由（标识）作业参数标识。请查看批处理的域语言部分，以了解作业、JobInstance和JobExecution概念之间的区别，以及如何使用参数来标识作业实例。

我试图在进程中间停止批处理并重新运行。它总是执行一个新的工作。

在您的示例中，由于您在每次运行时都将当前时间添加为作业参数，因此：

JobParametersBuilder paramsBuilder = new JobParametersBuilder();
paramsBuilder.addString("date", LocalDateTime.now().toString());