Spring Batch启动报错：无法找到JobBuilderFactory类型的Bean

错误详情 #

应用启动失败，报错信息：

com.example.persistence.batch.BatchConfiguration构造方法的第0个参数需要类型为'org.springframework.batch.core.configuration.annotation.JobBuilderFactory'的Bean，但未找到。

根本原因 #

JobBuilderFactory和StepBuilderFactory是由@EnableBatchProcessing注解自动向Spring容器注册的Bean，出现找不到的情况，通常是以下两个原因：

• 缺少Spring Batch核心依赖
• 配置类未被Spring上下文扫描到

解决方案 #

1. 确保引入正确的依赖 #

如果使用Maven，在pom.xml中添加Spring Batch Starter和MySQL驱动：

<!-- Spring Batch 核心依赖 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-batch</artifactId>
</dependency>
<!-- MySQL 驱动 -->
<dependency>
    <groupId>com.mysql</groupId>
    <artifactId>mysql-connector-j</artifactId>
    <scope>runtime</scope>
</dependency>

如果使用Gradle，在build.gradle中添加：

implementation 'org.springframework.boot:spring-boot-starter-batch'
runtimeOnly 'com.mysql:mysql-connector-j'

2. 确认配置类被正确扫描 #

确保BatchConfiguration类所在的包在Spring Boot主类的扫描范围内，或者在主类上用@ComponentScan指定扫描路径。比如主类如果在com.example.persistence包下，com.example.persistence.batch会被自动扫描到。

3. 完善MySQL写入逻辑（匹配你的需求） #

你当前的ItemWriter仅打印日志，要实现写入MySQL，替换为JdbcBatchItemWriter：

@Bean
public ItemWriter<CsvModel> writer(DataSource dataSource) {
    return new JdbcBatchItemWriterBuilder<CsvModel>()
            .itemSqlParameterSourceProvider(new BeanPropertyItemSqlParameterSourceProvider<>())
            .sql("INSERT INTO csv_data (block, tag, value) VALUES (:block, :tag, :value)")
            .dataSource(dataSource)
            .build();
}

注意提前在MySQL中创建对应表csv_data，字段与CsvModel属性匹配。

4. 简化构造注入（可选优化） #

Spring 4.3+支持单一构造方法的自动注入，可去掉@Autowired注解：

public BatchConfiguration(JobBuilderFactory jobBuilderFactory, StepBuilderFactory stepBuilderFactory) {
    this.jobBuilderFactory = jobBuilderFactory;
    this.stepBuilderFactory = stepBuilderFactory;
}

完整调整后的BatchConfiguration代码 #

package com.example.persistence.batch;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
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.batch.core.configuration.annotation.StepBuilderFactory;
import org.springframework.batch.core.launch.support.RunIdIncrementer;
import org.springframework.batch.item.ItemProcessor;
import org.springframework.batch.item.ItemReader;
import org.springframework.batch.item.ItemWriter;
import org.springframework.batch.item.database.JdbcBatchItemWriter;
import org.springframework.batch.item.database.builder.JdbcBatchItemWriterBuilder;
import org.springframework.batch.item.file.builder.FlatFileItemReaderBuilder;
import org.springframework.batch.item.file.mapping.BeanWrapperFieldSetMapper;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.ClassPathResource;
import javax.sql.DataSource;

import com.example.persistence.entities.CsvModel;

@Configuration
@EnableBatchProcessing
public class BatchConfiguration {

    private static final Logger logger = LoggerFactory.getLogger(BatchConfiguration.class);

    private final JobBuilderFactory jobBuilderFactory;
    private final StepBuilderFactory stepBuilderFactory;

    public BatchConfiguration(JobBuilderFactory jobBuilderFactory, StepBuilderFactory stepBuilderFactory) {
        this.jobBuilderFactory = jobBuilderFactory;
        this.stepBuilderFactory = stepBuilderFactory;
    }

    @Bean
    public ItemReader<CsvModel> reader() {
        return new FlatFileItemReaderBuilder<CsvModel>()
                .name("csvModelItemReader")
                .resource(new ClassPathResource("SwiftMessage.csv"))
                .delimited()
                .names("block", "tag", "value")
                .linesToSkip(1)
                .fieldSetMapper(new BeanWrapperFieldSetMapper<CsvModel>() {{
                    setTargetType(CsvModel.class);
                }})
                .build();
    }

    @Bean
    public ItemProcessor<CsvModel, CsvModel> processor() {
        return item -> {
            // 可添加数据校验、转换等处理逻辑
            logger.info("Processing item: {}", item);
            return item;
        };
    }

    @Bean
    public ItemWriter<CsvModel> writer(DataSource dataSource) {
        return new JdbcBatchItemWriterBuilder<CsvModel>()
                .itemSqlParameterSourceProvider(new BeanPropertyItemSqlParameterSourceProvider<>())
                .sql("INSERT INTO csv_data (block, tag, value) VALUES (:block, :tag, :value)")
                .dataSource(dataSource)
                .build();
    }

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

    @Bean
    public Job job(Step step) {
        return jobBuilderFactory.get("myJob")
                .incrementer(new RunIdIncrementer())
                .flow(step)
                .end()
                .build();
    }
}

额外注意事项 #

• 在application.properties中配置MySQL连接信息：

spring.datasource.url=jdbc:mysql://localhost:3306/your_database_name
spring.datasource.username=your_username
spring.datasource.password=your_password
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

• Spring Batch默认会创建批处理元数据表（如BATCH_JOB_INSTANCE），用于跟踪任务状态，首次运行建议保留；若不需要可添加spring.batch.jdbc.initialize-schema=never关闭。

内容的提问来源于stack exchange，提问作者Pranay Jadhav