Quartz总结：动态修改定时器一

曾经终败给现在 2022-07-14 05:42 177阅读 0赞

![复制代码][copycode.gif]

package com.mc.bsframe.job;
    
    import org.quartz.Scheduler;
    import org.quartz.SchedulerException;
    import org.quartz.TriggerKey;
    import org.quartz.impl.triggers.SimpleTriggerImpl;
    import org.springframework.beans.factory.annotation.Autowired;
    
    import com.mc.bsframe.service.TestService;
    import com.mc.bsframe.util.TimeUtils;
    
    public class TestJob {
    
        @Autowired
        private TestService testSevice;
        
        public void doSomething() {
            testSevice.sayHi();
            System.err.println("****:" + TimeUtils.getCurrentTime());
        }
    
        private Scheduler scheduler;
    
        public Scheduler getScheduler() {
            return scheduler;
        }
    
        public void setScheduler(Scheduler scheduler) {
            this.scheduler = scheduler;
        }
    
        public void restJob(long time) {
            TriggerKey triggerKey=new TriggerKey("testTrigger", Scheduler.DEFAULT_GROUP);
            SimpleTriggerImpl simpleTrigger=null;
            try {
                simpleTrigger= (SimpleTriggerImpl) scheduler.getTrigger(triggerKey);
            } catch (SchedulerException e) {
                e.printStackTrace();
            }
            simpleTrigger.setRepeatInterval(time);
            
            try {
                scheduler.rescheduleJob(triggerKey,simpleTrigger);
            } catch (SchedulerException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    }

![复制代码][copycode.gif]

代码如上：在任务类中注入Scheduler，然后添加restJob方法。

配置文件如下：

![复制代码][copycode.gif]

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
    
        
        <bean id="testQuartz" class="com.mc.bsframe.job.TestJob">
            <property name="scheduler" ref="schedulerFactoryBean"></property>
        </bean>
    
        
        <bean id="testJob" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
            <property name="targetObject" ref="testQuartz"></property>
            
            <property name="targetMethod" value="doSomething"></property>
            
            <property name="concurrent" value="false"></property>
        </bean>
    
        
        <bean id="testTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerFactoryBean">
            <property name="jobDetail" ref="testJob"></property>
            <property name="startDelay" value="3000"></property>
            <property name="repeatInterval" value="2000"></property>
        </bean>
    
        <bean id="schedulerFactoryBean" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
            <property name="triggers">
                <list>
                    <ref bean="testTrigger"></ref>
                </list>
            </property>
        </bean>
    </beans>

![复制代码][copycode.gif]

使用方法：

![复制代码][copycode.gif]

@Autowired
        @Qualifier(value="testQuartz")
        private TestJob job;
        
        @RequestMapping("/job")
        public void job(Long time){
            job.restJob(time);
        }

![复制代码][copycode.gif]

[copycode.gif]: /images/20220714/9dede7d7c5b949b186ffa97a7e211f79.png