Spring Batch不同参数编程触发同一作业报错及示例咨询

抛出java.lang.IllegalStateException: Existing transaction detected in JobRepository的核心原因是：
Spring Batch的JobRepository本身负责管理作业元数据的读写事务，不允许在客户端已经存在活跃事务的上下文里被调用。你当前的触发逻辑大概率满足以下任意一种情况：

• runJobs方法本身加了@Transactional注解
• 调用runJobs的上层方法/类开启了事务，事务上下文传播到了作业触发逻辑里
• 循环触发作业时，第一次作业执行的事务没有正确提交，线程上下文残留了未完成的事务
  Spring Batch官方明确要求：调用JobLauncher的客户端代码不要加额外的事务注解，框架会自行管理作业执行、元数据写入的全链路事务。

• 移除runJobs方法以及其上层调用链路中所有作用于作业触发逻辑的@Transactional注解，保证调用jobLauncher.run()时没有外层活跃事务。
• 如果构造作业参数的逻辑需要事务支持（比如查库生成参数），把参数构造逻辑和作业触发逻辑拆成独立方法/类，参数构造的事务边界不要覆盖到作业执行逻辑。
• 给作业触发方法加上@Transactional(propagation = Propagation.NEVER)校验，一旦方法被事务上下文调用就提前抛出异常，避免隐式事务导致的偶发报错。
• 不要在同一个事务边界内循环触发多个作业实例，每个作业的执行应该持有独立的事务上下文。

同步顺序执行（适合作业数少、单作业执行快的场景） #

import org.springframework.batch.core.Job
import org.springframework.batch.core.JobExecution
import org.springframework.batch.core.JobParameters
import org.springframework.batch.core.launch.JobLauncher
import org.springframework.stereotype.Service
import org.springframework.transaction.annotation.Propagation
import org.springframework.transaction.annotation.Transactional

@Service
class BatchJobTriggerService(
    private val jobLauncher: JobLauncher,
    private val targetBatchJob: Job
) {

    // 禁止给这个方法加@Transactional注解
    @Transactional(propagation = Propagation.NEVER)
    fun runJobs(jobParams: List<JobParameters>): List<JobExecution> {
        val executionList = mutableListOf<JobExecution>()
        jobParams.forEach { param ->
            // 每个作业独立执行，框架自行管理事务
            val execution = jobLauncher.run(targetBatchJob, param)
            executionList.add(execution)
        }
        return executionList
    }

    // 参数构造逻辑单独开事务，事务仅在方法内部生效
    @Transactional(propagation = Propagation.REQUIRED)
    fun generateJobParams(): List<JobParameters> {
        // 此处编写查库、组装作业参数的逻辑
        return emptyList()
    }
}

异步并行执行（适合作业数多、单作业执行耗时长的场景） #

首先配置异步执行的JobLauncher：

import org.springframework.batch.core.launch.JobLauncher
import org.springframework.batch.core.launch.support.TaskExecutorJobLauncher
import org.springframework.batch.core.repository.JobRepository
import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor

@Configuration
class BatchAsyncConfig {

    @Bean("asyncJobLauncher")
    fun asyncJobLauncher(jobRepository: JobRepository): JobLauncher {
        val launcher = TaskExecutorJobLauncher()
        launcher.setJobRepository(jobRepository)
        // 配置线程池参数，根据实际服务器资源、作业并发要求调整
        val threadPool = ThreadPoolTaskExecutor().apply {
            corePoolSize = 4
            maxPoolSize = 8
            setThreadNamePrefix("batch-worker-")
            initialize()
        }
        launcher.setTaskExecutor(threadPool)
        launcher.afterPropertiesSet()
        return launcher
    }
}

异步触发逻辑实现：

import org.springframework.batch.core.Job
import org.springframework.batch.core.JobExecution
import org.springframework.batch.core.JobParameters
import org.springframework.batch.core.launch.JobLauncher
import org.springframework.beans.factory.annotation.Qualifier
import org.springframework.stereotype.Service
import org.springframework.transaction.annotation.Propagation
import org.springframework.transaction.annotation.Transactional
import java.util.concurrent.Future

@Service
class AsyncBatchJobTriggerService(
    @Qualifier("asyncJobLauncher") private val asyncJobLauncher: JobLauncher,
    private val targetBatchJob: Job
) {
    @Transactional(propagation = Propagation.NEVER)
    fun runJobsParallel(jobParams: List<JobParameters>): List<Future<JobExecution>> {
        return jobParams.map { param ->
            asyncJobLauncher.run(targetBatchJob, param)
        }
    }
}

注意：传入的JobParameters需要能唯一标识一个作业实例，如果多次调用传入完全相同的参数，Spring Batch会判定为重复执行已存在的作业实例抛出异常。如果需要同参数重复跑作业，可以在参数中追加时间戳或随机UUID作为唯一识别字段。

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