Spring Batch Job无法执行求助：JSON读入数据库示例故障排查

问题描述 #

我是Spring Batch新手，正在实现一个简单批处理示例：从Students.json文件读取数据并写入数据库。Spring应用可正常启动，但对应的Job无法执行，相关代码片段如下：

代码片段 #

JsonItemReader定义

public ItemReader<Student> jsonItemReader() {
    return new JsonItemReaderBuilder<Student>()
            .jsonObjectReader(new JacksonJsonObjectReader<>(Student.class))
            .resource(new ClassPathResource("Students.json"))
            .name("studentJsonItemReader")
            .saveState(true)
            .build();
}

Step定义

public Step sampleStep(JobRepository jobRepository, PlatformTransactionManager transactionManager) {
    return new StepBuilder("studentProcessor", jobRepository)
            .<Student, Student>chunk(10, transactionManager)
            .reader(jsonItemReader())
            .writer(itemWriter())
            .processor(studentProcessor)
            .build();
}

Job定义

@Bean
public Job sampleJob(JobRepository jobRepository, Step sampleJob) {
    return new JobBuilder("sampleJob", jobRepository)
            .start(sampleJob)
            .build();
}

ItemWriter定义

@Bean
public ItemWriter<Student> itemWriter() {
    return new StudentWriter();
}

StudentWriter实现

public class StudentWriter implements ItemWriter<Student> {

    @Autowired
    private StudentRespository studentRespository;

    @Override
    public void write(Chunk<? extends Student> chunk) throws Exception {
        studentRespository.saveAll(chunk);
    }
}

问题排查点 #

1. Job未触发执行：Spring Batch默认不会自动执行Job，需手动触发或配置自动启动。可通过添加CommandLineRunner调用JobLauncher，或配置spring.batch.job.enabled=true（Spring Boot 2.x+支持）解决。
2. 依赖注入命名冲突：Job定义的参数Step sampleJob与Job Bean名sampleJob重名，导致Spring无法正确注入Step实例，需将参数名改为Step sampleStep。
3. StudentWriter未被Spring管理：itemWriter()直接new出StudentWriter实例，该实例不在Spring容器中，@Autowired的StudentRepository会注入失败，需将StudentWriter标注为@Component。
4. 资源文件校验：确认Students.json在src/main/resources根目录，且文件名大小写与代码一致（Linux/macOS环境大小写敏感）。

优化建议 #

1. 构造注入替代字段注入：修改StudentWriter为构造注入，提升可测试性：

@Component
public class StudentWriter implements ItemWriter<Student> {

    private final StudentRespository studentRespository;

    public StudentWriter(StudentRespository studentRespository) {
        this.studentRespository = studentRespository;
    }

    @Override
    public void write(Chunk<? extends Student> chunk) throws Exception {
        studentRespository.saveAll(chunk);
    }
}

2. 统一Bean命名：StepBuilder名称与Bean方法名保持一致，避免混淆：

public Step sampleStep(JobRepository jobRepository, PlatformTransactionManager transactionManager) {
    return new StepBuilder("sampleStep", jobRepository)
            .<Student, Student>chunk(10, transactionManager)
            .reader(jsonItemReader())
            .writer(itemWriter())
            .processor(studentProcessor)
            .build();
}

3. 添加Job触发逻辑：新增CommandLineRunner自动触发Job：

@Bean
public CommandLineRunner jobTrigger(JobLauncher jobLauncher, Job sampleJob) {
    return args -> {
        JobParameters jobParams = new JobParametersBuilder()
                .addString("runId", String.valueOf(System.currentTimeMillis()))
                .toJobParameters();
        jobLauncher.run(sampleJob, jobParams);
    };
}

4. 添加日志排查：在StudentWriter中添加日志，确认数据处理状态：

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class StudentWriter implements ItemWriter<Student> {
    private static final Logger logger = LoggerFactory.getLogger(StudentWriter.class);

    // ...构造注入

    @Override
    public void write(Chunk<? extends Student> chunk) throws Exception {
        logger.info("准备写入{}条学生数据", chunk.size());
        studentRespository.saveAll(chunk);
    }
}

内容的提问来源于stack exchange，提问作者Mohasin Kazi