Java SchedulerFactoryBean类使用实例

发布时间:2025-12-09 11:55:30 浏览次数:2

实例1: schedulerFactory

import org.springframework.scheduling.quartz.SchedulerFactoryBean; //导入依赖的package包/类@Beanpublic SchedulerFactoryBean schedulerFactory(JobFactory jobFactory) {    SchedulerFactoryBean schedulerFactoryBean = new SchedulerFactoryBean();    schedulerFactoryBean.setApplicationContext(applicationContext);    schedulerFactoryBean.setAutoStartup(schedulerProperties.isAutoStartup());    schedulerFactoryBean.setDataSource(dataSource);    schedulerFactoryBean.setTransactionManager(platformTransactionManager);    schedulerFactoryBean.setOverwriteExistingJobs(schedulerProperties.isOverwriteExistingJobs());    schedulerFactoryBean.setSchedulerFactoryClass(StdSchedulerFactory.class);    schedulerFactoryBean.setBeanName(schedulerProperties.getBeanName());    schedulerFactoryBean.setJobFactory(jobFactory);    schedulerFactoryBean.setWaitForJobsToCompleteOnShutdown(schedulerProperties.isWaitOnShutdown());    schedulerFactoryBean.setQuartzProperties(schedulerProperties.getProperties());    schedulerFactoryBean.setStartupDelay(schedulerProperties.getStartupDelay());    schedulerFactoryBean.setCalendars(calendarMap);    schedulerFactoryBean.setSchedulerListeners(schedulerListeners);    return schedulerFactoryBean;} 

实例2: schedulerFactoryBean

import org.springframework.scheduling.quartz.SchedulerFactoryBean; //导入依赖的package包/类@Bean    public SchedulerFactoryBean schedulerFactoryBean(DataSource dataSource) {        SchedulerFactoryBean factory = new SchedulerFactoryBean();        factory.setDataSource(dataSource);        //quartz参数        Properties prop = new Properties();        prop.put("org.quartz.scheduler.instanceName", "RenrenScheduler");        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.misfireThreshold", "12000");        prop.put("org.quartz.jobStore.tablePrefix", "QRTZ_");        factory.setQuartzProperties(prop);        factory.setSchedulerName("RenrenScheduler");        //延时启动        factory.setStartupDelay(30);        factory.setApplicationContextSchedulerContextKey("applicationContextKey");        //可选,QuartzScheduler 启动时更新己存在的Job,这样就不用每次修改targetObject后删除qrtz_job_details表对应记录了        factory.setOverwriteExistingJobs(true);        //设置自动启动,默认为true        factory.setAutoStartup(true);        return factory;    } 

实例3: schedulerFactoryBean

import org.springframework.scheduling.quartz.SchedulerFactoryBean; //导入依赖的package包/类/** * create scheduler */@Beanpublic SchedulerFactoryBean schedulerFactoryBean() throws IOException {     SchedulerFactoryBean factory = new SchedulerFactoryBean();    factory.setOverwriteExistingJobs(true);    factory.setDataSource(dataSource);    factory.setQuartzProperties(quartzProperties());        //Register listeners to get notification on Trigger misfire etc    factory.setGlobalTriggerListeners(triggerListner);    factory.setGlobalJobListeners(jobsListener);        AutowiringSpringBeanJobFactory jobFactory = new AutowiringSpringBeanJobFactory();    jobFactory.setApplicationContext(applicationContext);    factory.setJobFactory(jobFactory);        return factory;} 
schedulerfactorybean
需要做网站?需要网络推广?欢迎咨询客户经理 13272073477