我目前正在尝试学习spring Batch，我做了第一个实现，但是Reader、Processor和Writer里面的代码没有执行。有什么建议吗？
JustBatchApplication：
@SpringBootApplication
public class JustBatchApplication {
public static void main(String[] args) {
SpringApplication.run(JustBatchApplication.class, args);
}
}
批量配置：
@Slf4j
@Configuration
@EnableBatchProcessing
@RequiredArgsConstructor
public class BatchConfiguration {
private final EmployeeReader employeeReader;
private final EmployeeProcessor employeeProcessor;
private final EmployeeWriter employeeWriter;
@Bean
public Job employeeJob(JobRepository jobRepository, JobExecutionListener listener, Step step1) {
return new JobBuilder("employeeJob", jobRepository)
.incrementer(new RunIdIncrementer())
.listener(listener)
.flow(step1)
.end()
.build();
}
@Bean
public Step step1(JobRepository jobRepository, PlatformTransactionManager transactionManager) {
return new StepBuilder("step1", jobRepository)
.<Employee, Employee>chunk(10, transactionManager)
.reader(employeeReader)
.processor(employeeProcessor)
.writer(employeeWriter)
.build();
}
}
EmployeeJobListener：
@Slf4j
@Component
@RequiredArgsConstructor
public class EmployeeJobListener implements JobExecutionListener {
private final EmployeeReader employeeReader;
@Override
public void beforeJob(JobExecution jobExecution) {
log.info("############## JOB STARTING ############## ");
}
@Override
public void afterJob(JobExecution jobExecution) {
if (jobExecution.getStatus() == BatchStatus.COMPLETED) {
log.info("############## JOB COMPLETED ############## ");
employeeReader.closeIterator();
}
}
}
员工读者： 在这里，我使用已经实现的 CsvUtils 将 CSV 的每一行映射到 Employee 类，我已经检查过，它工作得很好。所以读取文件没有问题。
@Slf4j
@Component
public class EmployeeReader implements ItemReader<Employee> {
public EmployeeReader() {
CsvUtils<Employee> csvEmployee = new CsvUtils<>(Employee.class);
try {
iterator = csvEmployee.iterator(new FileInfo(DirectoryPath.SRC_MAIN_RESOURCES.value, "employees"));
} catch (IOException e) {
throw new RuntimeException("IOException while reading employees file!", e);
}
}
private MappingIterator<Employee> iterator;
@Override
public Employee read() {
if (iterator.hasNext()) {
Employee employee = iterator.next();
log.info("Reading item: {}", employee);
return employee;
} else {
return null;
}
}
public void closeIterator() {
try {
iterator.close();
} catch (IOException e) {
log.warn("IOException while trying to close the iterator!");
e.printStackTrace();
}
}
}
员工处理者：
@Slf4j
@Component
public class EmployeeProcessor implements ItemProcessor<Employee, Employee> {
@Override
public Employee process(Employee employee) {
log.info("Processing employee: {}", employee);
return employee;
}
}
员工作家：
@Slf4j
@Component
public class EmployeeWriter implements ItemWriter<Employee> {
@Override
public void write(Chunk<? extends Employee> chunk) throws Exception {
for ( Employee employee : chunk ) {
log.info("Writing to console : " + employee );
}
}
}
控制台：
________ _____ ______
___ __ )_____ __ /_________ /_
__ __ | __ `/ __/ ___/_ __ \
_ /_/ // /_/ // /_ / /__ _ / / /
/_____/ \__,_/ \__/ \___/ /_/ /_/
Powered by Spring Boot 3.1.2
2023-09-17T01:09:40.442+02:00 INFO 44199 --- [ main] c.p.b.JustBatchApplication : Starting JustBatchApplication using Java 17.0.5 with PID 44199 (/Users/xyz/Develop/Personal/projects/Training/batch/target/classes started by xyz in /Users/xyz/Develop/Personal/projects/Training/batch)
2023-09-17T01:09:40.443+02:00 INFO 44199 --- [ main] c.p.b.JustBatchApplication : No active profile set, falling back to 1 default profile: "default"
2023-09-17T01:09:40.585+02:00 INFO 44199 --- [ main] o.s.b.c.c.a.BatchRegistrar : Finished Spring Batch infrastructure beans configuration in 2 ms.
2023-09-17T01:09:40.632+02:00 INFO 44199 --- [ main] .s.d.r.c.RepositoryConfigurationDelegate : Multiple Spring Data modules found, entering strict repository configuration mode
2023-09-17T01:09:40.633+02:00 INFO 44199 --- [ main] .s.d.r.c.RepositoryConfigurationDelegate : Bootstrapping Spring Data JDBC repositories in DEFAULT mode.
2023-09-17T01:09:40.640+02:00 INFO 44199 --- [ main] .s.d.r.c.RepositoryConfigurationDelegate : Finished Spring Data repository scanning in 5 ms. Found 0 JDBC repository interfaces.
2023-09-17T01:09:40.647+02:00 INFO 44199 --- [ main] .s.d.r.c.RepositoryConfigurationDelegate : Multiple Spring Data modules found, entering strict repository configuration mode
2023-09-17T01:09:40.648+02:00 INFO 44199 --- [ main] .s.d.r.c.RepositoryConfigurationDelegate : Bootstrapping Spring Data JPA repositories in DEFAULT mode.
2023-09-17T01:09:40.650+02:00 INFO 44199 --- [ main] .s.d.r.c.RepositoryConfigurationDelegate : Finished Spring Data repository scanning in 1 ms. Found 0 JPA repository interfaces.
2023-09-17T01:09:40.772+02:00 INFO 44199 --- [ main] o.h.j.i.u.LogHelper : HHH000204: Processing PersistenceUnitInfo [name: default]
2023-09-17T01:09:40.794+02:00 INFO 44199 --- [ main] o.h.Version : HHH000412: Hibernate ORM core version 6.2.6.Final
2023-09-17T01:09:40.796+02:00 INFO 44199 --- [ main] o.h.c.Environment : HHH000406: Using bytecode reflection optimizer
2023-09-17T01:09:40.851+02:00 INFO 44199 --- [ main] o.h.b.i.BytecodeProviderInitiator : HHH000021: Bytecode provider name : bytebuddy
2023-09-17T01:09:40.907+02:00 INFO 44199 --- [ main] o.s.o.j.p.SpringPersistenceUnitInfo : No LoadTimeWeaver setup: ignoring JPA class transformer
[main] INFO com.zaxxer.hikari.HikariDataSource - HikariPool-1 - Starting...
[main] INFO com.zaxxer.hikari.pool.HikariPool - HikariPool-1 - Added connection org.postgresql.jdbc.PgConnection@204d9edf
[main] INFO com.zaxxer.hikari.HikariDataSource - HikariPool-1 - Start completed.
2023-09-17T01:09:41.124+02:00 INFO 44199 --- [ main] o.h.b.i.BytecodeProviderInitiator : HHH000021: Bytecode provider name : bytebuddy
2023-09-17T01:09:41.361+02:00 INFO 44199 --- [ main] o.h.e.t.j.p.i.JtaPlatformInitiator : HHH000490: Using JtaPlatform implementation: [org.hibernate.engine.transaction.jta.platform.internal.NoJtaPlatform]
2023-09-17T01:09:41.391+02:00 INFO 44199 --- [ main] j.LocalContainerEntityManagerFactoryBean : Initialized JPA EntityManagerFactory for persistence unit 'default'
2023-09-17T01:09:41.436+02:00 INFO 44199 --- [ main] o.s.b.c.r.s.JobRepositoryFactoryBean : No database type set, using meta data indicating: POSTGRES
2023-09-17T01:09:41.453+02:00 INFO 44199 --- [ main] .c.a.BatchObservabilityBeanPostProcessor : No Micrometer observation registry found, defaulting to ObservationRegistry.NOOP
2023-09-17T01:09:41.457+02:00 INFO 44199 --- [ main] .c.a.BatchObservabilityBeanPostProcessor : No Micrometer observation registry found, defaulting to ObservationRegistry.NOOP
2023-09-17T01:09:41.459+02:00 INFO 44199 --- [ main] o.s.b.c.l.s.SimpleJobLauncher : No TaskExecutor has been set, defaulting to synchronous executor.
2023-09-17T01:09:41.552+02:00 INFO 44199 --- [ main] c.p.b.JustBatchApplication : Started JustBatchApplication in 1.286 seconds (process running for 1.637)
2023-09-17T01:09:41.554+02:00 INFO 44199 --- [ionShutdownHook] j.LocalContainerEntityManagerFactoryBean : Closing JPA EntityManagerFactory for persistence unit 'default'
[SpringApplicationShutdownHook] INFO com.zaxxer.hikari.HikariDataSource - HikariPool-1 - Shutdown initiated...
[SpringApplicationShutdownHook] INFO com.zaxxer.hikari.HikariDataSource - HikariPool-1 - Shutdown completed.
我还通过保存员工来检查与 PostgresSQL 的连接。
默认情况下，如果您有一个作业，Spring Boot 将在启动后执行它（请参阅this）。所以猜测您现在正在将属性
spring.batch.job.enabledfalse无论如何，尝试设置
spring.batch.job.enabled=true顺便说一句，与您的问题无关，使用
JobBuilderFactoryStepBuilderFactory@EnableBatchProcessing
public class BatchConfiguration {
private final EmployeeReader employeeReader;
private final EmployeeProcessor employeeProcessor;
private final EmployeeWriter employeeWriter;
@Autowired
private JobBuilderFactory jobBuilder;
@Autowired
private StepBuilderFactory stepBuilder;
@Bean
public Job employeeJob(Step step1) {
return jobBuilder.get("employeeJob").
.incrementer(new RunIdIncrementer())
.listener(listener)
.flow(step1)
.end()
.build();
}
@Bean
public Step step1() {
return stepBuilder.get("step1")
.<Employee, Employee>chunk(10)
.reader(employeeReader)
.processor(employeeProcessor)
.writer(employeeWriter)
.build();
}
}