在开发中,有时候会遇到定时推送的需要,例如定时发送推送、定时发送邮件等等。SpringBoot为咱们内置了定时工作,咱们只须要一个注解就能够开启定时为咱们所用了。
开启定时工作
在入口类LogApplication中增加 @EnableScheduling 注解,增加注解后SpringBoot就曾经认定了咱们要应用定时工作来实现一些业务逻辑了,外部会对应原始配置定时工作增加对应的配置文件。
@SpringBootApplication@EnableScheduling + // 启用定时工作public class LogApplication {
@Scheduled
配置定时工作非常简单,只须要在须要定时执行的办法上增加 @Scheduled 注解即可。留神,该类上须要打上组件型注解,例如 @Componet,这样该类才会被注入到 Spring 容器中进行治理,用来表明这是一个被Spring治理的Bean,@Scheduled 才会失效。
当然个别会应用@Coponent的衍生注解:@Repository, @Service, @Controller来代替,这里不开展讲了。
@Service +public class DayLogTaskImpl implements DayLogTask { @Scheduled(cron = "* * * * * ?") + public void test1() {
当初来测试一下代码:
@Scheduled(cron = "* * * * * ?") public void test1() { /** * 每秒执行一次 */ logger.info("scheduler1 执行: " + System.currentTimeMillis()); }
运行后果:
2022-02-14 13:46:50.000 INFO 2337 --- [ scheduling-1] club.yunzhi.log.task.DayLogTask : scheduler1 执行: 16448284100002022-02-14 13:46:51.003 INFO 2337 --- [ scheduling-1] club.yunzhi.log.task.DayLogTask : scheduler1 执行: 16448284110032022-02-14 13:46:52.000 INFO 2337 --- [ scheduling-1] club.yunzhi.log.task.DayLogTask : scheduler1 执行: 16448284120002022-02-14 13:46:53.000 INFO 2337 --- [ scheduling-1] club.yunzhi.log.task.DayLogTask : scheduler1 执行: 1644828413000
能够看到打印出的工夫相隔都大概是1000毫秒左右,合乎定义的每秒执行一次。
@Scheduled 注解参数阐明
cron:该参数接管一个cron表达式,cron表达式是一个字符串,如示意每5秒执行一次。
zone: 时区。默认为服务器所在时区,接管类型为 java.util.TimeZone。
fixedDelay:上一次执行结束工夫点之后多长时间再执行。如:
@Scheduled(fixedDelay = 10000) //上一次执行结束工夫点之后10秒再执行
fixedRate: 示意在上次执行开始之后多久后再次执行。用法同上。
initialDelay: 示意第一次工作执行提早多久。用法同上。
@Scheduled的线程问题
@Scheduled 默认是单线程执行的,多个 @Scheduled 工作都用的同一个线程。如果某个工作是个耗时的操作,那么其它定时工作都会期待该工作的执行实现,从而造成梗塞。
比方上面咱们给出一个例子:两个无关的定时工作:打印日志print和生成表格generate,都是须要每秒触发一次。如果generate执行一次须要耗时 3 秒,则print和generate 都要等这一次的generate执行后能力再执行,这就达不到工作print、generate 每秒执行一次的成果了。
咱们用代码来测试一下
咱们用Thread.sleep()模仿执行办法时的耗时。两者都是每秒执行一次,其中test1睡眠3秒模仿耗时。
@Scheduled(cron = "* * * * * ?") public void test1() { /** * 每秒执行一次 */ logger.info("test1执行并睡眠3秒: " + System.currentTimeMillis()); try { Thread.sleep(3000); } catch (InterruptedException e) { e.printStackTrace(); } logger.info("test1执行完结: " + System.currentTimeMillis()); } @Scheduled(cron = "* * * * * ?") public void test2() { /** * 每秒执行一次 */ logger.info("test2 执行: " + System.currentTimeMillis()); }
运行后果:
2022-02-14 14:09:41.004 INFO 2484 --- [ scheduling-1] club.yunzhi.log.task.DayLogTask : test1执行并睡眠3秒: 16448297810042022-02-14 14:09:44.007 INFO 2484 --- [ scheduling-1] club.yunzhi.log.task.DayLogTask : test1执行完结: 16448297840072022-02-14 14:09:44.010 INFO 2484 --- [ scheduling-1] club.yunzhi.log.task.DayLogTask : test2 执行: 16448297840102022-02-14 14:09:45.005 INFO 2484 --- [ scheduling-1] club.yunzhi.log.task.DayLogTask : test1执行并睡眠3秒: 16448297850052022-02-14 14:09:48.007 INFO 2484 --- [ scheduling-1] club.yunzhi.log.task.DayLogTask : test1执行完结: 16448297880072022-02-14 14:09:48.008 INFO 2484 --- [ scheduling-1] club.yunzhi.log.task.DayLogTask : test2 执行: 16448297880082022-02-14 14:09:49.009 INFO 2484 --- [ scheduling-1] club.yunzhi.log.task.DayLogTask : test2 执行: 16448297890092022-02-14 14:09:49.011 INFO 2484 --- [ scheduling-1] club.yunzhi.log.task.DayLogTask : test1执行并睡眠3秒: 16448297890112022-02-14 14:09:52.012 INFO 2484 --- [ scheduling-1] club.yunzhi.log.task.DayLogTask : test1执行完结: 16448297920122022-02-14 14:09:52.013 INFO 2484 --- [ scheduling-1] club.yunzhi.log.task.DayLogTask : test2 执行: 16448297920132022-02-14 14:09:53.005 INFO 2484 --- [ scheduling-1] club.yunzhi.log.task.DayLogTask : test1执行并睡眠3秒: 1644829793005
能够看到执行的线程都是[ scheduling-1],并且test2执行距离并不固定是设置好的1s,而是 有时是1s,有时是3s,4s。
那么,如何能让每个定时工作依照配置好的定时规定准时执行呢?这就须要咱们将定时工作配置成多线程的形式。
应用 @Async 异步执行办法
与增加定时工作雷同,在入口类中增加 @EnableAsync,开启异步执行。在定时工作上增加 @Async 注解,标识该办法异步执行。办法代码与下面的雷同。
@Async + @Scheduled(cron = "* * * * * ?") public void test1() {
这时候咱们再执行代码看看成果:
2022-02-14 14:45:04.001 INFO 2608 --- [ task-4] club.yunzhi.log.task.DayLogTask : test1执行并睡眠3秒: 16448319040012022-02-14 14:45:04.001 INFO 2608 --- [ task-1] club.yunzhi.log.task.DayLogTask : test1执行完结: 16448319040012022-02-14 14:45:05.002 INFO 2608 --- [ task-2] club.yunzhi.log.task.DayLogTask : test1执行完结: 16448319050022022-02-14 14:45:05.002 INFO 2608 --- [ task-5] club.yunzhi.log.task.DayLogTask : test1执行并睡眠3秒: 16448319050022022-02-14 14:45:05.003 INFO 2608 --- [ scheduling-1] club.yunzhi.log.task.DayLogTask : test2 执行: 16448319050032022-02-14 14:45:06.001 INFO 2608 --- [ scheduling-1] club.yunzhi.log.task.DayLogTask : test2 执行: 16448319060012022-02-14 14:45:06.001 INFO 2608 --- [ task-6] club.yunzhi.log.task.DayLogTask : test1执行并睡眠3秒: 16448319060012022-02-14 14:45:06.008 INFO 2608 --- [ task-3] club.yunzhi.log.task.DayLogTask : test1执行完结: 16448319060082022-02-14 14:45:07.001 INFO 2608 --- [ scheduling-1] club.yunzhi.log.task.DayLogTask : test2 执行: 16448319070012022-02-14 14:45:07.001 INFO 2608 --- [ task-4] club.yunzhi.log.task.DayLogTask : test1执行完结: 16448319070012022-02-14 14:45:07.002 INFO 2608 --- [ task-7] club.yunzhi.log.task.DayLogTask : test1执行并睡眠3秒: 1644831907002
尽管办法执行须要耗时 3 秒,然而每个工作还是依照每秒钟触发一次准时执行了。通过后面的 线程号 能够看出,工作的执行应用了不同的线程。test2用的是scheduling-1的线程号,每秒一次。而test1异步则用了多个线程号。
@Async 默认线程池个数为 8 个。
默认的 @Async 能够应酬个别的场景,但如果是并发量比拟高的状况下,就会存在肯定危险。例如开销过大、内存溢出等。为使服务运行稳固,咱们能够自定义配置线程池,而后让给须要异步执行的办法指定用该线程池运行。
简略来说就是配置一个Executor,配置外围线程数,最大线程数,队列大小等信息。用@Async("myExecutor")指定该调用该线程池。
@Configurationpublic class ExecutorConfig { @Bean(name = "myExecutor") public Executor taskExecutor() {
具体能够参考这篇文章:https://www.interhorse.cn/a/3...
目前的我的项目中定时工作执行的办法较快,且距离在分钟级别,所以没有用到多线程定时工作,记录一下避免当前须要。
以上为定时工作的相干内容。