Spring Scheduled定时任务动态修改cron参数

迷南。 2023-07-25 06:22 5阅读 0赞

使用[spring][] @scheduled注解可以方便的设定定时任务，但是对于定时参数需要变化的情况就会很不方便，如果要实现更改定时参数，就要停止服务，更改参数，重新部署。  
对于这种需求， 可以利用TaskScheduler借口来实现,实现方法有两种

*  启动定时,关闭定时，使用新参数启动定时
 *  使用自定义的Trigger启动定时，更改参数

范例代码如下

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 </td> 
 <td> <code>package</code>&nbsp;<code>schedule;</code> &nbsp; <code>import</code>&nbsp;<code>java.util.Date;</code> &nbsp; <code>public</code>&nbsp;<code>class</code>&nbsp;<code>Say&nbsp;</code><code>implements</code>&nbsp;<code>Runnable { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>void</code>&nbsp;<code>run(){ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(</code><code>""</code>&nbsp;<code>+&nbsp;</code><code>new</code>&nbsp;<code>Date() +&nbsp;</code><code>" hello"</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 </td> 
 <td> <code>package</code>&nbsp;<code>schedule;</code> &nbsp; <code>import</code>&nbsp;<code>java.util.Date;</code> <code>import</code>&nbsp;<code>java.util.concurrent.ScheduledFuture;</code> &nbsp; <code>import</code>&nbsp;<code>javax.annotation.PostConstruct;</code> &nbsp; <code>import</code>&nbsp;<code>org.springframework.beans.factory.annotation.Autowired;</code> <code>import</code>&nbsp;<code>org.springframework.boot.SpringApplication;</code> <code>import</code>&nbsp;<code>org.springframework.boot.autoconfigure.SpringBootApplication;</code> <code>import</code>&nbsp;<code>org.springframework.context.annotation.Bean;</code> <code>import</code>&nbsp;<code>org.springframework.scheduling.Trigger;</code> <code>import</code>&nbsp;<code>org.springframework.scheduling.TriggerContext;</code> <code>import</code>&nbsp;<code>org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;</code> <code>import</code>&nbsp;<code>org.springframework.scheduling.support.CronTrigger;</code> <code>import</code>&nbsp;<code>org.springframework.stereotype.Controller;</code> <code>import</code>&nbsp;<code>org.springframework.web.bind.annotation.RequestMapping;</code> <code>import</code>&nbsp;<code>org.springframework.web.bind.annotation.ResponseBody;</code> &nbsp; <code>@Controller</code> <code>@SpringBootApplication</code> <code>public</code>&nbsp;<code>class</code>&nbsp;<code>ScheduleApplication { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Autowired</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>private</code>&nbsp;<code>ThreadPoolTaskScheduler threadPoolTaskScheduler;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Bean</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>ThreadPoolTaskScheduler threadPoolTaskScheduler(){ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>new</code>&nbsp;<code>ThreadPoolTaskScheduler();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>private</code>&nbsp;<code>ScheduledFuture&lt;?&gt; future;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@RequestMapping</code><code>(</code><code>"/"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@ResponseBody</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>String home(){ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>"home"</code><code>;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>///方法一</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@RequestMapping</code><code>(</code><code>"/startCron"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@ResponseBody</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>String startCron(){ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(</code><code>"x0"</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//threadPoolTaskScheduler.shutdown();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>future = threadPoolTaskScheduler.schedule(</code><code>new</code>&nbsp;<code>Say(),&nbsp;</code><code>new</code>&nbsp;<code>CronTrigger(</code><code>"*/5 * * * * *"</code><code>));</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(</code><code>"x1"</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>"x"</code><code>;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@RequestMapping</code><code>(</code><code>"/stopCron"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@ResponseBody</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>String stopCron(){ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(</code><code>"stop &gt;&gt;&gt;&gt;&gt;"</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code><code>(future !=&nbsp;</code><code>null</code><code>) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>future.cancel(</code><code>true</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//future = threadPoolTaskScheduler.schedule(new Say(), new CronTrigger("*/5 * * * * *"));</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(</code><code>"stop &lt;&lt;&lt;&lt;&lt;"</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>"stop cron"</code><code>;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@RequestMapping</code><code>(</code><code>"/startCron10"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@ResponseBody</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>String startCron10(){ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(</code><code>"x100"</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>future = threadPoolTaskScheduler.schedule(</code><code>new</code>&nbsp;<code>Say10(),&nbsp;</code><code>new</code>&nbsp;<code>CronTrigger(</code><code>"*/12 * * * * *"</code><code>));</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(</code><code>"x101"</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>"x10"</code><code>;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> &nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>///方法二</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>private</code>&nbsp;<code>String cronStr =&nbsp;</code><code>"*/5 * * * * *"</code><code>;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@RequestMapping</code><code>(</code><code>"/startCron1"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@ResponseBody</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>String startCron1(){ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(</code><code>"startCron1 &gt;&gt;&gt;&gt;"</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>threadPoolTaskScheduler.schedule(</code><code>new</code>&nbsp;<code>Say(),&nbsp;</code><code>new</code>&nbsp;<code>Trigger(){ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>Date nextExecutionTime(TriggerContext triggerContext){ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>new</code>&nbsp;<code>CronTrigger(cronStr).nextExecutionTime(triggerContext);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>});</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(</code><code>"startCron1 &lt;&lt;&lt;&lt;"</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;<code>"*****"</code><code>;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@PostConstruct</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>void</code>&nbsp;<code>start(){ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>startCron1();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@RequestMapping</code><code>(</code><code>"/changeCronStr"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@ResponseBody</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>String changeCronStr(){ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>cronStr =&nbsp;</code><code>"*/12 * * * * *"</code><code>;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(</code><code>"change "</code>&nbsp;&nbsp;<code>+ cronStr);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;&nbsp;<code>cronStr;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@RequestMapping</code><code>(</code><code>"/changeCronStr5"</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@ResponseBody</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>String changeCronStr5(){ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>cronStr =&nbsp;</code><code>"*/5 * * * * *"</code><code>;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>System.out.println(</code><code>"change "</code>&nbsp;&nbsp;<code>+ cronStr);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code>&nbsp;&nbsp;<code>cronStr;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code>&nbsp;<code>static</code>&nbsp;<code>void</code>&nbsp;<code>main(String[] args) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>SpringApplication.run(ScheduleApplication.</code><code>class</code><code>, args);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

说明 threadPoolTaskScheduler.shutdown();会抛出异常  
@PostConstruct 在依赖注入完成后，进行调用  
使用

{
        sartcron();
    }

会产生空指针异常，以为依赖注入为完成.  
@PostConstruct还可以使用BeanPostProcessor的功能来完成.  
或使用

<table> 
 <tbody> 
 <tr> 
 <td> 1 </td> 
 <td> <code>public</code>&nbsp;<code>class</code>&nbsp;<code>StartupListener&nbsp;</code><code>implements</code>&nbsp;<code>ApplicationListener&lt;ContextRefreshedEvent&gt;</code> </td> 
 </tr> 
 </tbody> 
</table>

监听事件.

参考  
Spring/SpringMVC在启动完成后执行方法  
[http://blog.csdn.net/renyisheng/article/details/50803875][http_blog.csdn.net_renyisheng_article_details_50803875]  
Spring/SpringMVC在启动完成后执行方法  
[http://www.cnblogs.com/itjcw/p/5977911.html][http_www.cnblogs.com_itjcw_p_5977911.html]  
Spring @Scheduled定时任务动态修改cron参数  
[http://blog.csdn.net/xht555/article/details/53121962][http_blog.csdn.net_xht555_article_details_53121962]  
[Java][] 定时任务系列（2）-Spring 定时任务的几种实现  
[https://segmentfault.com/a/1190000002504252][https_segmentfault.com_a_1190000002504252]  
[Java ][Java 1]timer task schedule  
[http://stackoverflow.com/questions/4044729/java-timer-task-schedule][http_stackoverflow.com_questions_4044729_java-timer-task-schedule]  
\[Spring笔记\]支持注解的Spring调度器

[spring]: http://lib.csdn.net/base/javaee
[http_blog.csdn.net_renyisheng_article_details_50803875]: http://blog.csdn.net/renyisheng/article/details/50803875
[http_www.cnblogs.com_itjcw_p_5977911.html]: http://www.cnblogs.com/itjcw/p/5977911.html
[http_blog.csdn.net_xht555_article_details_53121962]: http://blog.csdn.net/xht555/article/details/53121962
[Java]: http://lib.csdn.net/base/javase
[https_segmentfault.com_a_1190000002504252]: https://segmentfault.com/a/1190000002504252
[Java 1]: http://lib.csdn.net/base/java
[http_stackoverflow.com_questions_4044729_java-timer-task-schedule]: http://stackoverflow.com/questions/4044729/java-timer-task-schedule