如何將@Configuration和@EnableScheduling與Spring批處理一起使用

Question

由於「只有void-returning方法可能註解爲@Scheduled」，因此當我使用@Bean配置而不是xml配置時，如何使用Spring Batch和Spring Scheduler Task？您可以在下面找到我的完整配置文件。當我從main()觸發，但只有一次，它運行完美。我想添加@Scheduled(fixedrate=9999)以便以特定頻率喚起相同的工作。據我所知，爲了做到這一點，我期望在step1方法的基礎上增加@Scheduled，但是我不能這樣做，因爲它與void的返回值不同。

@Configuration 
@EnableBatchProcessing 
@EnableScheduling 
public class BatchConfiguration { 
     private static final Logger log = LoggerFactory 
        .getLogger(BatchConfiguration.class); 

     @Bean 
     @StepScope 
     public FlatFileItemReader<Person> reader() { 
       log.info(new Date().toString()); 
       FlatFileItemReader<Person> reader = new FlatFileItemReader<Person>(); 
       reader.setResource(new ClassPathResource("test_person_json.js")); 
       reader.setLineMapper(new DefaultLineMapper<Person>() { 
        { 
          setLineTokenizer(new DelimitedLineTokenizer() { 
            { 
             setNames(new String[] {"firstName", "lastName" }); 
            } 
          }); 
          setFieldSetMapper(new BeanWrapperFieldSetMapper<Person>() { 
            { 
             setTargetType(Person.class); 
            } 
          }); 
        } 
       }); 
       return reader; 
     } 

     @Bean 
     public ItemProcessor<Person, Person> processor() { 
       return new PersonItemProcessor(); 
     } 

     @Bean 
     public ItemWriter<Person> writer(DataSource dataSource) { 
       JdbcBatchItemWriter<Person> writer = new JdbcBatchItemWriter<Person>(); 
       writer.setItemSqlParameterSourceProvider(new BeanPropertyItemSqlParameterSourceProvider<Person>()); 
       writer.setSql("INSERT INTO people (first_name, last_name) VALUES (:firstName, :lastName)"); 
       writer.setDataSource(dataSource); 
       return writer; 
     } 

     @Bean 
     public Job importUserJob(JobBuilderFactory jobs, Step s1, 
        JobExecutionListener listener) { 
       return jobs.get("importUserJob").incrementer(new RunIdIncrementer()) 
          .listener(listener).flow(s1).end().build(); 
     } 

     @Bean 
     public Step step1(StepBuilderFactory stepBuilderFactory, 
        ItemReader<Person> reader, ItemWriter<Person> writer, 
        ItemProcessor<Person, Person> processor) { 
       return stepBuilderFactory.get("step1").<Person, Person> chunk(10) 
.reader(reader).processor(processor).writer(writer).build(); 
     } 

     @Bean 
     public JdbcTemplate jdbcTemplate(DataSource dataSource) { 
       return new JdbcTemplate(dataSource); 
     } 
} 


//Question updated on Dec 3th 2015 with first suggestion 
import org.springframework.batch.core.Job; 
import org.springframework.batch.core.JobParameters; 
import org.springframework.batch.core.launch.JobLauncher; 
import org.springframework.beans.factory.annotation.Autowired; 
import org.springframework.beans.factory.annotation.Qualifier; 
import org.springframework.scheduling.annotation.Scheduled; 
import org.springframework.stereotype.Component; 

@Component 
public class PersonScheduler { 
    private Job myImportJob; 
    private JobLauncher jobLauncher; 

    @Autowired 
    public PersonScheduler(JobLauncher jobLauncher, @Qualifier("myImportJob") Job myImportJob){ 
     this.myImportJob = myImportJob; 
     this.jobLauncher = jobLauncher; 
    } 

    @Scheduled(fixedRate=9999) 
    public void runJob{ 
     jobLauncher.run(myImportJob, new JobParameters()); 
    } 
} 

Answer 1

只需創建單獨的組件，你自動裝配你的工作，並安排它：第三次評論

@Component 
public class MyScheduler{ 
    private Job myImportJob; 
    private JobLauncher jobLauncher; 

    @Autowired 
    public MyScheduler(JobLauncher jobLauncher, @Qualifier("myImportJob") Job myImportJob){ 
     this.myImportJob = myImoportJob; 
     this.jobLauncher = jobLauncher; 
    } 

    @Scheduled(fixedRate=9999) 
    public void runJob(){ 
     jobLauncher.run(myImportJob, new JobParameters()); 
    } 
} 

反應：

只需使用.allowStartIfComplete(true)當您創建的步驟。