生产环境下Spring Batch Job运行方式及代码修正咨询

一、生产环境Spring Batch Job的正确运行方式 #

1. 用@Configuration定义批处理组件：官方推荐通过@Configuration类结合@Bean注解定义Job、Step、ItemReader/Processor/Writer等组件，Spring Batch会自动管理这些组件的生命周期、依赖注入，并与JobRepository、JobLauncher等核心组件集成，确保参数传递、作业重启等功能正常工作。
2. 复用容器中的Job实例：Job是单例Bean，无需每次调度都新建，直接注入容器中初始化好的Job实例即可，这样@StepScope注解才能生效，JobParameter才能正确注入到Step级别的组件中。
3. 规范JobParameters传递：通过JobParametersBuilder构建唯一的作业参数，结合JobExplorer的getNextJobParameters方法避免重复作业执行，确保每次调度的作业实例可追踪。

二、现有代码修正 #

1. 修正InactiveMemberJob配置类 #

改回@Configuration，给所有批处理组件添加@Bean注解，修复JobParameter注入的EL表达式：

package com.capston.chatting.config.batch;

import com.capston.chatting.entity.Member;
import com.capston.chatting.enums.MemberStatus;
import com.capston.chatting.repository.MemberRepository;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.batch.core.Job;
import org.springframework.batch.core.Step;
import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
import org.springframework.batch.core.configuration.annotation.StepScope;
import org.springframework.batch.core.launch.support.RunIdIncrementer;
import org.springframework.batch.item.ItemProcessor;
import org.springframework.batch.item.ItemWriter;
import org.springframework.batch.item.support.ListItemReader;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.time.LocalDateTime;
import java.util.List;

@Slf4j
@RequiredArgsConstructor
@Configuration
public class InactiveMemberJobConfig {

    private final MemberRepository memberRepository;
    private final JobBuilderFactory jobBuilderFactory;
    private final StepBuilderFactory stepBuilderFactory;

    @Bean
    public Job inactiveMemberJob() {
        log.info("InactiveMemberJob Bean初始化");
        return jobBuilderFactory.get("inactiveMemberJob")
                .start(inactiveJobStep())
                .preventRestart()
                .incrementer(new RunIdIncrementer())
                .build();
    }

    @Bean
    public Step inactiveJobStep() {
        log.info("InactiveMemberStep Bean初始化");
        return stepBuilderFactory.get("inactiveMemberStep")
                .<Member, Member>chunk(10)
                .reader(inactiveMemberReader(null))
                .processor(inactiveMemberProcessor())
                .writer(inactiveMemberWriter())
                .allowStartIfComplete(true)
                .build();
    }

    @StepScope
    @Bean
    public ListItemReader<Member> inactiveMemberReader(@Value("#{jobParameters['test']}") String test) {
        log.info("InactiveMemberReader执行，JobParameters : {}", test);

        List<Member> oldMembers = memberRepository
                .findByUpdateDateBeforeAndStatusEquals(LocalDateTime.now().minusYears(1), MemberStatus.ACTIVE);

        return new ListItemReader<>(oldMembers);
    }

    @Bean
    public ItemProcessor<Member, Member> inactiveMemberProcessor() {
        return member -> {
            log.info("InactiveMemberProcessor执行");
            return member.setInactive();
        };
    }

    @Bean
    public ItemWriter<Member> inactiveMemberWriter() {
        return members -> {
            log.info("InactiveMemberWriter执行，更新{}个用户状态", members.size());
            memberRepository.saveAll(members);
        };
    }
}

2. 修正ScheduleService调度类 #

直接注入Job实例，避免每次新建Job，确保参数传递生效：

package com.capston.chatting.service.scheduler;

import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.batch.core.Job;
import org.springframework.batch.core.JobParameters;
import org.springframework.batch.core.JobParametersBuilder;
import org.springframework.batch.core.explore.JobExplorer;
import org.springframework.batch.core.launch.JobLauncher;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

import java.time.LocalDateTime;

@Service
@RequiredArgsConstructor
@Slf4j
public class ScheduleService {

    private final Job inactiveMemberJob;
    private final JobLauncher jobLauncher;
    private final JobExplorer jobExplorer;

    @Scheduled(cron = "0/5 * * * * *")
    public void runInactiveMemberScheduler() {
        try {
            JobParameters jobParameters = new JobParametersBuilder(jobExplorer)
                    .getNextJobParameters(inactiveMemberJob)
                    .addString("requestDate", LocalDateTime.now().toString().substring(0, 16))
                    .addString("test", "Test")
                    .toJobParameters();

            jobLauncher.run(inactiveMemberJob, jobParameters);
            log.info("休眠账户处理作业已启动，参数：{}", jobParameters);
        } catch(Exception e) {
            log.error("作业启动失败", e);
        }
    }
}

三、关键修正点说明 #

• @Configuration与@Bean：恢复官方推荐的配置方式，让Spring Batch正确管理组件生命周期，@StepScope注解依赖容器管理才能实现JobParameter的延迟注入。
• Job参数注入：修正EL表达式为#{jobParameters['test']}（注意驼峰JobParameters），@StepScope确保Reader在作业执行时才初始化，此时JobParameters已传递到位。
• 复用Job实例：直接注入容器中的Job Bean，避免每次调用新建实例，确保作业元数据正确写入JobRepository，同时保证参数传递有效。

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