在彈簧引導應用程序中調度多個批處理作業

Question

我的彈簧引導批處理應用程序有一個調度程序，它將我的批處理作業編寫在FirstBatchConfiguration類中，以便每小時運行一次。

我有另一個批處理作業，我已經在同一個應用程序的SecondBatchConfiguration類中配置了，我將安排在一週內運行一次，但是我無法弄清楚如何在同一個JobScheduler中安排它，這兩個職位都應該在他們自己的預定時間運行

如果有人能幫助我實現這一目標。

我目前的調度是：

@Component 
public class JobScheduler { 

    @Autowired 
    private JobLauncher jobLauncher; 

    @Autowired 
    private FirstBatchConfiguration firstBatchConfiguration; 

    @Scheduled(cron = "0 0 0/1 * * ?") 
    public void runJob() { 

     Map<String, JobParameter> confMap = new HashMap<>(); 
     confMap.put("time", new JobParameter(System.currentTimeMillis())); 
     JobParameters jobParameters = new JobParameters(confMap); 
     final Logger logger = LoggerFactory.getLogger("applicationlogger"); 

     try { 

      jobLauncher.run(firstBatchConfiguration.firstJob(), jobParameters); 

     } catch (JobExecutionAlreadyRunningException | JobInstanceAlreadyCompleteException 
       | JobParametersInvalidException | org.springframework.batch.core.repository.JobRestartException e) { 

      logger.error(e.getMessage()); 
     } 
    } 

} 

Answer 1

如果程序有運行第二個時間表，然後用附表標註添加一個新的方法，例如@Scheduled(cron = "5 8 * * 6 ?")。如果您需要使用SecondBatchConfiguration類，那麼只需Autowired它。

1. 第一步（自動裝配配置）@Autowired您SecondBatchConfiguration

實施例：

@Autowired 
private SecondBatchConfiguration secondBatchConfiguration; 

創建一個新的方法，並用@Scheduled註釋調度它，並在方法體內啓動第二份工作。

例子：

@Scheduled(cron = "5 8 * * 6 ?") 
public void runSecondJob() { ... } 

你可以有多個計劃很多，你需要的，每個人有自己的時間表。

@Scheduled(cron = "5 8 * * 6 ?") 
public void runSecondJob() { .... } 

@Scheduled(cron = "0 0 0/1 * * ?") 
public void runJob() { .... } 

編輯：異步作業執行

異步工作excecution是春天一批非常強大的功能，有一個很好的文檔和它的例子。

請參見下面的說明，以激活異步工作異常：

第1步：添加作業配置（本項選擇使用內存JobRepository）。要了解更多有關存儲庫的類型去Spring Documentation

創建ResourcelessTransactionManager豆

@Bean 
    public ResourcelessTransactionManager transactionManager() { 
     return new ResourcelessTransactionManager(); 
    } 

創建MapJobRepositoryFactory豆

@Bean 
public MapJobRepositoryFactoryBean mapJobRepositoryFactory(
     ResourcelessTransactionManager txManager) throws Exception { 
    MapJobRepositoryFactoryBean factory = new 
      MapJobRepositoryFactoryBean(txManager); 
    factory.afterPropertiesSet(); 
    return factory; 
} 

創建JobRepository豆

@Bean 
public JobRepository jobRepository(
     MapJobRepositoryFactoryBean factory) throws Exception { 
    return factory.getObject(); 
} 

創建的ThreadPoolExecutor（ThreadPoolExecutor的負責異步執行的，也有更多類型的執行者，你可以在Spring Documentation閱讀更多關於他們）

@Bean 
public ThreadPoolTaskExecutor taskExecutor() { 
    ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor(); 
    taskExecutor.setCorePoolSize(5); 
    taskExecutor.setMaxPoolSize(10); 
    taskExecutor.setQueueCapacity(30); 
    return taskExecutor; 
} 

創建JobLauncher豆

@Bean 
    public JobLauncher jobLauncher(ThreadPoolTaskExecutor taskExecutor, JobRepository jobRepository){ 
     SimpleJobLauncher jobLauncher = new SimpleJobLauncher(); 
     jobLauncher.setTaskExecutor(taskExecutor); 
     jobLauncher.setJobRepository(jobRepository); 
     return jobLauncher; 
    } 

第2步：啓用異步作業執行

轉到您Spring Boot Application Class和下列註釋

@EnableBatchProcessing 
@EnableAsync 
@EnableScheduling 
@SpringBootApplication 
public class MyBatchApp {