0

我正在使用 SimpleTrigger 安排一个应该无限期运行的作业（重复计数-1）。

我正在使用 JDBC 存储将作业状态持久保存在数据库中。

但是触发器会触发一些时间间隔（在我的情况下总是 8）并进入 BLOCKED 状态。具体来说，QRTZ_TRIGGERS 表中 TRIGGERS_STATE 的值将被更改为 BLOCKED。注意我的 Quartx 表的前缀是 QRTZ_ 下面是我的 Job Trigger 信息。

重复计数：-1，重复间隔：6 秒，启动延迟：10 秒

MY石英配置：

#===============================================================
#Configure ThreadPool
#===============================================================
org.quartz.threadPool.class=org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount = 10
org.quartz.threadPool.threadPriority = 5
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true
#===============================================================
#Configure JobStore
#===============================================================
org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.misfireThreshold = 60000
org.quartz.jobStore.maxMisfiresToHandleAtATime=20
# Flag to turn off to ignore all misfires
scheduler.ignoreMisfire=no

# Configuring JDBCJobStore with the Table Prefix
org.quartz.jobStore.tablePrefix = QRTZ_

# Using DriverDelegate
org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.oracle.OracleDelegate
org.quartz.jobStore.useProperties = false

调度程序类：

public static void scheduleJob(Class<? extends Job> job,JobDataMap dataMap) 
{

    Scheduler scheduler = schedulerFactoryBean.getScheduler();
    try
    {
        JobDetail jobDetail = newJob(job)
                .withIdentity(job.getSimpleName()+"_"+DateUtil.getSystemDate(), job.getSimpleName() + "_group")
                .storeDurably()
                .usingJobData(dataMap)
                .requestRecovery()
                .build();

        SimpleTrigger trigger = (SimpleTrigger) newTrigger()
                .withIdentity(job.getSimpleName() + "_trigger_"+DateUtil.getSystemDateWithMs(), job.getSimpleName() + "_trigger_group")
                .startNow()                 
                .withSchedule(simpleSchedule().repeatSecondlyForever(10).withMisfireHandlingInstructionFireNow())
                .build();

        scheduler.scheduleJob(jobDetail, trigger);

        //logger.debug(scheduler.getMetaData().toString());
        scheduler.start();
    }
    catch (SchedulerException e)
    {
        e.printStackTrace();
        throw new SchedulerException("", e);
    }
}

工作类别：

@PersistJobDataAfterExecution
public class MyJob  Implements Job
{
    private SessionFactory sessionFactory;

    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException
    {
        getBeansFromContext(context);
        Session session = sessionFactory.openSession(); // Hibernate Session Factory
        // to do some DB opetations
    }

    private void getBeansFromContext(JobExecutionContext context) throws SchedulerException
    {
        ApplicationContext applicationContext = (ApplicationContext)context.getScheduler().getContext().get("applicationContext");
        this.sessionFactory=applicationContext.getBean(SessionFactory.class);
    }
}

Quartz 调度器工厂的 Spring bean 配置。

<beans:bean id="schedulerFactoryBean"
class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<beans:property name="jobFactory">
    <beans:bean class="org.springframework.scheduling.quartz.SpringBeanJobFactory"></beans:bean>
</beans:property>
<beans:property name="dataSource" ref="dataSource" />
<beans:property name="transactionManager" ref="txManager" />
<beans:property name="configLocation"
    value="resources/scheduler/Scheduler.properties" />
<beans:property name="applicationContextSchedulerContextKey"
    value="applicationContext" />
<beans:property name="autoStartup" value="true" />
</beans:bean>

<beans:bean id="taskExecutor"
class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor"
p:corePoolSize="5" p:maxPoolSize="10" p:queueCapacity="100"
p:waitForTasksToCompleteOnShutdown="true" />

非常感谢任何帮助。提前致谢

4

2 回答 2

2

我终于明白了这个问题并能够解决它。

正如@zerologiko 评论的那样，问题在于交易。我正在将 Spring 托管事务与休眠一起使用。一旦我声明了我的事务策略，Spring 就会处理事务的开始/结束。

在我的情况下出现问题的原因：Spring bean 生命周期在调度程序作业中无效。为了详细说明这一点，如主帖中所述，我什至必须使用我的作业类中的 applicationContext 访问

jobContext.getScheduler().getContext().get("applicationContext");

工作完成后，我正在尝试将具有某些状态的数据库更新回我们的事务数据库之一。

我最初错过了意识到即使事务也由 Spring 控制。当从作业类触发这些数据库更新时，在我的业务方法上声明的事务无效。

根据我的理解，触发器将被获取，因为完成工作的线程无法回到池中。

为了解决这个问题，我手动打开/关闭了我的作业类中的事务，而不依赖于 Spring CMT，并且它没有问题地工作。

希望这对面临同样问题的人有所帮助。

于 2013-10-02T15:37:04.093 回答
0

我遇到了与 CRON 触发器类似的问题，根本原因也是由于 Spring 托管事务。

但是，我为解决该问题所做的工作与您的有所不同。

我在代码级别保留了@Transactional 注释，而是为 Quartz 配置了一个专用的数据源，以用于其自己的数据库操作，而无需 Spring 干预。

 <!-- Datasource used by Quartz -->
<bean id="quartzDataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
    <property name="driverClassName" value="${db.driver}"/>
    <property name="url" value="${db.url}"/>
    <property name="username" value="${db.user}"/>
    <property name="password" ref="dbPassword"/>
    <property name="maxActive" value="${db.conn.pool.maxActive:30}"/>
    <property name="maxIdle" value="${db.conn.pool.maxIdle:15}"/>
    <property name="minIdle" value="${db.conn.pool.minIdle:0}"/>
</bean>
<!-- Datasource used by Quartz --> 


 <!-- Assign an dedicated dataSource to quartz scheduler-->
 <bean id="cronJobScheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
    <property name="configLocation" value="classpath:META-INF/quartz/quartz.properties"/>
    <property name="jobFactory" ref="springBeanJobFactory"/>
    <property name="dataSource" ref="quartzDataSource"/>
 </bean>
于 2016-02-24T07:21:30.713 回答