Как я мог предотвратить выполнение задания Spring Batch сразу после того, как контекст был загружен

Question

Я новичок в Spring Batch, теперь у меня есть образец для запуска весеннего пакетного задания из Quartz scheduler. Мое приложение запускается с помощью Spring boot для загрузки весеннего контекста.

Моя проблема заключается в том, что каждый раз, когда мой контекст приложения был загружен, весеннее пакетное задание выполняется немедленно, это неожиданно. После этого задание запускается Quartz как время, установленное в выражении cron.

Я хочу иметь решение для удаления первого запуска задания, которое происходит сразу после загрузки весеннего контекста. Может ли кто-нибудь дать мне способ сделать это?

Ниже мой конфигурационный файл, моя работа называется "importUserJob"

import java.util.HashMap; 
import java.util.Map; 

import javax.sql.DataSource; 
import javax.transaction.TransactionManager; 

import org.quartz.JobDataMap; 
import org.springframework.batch.core.Job; 
import org.springframework.batch.core.JobExecutionListener; 
import org.springframework.batch.core.Step; 
import org.springframework.batch.core.configuration.JobRegistry; 
import org.springframework.batch.core.configuration.annotation.BatchConfigurer; 
import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing; 
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory; 
import org.springframework.batch.core.configuration.annotation.StepBuilderFactory; 
import org.springframework.batch.core.configuration.support.JobRegistryBeanPostProcessor; 
import org.springframework.batch.core.configuration.support.MapJobRegistry; 
import org.springframework.batch.core.explore.JobExplorer; 
import org.springframework.batch.core.explore.support.JobExplorerFactoryBean; 
import org.springframework.batch.core.launch.JobLauncher; 
import org.springframework.batch.core.launch.support.RunIdIncrementer; 
import org.springframework.batch.core.launch.support.SimpleJobLauncher; 
import org.springframework.batch.core.repository.JobRepository; 
import org.springframework.batch.core.repository.support.JobRepositoryFactoryBean; 
import org.springframework.batch.core.repository.support.MapJobRepositoryFactoryBean; 
import org.springframework.batch.core.repository.support.SimpleJobRepository; 
import org.springframework.batch.item.ItemReader; 
import org.springframework.batch.item.NonTransientResourceException; 
import org.springframework.batch.item.ParseException; 
import org.springframework.batch.item.UnexpectedInputException; 
import org.springframework.batch.item.database.BeanPropertyItemSqlParameterSourceProvider; 
import org.springframework.batch.item.database.JdbcBatchItemWriter; 
import org.springframework.batch.item.file.FlatFileItemReader; 
import org.springframework.batch.item.file.mapping.BeanWrapperFieldSetMapper; 
import org.springframework.batch.item.file.mapping.DefaultLineMapper; 
import org.springframework.batch.item.file.transform.DelimitedLineTokenizer; 
import org.springframework.beans.factory.annotation.Autowired; 
import org.springframework.beans.factory.annotation.Qualifier; 
import org.springframework.context.annotation.Bean; 
import org.springframework.context.annotation.Configuration; 
import org.springframework.core.io.ClassPathResource; 
import org.springframework.core.task.SimpleAsyncTaskExecutor; 
import org.springframework.core.task.TaskExecutor; 
import org.springframework.jdbc.core.JdbcTemplate; 
import org.springframework.scheduling.Trigger; 
import org.springframework.scheduling.TriggerContext; 
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; 
import org.springframework.scheduling.quartz.CronTriggerFactoryBean; 
import org.springframework.scheduling.quartz.JobDetailFactoryBean; 
import org.springframework.scheduling.quartz.SchedulerFactoryBean; 
import org.springframework.scheduling.support.CronTrigger; 
import org.springframework.stereotype.Component; 
import org.springframework.transaction.PlatformTransactionManager; 

@Configuration 
@EnableBatchProcessing 
public class BatchConfiguration implements BatchConfigurer{ 

    @Autowired 
    public JobBuilderFactory jobBuilderFactory; 

    @Autowired 
    public StepBuilderFactory stepBuilderFactory; 

    @Autowired 
    public DataSource dataSource; 

    @Autowired 
    @Qualifier("jpaTxnManagerBean") 
    public PlatformTransactionManager transactionManager; 

    @Bean 
    public PersonItemProcessor processor() { 
     return new PersonItemProcessor(); 
    } 

    @Bean(name="importUserJob") 
    public Job importUserJob(JobCompletionNotificationListener listener) { 
     return jobBuilderFactory.get("importUserJob") 
       .incrementer(new RunIdIncrementer()) 
       .listener(listener) 
       .flow(step1()) 
       .end() 
       .build(); 
    } 

    @Bean 
    public Step step1() { 
     return stepBuilderFactory.get("step1"). 
      chunk(10) 
      .reader(reader()) 
       .processor(processor()).transactionManager(transactionManager) 
       .build(); 
    } 

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

    @Bean 
    public ItemReader<Object> reader() { 
     return new ItemReader<Object>() { 
      int i = 0; 
      @Override 
      public Object read() 
        throws Exception, UnexpectedInputException, ParseException, NonTransientResourceException { 

       if(i == 100) return null; 
       if(i%10 == 0) System.out.println("_________________"); 
       i++; 
       System.out.println("Access to reader: "+i); 

       return new String("abc"); // null could not run processor 
      } 
     }; 
    } 

    @Bean 
    public SchedulerFactoryBean schedulerFactoryBean(JobCompletionNotificationListener listener) throws Exception{ 
     SchedulerFactoryBean schedulerFac = new SchedulerFactoryBean(); 
     CronTriggerFactoryBean cronTrigger = new CronTriggerFactoryBean(); 
     cronTrigger.setCronExpression("00 31 23 ? * TUE-SAT *"); 

     cronTrigger.setName("EveryWeekDay"); 
     cronTrigger.setGroup("quatz-group"); 

     JobDetailFactoryBean jobDetail = new JobDetailFactoryBean(); 
     jobDetail.setName("importUserJob"); 
     jobDetail.setJobClass(JobLauncherDetails.class); 
     jobDetail.setDurability(true); 
     jobDetail.setGroup("quatz-group"); 
     Map<String, Object> map = new HashMap<>(); 
     map.put("jobName", "importUserJob"); 
     map.put("jobLocator", getJobRegistry()); 
     map.put("jobLauncher", getJobLauncher()); 
     jobDetail.setJobDataAsMap(map); 
     jobDetail.afterPropertiesSet(); 

     cronTrigger.setJobDetail(jobDetail.getObject()); 
     cronTrigger.afterPropertiesSet(); 

     schedulerFac.setTriggers(cronTrigger.getObject()); 
     schedulerFac.afterPropertiesSet(); 

     return schedulerFac; 
    } 

    @Bean 
    public JobRegistryBeanPostProcessor jobRegistryBeanPostProcessor() throws Exception{ 
     JobRegistryBeanPostProcessor postProcessor = new JobRegistryBeanPostProcessor(); 
     postProcessor.setJobRegistry(getJobRegistry()); 
     postProcessor.afterPropertiesSet(); 
     return postProcessor; 
    } 

    @Bean 
    public JobRegistry getJobRegistry(){ 
     MapJobRegistry jobRegistry = new MapJobRegistry(); 
     return jobRegistry; 
    } 

    @Override 
    public JobExplorer getJobExplorer() throws Exception { 
     JobExplorerFactoryBean jobExplorer = new JobExplorerFactoryBean(); 
     jobExplorer.setDataSource(dataSource); 
     jobExplorer.afterPropertiesSet(); 
     return jobExplorer.getObject(); 
    } 

    @Override 
    public JobLauncher getJobLauncher() throws Exception { 
     SimpleJobLauncher jobLauncher = new SimpleJobLauncher(); 
     jobLauncher.setJobRepository(getJobRepository()); 
     jobLauncher.setTaskExecutor(taskExecutor()); 
     jobLauncher.afterPropertiesSet(); 
     return jobLauncher; 
    } 

    @Override 
    public JobRepository getJobRepository() throws Exception { 
     JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean(); 
     factory.setDataSource(dataSource); 
     factory.setTransactionManager(getTransactionManager()); 
     factory.afterPropertiesSet(); 
     return (JobRepository) factory.getObject(); 
    } 

    @Override 
    public PlatformTransactionManager getTransactionManager() throws Exception { 
     return transactionManager; 
    } 

} 

Answer 1

Установите свойство spring.batch.job.enabled=false в ваших application.properties файл refer the document for more details

spring.batch.job.enabled = верно # Выполнять все задания Spring Batch в контексте при запуске.