Quartz作业未参与Spring托管事务（Quartz Spring批量启动）

Question

我有几个spring批处理作业，如果在spring批处理中触发作业执行，这些作业可以正常工作。这些作业将使用JpaItemWriter对数据库进行读写，其中需要事务。

我的问题是，我有一个quartz调度器，它被配置为定期运行这些作业，我得到了“javax.persistence.TransactionRequiredException:无事务正在进行”错误。我知道目前quartz正在实例化作业bean，而不是spring本身，这使得bean不知道spring管理的正在进行的事务，如果我错了，请纠正我。

然而，我尝试了很多方法，但都不管用。以下是我目前的配置：

石英属性

org.quartz.scheduler.instanceName=sample_instance
org.quartz.scheduler.instanceId=AUTO
org.quartz.threadPool.threadCount=5

org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreCMT
org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.MSSQLDelegate
org.quartz.jobStore.useProperties=true
org.quartz.jobStore.misfireThreshold=60000
org.quartz.jobStore.tablePrefix=QRTZ_

org.quartz.jobStore.isClustered=true
org.quartz.jobStore.clusterCheckinInterval=20000

SchedulerConfig。JAVA

@EnableScheduling
@Configuration
public class SchedulerConfig {

@Inject
private DataSource dataSource;

@Inject
private JobsListenerService jobsListenerService;

@Bean
public JobFactory jobFactory(ApplicationContext applicationContext) {
    AutowiringSpringBeanJobFactory jobFactory = new AutowiringSpringBeanJobFactory();
    jobFactory.setApplicationContext(applicationContext);
    return jobFactory;
}


@Bean
public SchedulerFactoryBean schedulerFactoryBean(JobFactory jobFactory)
        throws IOException {
    SchedulerFactoryBean factory = new SchedulerFactoryBean();
    factory.setJobFactory(jobFactory);
    factory.setDataSource(dataSource);
    factory.setQuartzProperties(quartzProperties());
    factory.setGlobalJobListeners(jobsListenerService);
    return factory;
}

@Bean
public Properties quartzProperties() throws IOException {
    PropertiesFactoryBean propertiesFactoryBean = new PropertiesFactoryBean();
    propertiesFactoryBean.setLocation(new ClassPathResource("/quartz.properties"));
    propertiesFactoryBean.afterPropertiesSet();
    return propertiesFactoryBean.getObject();
}
}

工作：

@Component
@DisallowConcurrentExecution
public class TestJob implements Job {

    private static final String PARAMETERS = "param1=abc";

    @Inject
    private JobRegistry jobRegistry;

    @Inject
    private JobLauncher jobLauncher;

    @Inject
    private JobRepository jobRepository;

    @Inject
    private JobExplorer jobExplorer;

    private JobParametersConverter jobParametersConverter = new DefaultJobParametersConverter();

    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        try {
            org.springframework.batch.core.Job job = jobRegistry.getJob("Job1");
            JobParameters jobParameters = JobParametersUtil.createJobParametersWithIncrementerIfAvailable(PARAMETERS, job);
            jobLauncher.run(job, jobParameters).getId();
        } catch (NoSuchJobException | JobParametersNotFoundException | JobParametersInvalidException | JobExecutionAlreadyRunningException | JobRestartException | JobInstanceAlreadyCompleteException e) {
            e.printStackTrace();
        }
    }
}

我已经将quartz配置为使用JobStoreCMT。我必须显式声明TransactionManager并将其传递到SchedulerFactoryBean吗？非常感谢您的帮助。

Answer 1

如果你遇到和我类似或相同的问题，为了节省世界各地其他人的时间，以下是对我有效的方法。

我明确地为SchedulerFactoryBean提供了一个事务管理器。

    @Bean
    public PlatformTransactionManager transactionManager(EntityManagerFactory emf) {
        JpaTransactionManager transactionManager = new JpaTransactionManager();
        transactionManager.setEntityManagerFactory(emf);
        return transactionManager;
    }

    @Bean
    public SchedulerFactoryBean schedulerFactoryBean(JobFactory jobFactory, PlatformTransactionManager transactionManager)
            throws IOException {
        SchedulerFactoryBean factory = new SchedulerFactoryBean();
        factory.setJobFactory(jobFactory);
        factory.setDataSource(dataSource);
        factory.setTransactionManager(transactionManager);
        factory.setQuartzProperties(quartzProperties());
        factory.setGlobalJobListeners(jobsListenerService);
        return factory;
    }