Spring批处理-如何执行清除任务

Question

我编写了一个简单的spring批处理tasklet，它调用一个dao方法，该方法反过来执行一些删除操作。但我不确定该怎么称呼这份工作。

public class RemoveSpringBatchHistoryTasklet implements Tasklet {

    @Autowired
    private SpringBatchDao springBatchDao;

    public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext)
            throws Exception {
        contribution.incrementWriteCount(springBatchDao.purge());
        return RepeatStatus.FINISHED;
    }

}

到目前为止，为了执行我的spring批处理作业，我使用了类似于这样的设置的quartz触发器。每个作业都有自己的xml文件，该文件具有读写器。

    <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="jobDetails">
           <list>
              <ref bean="dailyTranCountJobDetail" />
           </list>
        </property>
        <property name="triggers">
           <list>
              <ref bean="dailyTranCountCronTrigger" />
           </list>
        </property>
    </bean>

    <bean id="dailyTranCountCronTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">
        <property name="jobDetail" ref="dailyTranCountJobDetail" />
        <property name="cronExpression" value="#{batchProps['cron.dailyTranCounts']}" />
    </bean>

    <bean id="dailyTranCountJobDetail" class="org.springframework.scheduling.quartz.JobDetailBean">
        <property name="jobClass" value="com.myer.reporting.batch.JobLauncherDetails" />
        <property name="group" value="quartz-batch" />
        <property name="jobDataAsMap">
            <map>
                <entry key="jobName" value="job-daily-tran-counts" />
                <entry key="jobLocator" value-ref="jobRegistry" />
                <entry key="jobLauncher" value-ref="jobLauncher" />
            </map>
        </property>
    </bean>

然后这里是一个作业文件本身的示例，包含一个读写器。

<job id="job-daily-tran-counts" xmlns="http://www.springframework.org/schema/batch">
    <step id="job-daily-tran-counts-step1">
        <tasklet transaction-manager="custDbTransactionManager">
            <chunk 
                reader="dailyTranCountJdbcCursorItemReader" 
                writer="dailyTranCountItemWriter" 
                commit-interval="1000" />
        </tasklet>
    </step>
</job>

<bean id="dailyTranCountJdbcCursorItemReader"
    class="com.myer.reporting.dao.itemreader.DailyTranCountJdbcCursorItemReader"
    scope="step"
    parent="abstractEposJdbcDao">
    <property name="rowMapper">
        <bean class="com.myer.reporting.dao.mapper.DailyTranCountMapper" />
    </property>
</bean>

<bean id="dailyTranCountItemWriter" 
    class="com.myer.reporting.dao.itemwriter.DailyTranCountItemWriter" 
    parent="abstractCustDbJdbcDao"/>

显然，这份新工作没有读者或作家。那么，我执行新任务的最佳/正确方式是什么？

谢谢

Answer 1

我更喜欢java配置而不是xml。您可以使用以下代码配置您的tasklet：

@Configuration
@EnableBatchProcessing
public class BatchCleanUpJobsConfiguration {

  @Bean
  public Job batchCleanUpJob(final JobBuilderFactory jobBuilderFactory,
                             final StepBuilderFactory stepBuilderFactory,
                             final RemoveSpringBatchHistoryTasklet removeSpringBatchHistoryTasklet) {
    return jobBuilderFactory.get("batchCleanUpJob")
        .start(stepBuilderFactory.get("batchCleanUpStep")
                   .tasklet(removeSpringBatchHistoryTasklet)
                   .build())
        .build();
  }

  @Bean
  public RemoveSpringBatchHistoryTasklet batchCleanUpTasklet(final JdbcTemplate jdbcTemplate) {
    final var tasklet = new RemoveSpringBatchHistoryTasklet();
    tasklet.setJdbcTemplate(jdbcTemplate);
    return tasklet;
  }
}

要计划新作业，请使用以下代码：

@Component
@RequiredArgsConstructor
public class BatchCleanUpJobsScheduler {

  private final Job batchCleanUpJob;
  private final JobLauncher launcher;

  @Scheduled(cron = "0 0 0 * * MON-FRI")
  public void launchBatchCleanupJob()
      throws JobParametersInvalidException, JobExecutionAlreadyRunningException,
          JobRestartException, JobInstanceAlreadyCompleteException {
    launcher.run(
        batchCleanUpJob,
        new JobParametersBuilder()
            .addLong("launchTime", System.currentTimeMillis())
            .toJobParameters());
  }
}