若依 3.0

RuoYi

2020-07-19 cee572f237cb293e4a9070ef458356bc6daa2105

 ruoyi-quartz/src/main/java/com/ruoyi/quartz/config/ScheduleConfig.java

ÎļþÃû´Ó ruoyi/src/main/java/com/ruoyi/framework/config/ScheduleConfig.java ÐÞ¸Ä
@@ -1,57 +1,57 @@
package com.ruoyi.framework.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;
import javax.sql.DataSource;
import java.util.Properties;

/**
 * å®šæ—¶ä»»åŠ¡é…ç½®
 * 
 * @author ruoyi
 */
@Configuration
public class ScheduleConfig
{
    @Bean
    public SchedulerFactoryBean schedulerFactoryBean(DataSource dataSource)
    {
        SchedulerFactoryBean factory = new SchedulerFactoryBean();
        factory.setDataSource(dataSource);

        // quartz参数
        Properties prop = new Properties();
        prop.put("org.quartz.scheduler.instanceName", "RuoyiScheduler");
        prop.put("org.quartz.scheduler.instanceId", "AUTO");
        // çº¿ç¨‹æ± é…ç½®
        prop.put("org.quartz.threadPool.class", "org.quartz.simpl.SimpleThreadPool");
        prop.put("org.quartz.threadPool.threadCount", "20");
        prop.put("org.quartz.threadPool.threadPriority", "5");
        // JobStore配置
        prop.put("org.quartz.jobStore.class", "org.quartz.impl.jdbcjobstore.JobStoreTX");
        // é›†ç¾¤é…ç½®
        prop.put("org.quartz.jobStore.isClustered", "true");
        prop.put("org.quartz.jobStore.clusterCheckinInterval", "15000");
        prop.put("org.quartz.jobStore.maxMisfiresToHandleAtATime", "1");
        prop.put("org.quartz.jobStore.txIsolationLevelSerializable", "true");

        // sqlserver å¯ç”¨
        // prop.put("org.quartz.jobStore.selectWithLockSQL", "SELECT * FROM {0}LOCKS UPDLOCK WHERE LOCK_NAME = ?");
        prop.put("org.quartz.jobStore.misfireThreshold", "12000");
        prop.put("org.quartz.jobStore.tablePrefix", "QRTZ_");
        factory.setQuartzProperties(prop);

        factory.setSchedulerName("RuoyiScheduler");
        // å»¶æ—¶å¯åŠ¨
        factory.setStartupDelay(1);
        factory.setApplicationContextSchedulerContextKey("applicationContextKey");
        // å¯é€‰ï¼ŒQuartzScheduler
        // å¯åŠ¨æ—¶æ›´æ–°å·±å­˜åœ¨çš„Job，这样就不用每次修改targetObject后删除qrtz_job_details表对应记录了
        factory.setOverwriteExistingJobs(true);
        // è®¾ç½®è‡ªåŠ¨å¯åŠ¨ï¼Œé»˜è®¤ä¸ºtrue
        factory.setAutoStartup(true);

        return factory;
    }
}
package com.ruoyi.quartz.config;



import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.scheduling.quartz.SchedulerFactoryBean;

import javax.sql.DataSource;

import java.util.Properties;



/**

 * å®šæ—¶ä»»åŠ¡é…ç½®

 * 
 * @author ruoyi

 */

@Configuration

public class ScheduleConfig

{

    @Bean

    public SchedulerFactoryBean schedulerFactoryBean(DataSource dataSource)

    {

        SchedulerFactoryBean factory = new SchedulerFactoryBean();

        factory.setDataSource(dataSource);



        // quartz参数

        Properties prop = new Properties();

        prop.put("org.quartz.scheduler.instanceName", "RuoyiScheduler");

        prop.put("org.quartz.scheduler.instanceId", "AUTO");

        // çº¿ç¨‹æ± é…ç½®

        prop.put("org.quartz.threadPool.class", "org.quartz.simpl.SimpleThreadPool");

        prop.put("org.quartz.threadPool.threadCount", "20");

        prop.put("org.quartz.threadPool.threadPriority", "5");

        // JobStore配置

        prop.put("org.quartz.jobStore.class", "org.quartz.impl.jdbcjobstore.JobStoreTX");

        // é›†ç¾¤é…ç½®

        prop.put("org.quartz.jobStore.isClustered", "true");

        prop.put("org.quartz.jobStore.clusterCheckinInterval", "15000");

        prop.put("org.quartz.jobStore.maxMisfiresToHandleAtATime", "1");

        prop.put("org.quartz.jobStore.txIsolationLevelSerializable", "true");



        // sqlserver å¯ç”¨

        // prop.put("org.quartz.jobStore.selectWithLockSQL", "SELECT * FROM {0}LOCKS UPDLOCK WHERE LOCK_NAME = ?");

        prop.put("org.quartz.jobStore.misfireThreshold", "12000");

        prop.put("org.quartz.jobStore.tablePrefix", "QRTZ_");

        factory.setQuartzProperties(prop);



        factory.setSchedulerName("RuoyiScheduler");

        // å»¶æ—¶å¯åŠ¨

        factory.setStartupDelay(1);

        factory.setApplicationContextSchedulerContextKey("applicationContextKey");

        // å¯é€‰ï¼ŒQuartzScheduler

        // å¯åŠ¨æ—¶æ›´æ–°å·±å­˜åœ¨çš„Job，这样就不用每次修改targetObject后删除qrtz_job_details表对应记录了

        factory.setOverwriteExistingJobs(true);

        // è®¾ç½®è‡ªåŠ¨å¯åŠ¨ï¼Œé»˜è®¤ä¸ºtrue

        factory.setAutoStartup(true);



        return factory;

    }

}