您好，如何將不同類中的步驟分開。 @Configurationpublic class JobBatch { @Beanpublic Job jobCC5(JobBuilderFactory jobBuilders, StepBuilderFactory stepBuilders) throws IOException { return jobBuilders.get("jobCC5").start(chStep1(stepBuilders)).build(); } } @Configurationpublic class Step1{@Beanpublic Step Step1(StepBuilderFactory stepBuilders) throws IOException {return stepBuilders.get("step1").<CSCiviqueDTO, String>chunk(100) .reader(readerStep1VerifLenghtNir(null)).processor(processorStep1()) .writer(writerStep1(null)).faultTolerant().skipLimit(9).skip(Exception.class).build();}
1 回答
嚕嚕噠
TA貢獻1784條經驗 獲得超7個贊
下面是一個示例。創建一個類，在其中定義步驟：
import org.springframework.batch.core.Step;
import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
import org.springframework.batch.repeat.RepeatStatus;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class StepConfig {
@Autowired
private StepBuilderFactory steps;
@Bean
public Step step() {
return steps.get("step")
.tasklet((contribution, chunkContext) -> {
System.out.println("hello world");
return RepeatStatus.FINISHED;
})
.build();
}
}
然后在作業配置中導入該類：
import org.springframework.batch.core.Job;
import org.springframework.batch.core.Step;
import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Import;
@EnableBatchProcessing
@Configuration
@Import(StepConfig.class)
public class JobConfig {
@Autowired
private JobBuilderFactory jobs;
@Bean
public Job job(Step step) {
return jobs.get("job")
.start(step)
.build();
}
}
希望這有幫助。
添加回答
舉報
0/150
提交
取消