java

关注公众号 jb51net

关闭
首页 > 软件编程 > java > SpringBoot定时任务

SpringBoot中定时任务的使用方法解析

作者：Mu_Mu是一只小白

这篇文章主要介绍了SpringBoot中定时任务的使用方法解析,@EnableScheduling 注解,它的作用是发现注解 @Scheduled的任务并由后台执行,没有它的话将无法执行定时任务,需要的朋友可以参考下

1.定时任务注解

在springboot启动器开启定时任务注解

在这里插入图片描述

这里的 @EnableScheduling 注解，它的作用是发现注解 @Scheduled的任务并由后台执行。没有它的话将无法执行定时任务。

2.使用的@Scheduled 注解

2.1 @Scheduled 的常用配置项

@Scheduled(fixedRate=2000)：上一次开始执行时间点后2秒再次执行，无论上一个任务是否执行完过2s就开始下一个任务；

@Scheduled(fixedDelay=2000)：上一次执行完毕时间点后2秒再次执行，上一个任务执行完后过2s 才执行下个任务；

@Scheduled(initialDelay=1000, fixedDelay=2000)：第一次延迟1秒执行， 然后在上一次执行完毕时间点后2秒再次执行；

@Scheduled(cron=“* * * * * ?”)：按cron规则执行。 在线Cron表达式生成器：//cron.qqe2.com/介绍

3.实战

3.1 @Scheduled 多线程并发执行

@Scheduled 默认是使用单线程执行所有任务的。

1）验证：

编写多个@Scheduled 任务且设置执行时间和时间间隔都相同。

@Component
public class AnnotationSchedulTask {
    private static final Logger LOG = LoggerFactory.getLogger(AnnotationSchedulTask.class);
    private int count=0;
    
    @Scheduled(cron = "0/2 * * * * ? ")
    public  void test(){
        //0/1 第一次运行间隔0s，每次间隔1s运行一次
        LOG.info("SchedulTask run count:"+count++);
    }
    
    /**
     * 测试@Scheduled 默认是否是单线程运行
     */
    @Scheduled(cron = "0/2 * * * * ? ")
    public  void testConcurrence(){
        LOG.info("*********testConcurrence run**************");
    }

    /**
     * 测试@Scheduled 默认是否是单线程运行
     */
    @Scheduled(cron = "0/2 * * * * ? ")
    public  void testConcurrence2(){
        LOG.info("--------testConcurrence2-----------");
    }
    
}

启动服务运行结果：

可以看到所有任务都被 scheduling-1 线程执行

在这里插入图片描述

原因：

从ScheduledAnnotationBeanPostProcessor类开始一路找下去，在ScheduledTaskRegistrar（定时任务注册类）中的ScheduleTasks中又这样一段判断：

if (this.taskScheduler == null) {
 this.localExecutor = Executors.newSingleThreadScheduledExecutor();
 this.taskScheduler = new ConcurrentTaskScheduler(this.localExecutor);
}

当this.taskScheduler 为null 时 Executors.newSingleThreadScheduledExecutor(); 单个线程的线程池。

2）扩展多线程

其实只要设置一个我们自定义的this.taskScheduler

方法一： 配置一个ScheduledExecutorService bean即可设置

 /**
     * 执行周期性或定时任务
     */
    @Bean(name = "scheduledExecutorService")
    protected ScheduledExecutorService scheduledExecutorService()
    {
        return new ScheduledThreadPoolExecutor(corePoolSize,
                new BasicThreadFactory.Builder().namingPattern("MySchedule-pool-%d").daemon(true).build(),
                new ThreadPoolExecutor.CallerRunsPolicy())
        {
            @Override
            protected void afterExecute(Runnable r, Throwable t)
            {
                super.afterExecute(r, t);
                if (t == null && r instanceof Future<?>)
                {
                    try
                    {
                        Future<?> future = (Future<?>) r;
                        if (future.isDone())
                        {
                            future.get();
                        }
                    }
                    catch (CancellationException ce)
                    {
                        t = ce;
                    }
                    catch (ExecutionException ee)
                    {
                        t = ee.getCause();
                    }
                    catch (InterruptedException ie)
                    {
                        Thread.currentThread().interrupt();
                    }
                }
                if (t != null)
                {
                    log.error(t.getMessage(), t);
                }
            }
        };
    }

执行结果：

可以看到现在@Scheduled 由不同线程执行。

在这里插入图片描述

原理：

ScheduledAnnotationBeanPostProcessor 类的finishRegistration方法

最终在 this.registrar.setScheduler(resolveSchedulerBean(this.beanFactory, ScheduledExecutorService.class, false));

这一行 我们自定义的ScheduledExecutorService bean被当作执行的线程池。

方法2:

@Configurationpublic class ScheduleConfig implements SchedulingConfigurer { @Override public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { taskRegistrar.setScheduler( new ScheduledThreadPoolExecutor(8, new BasicThreadFactory.Builder().namingPattern("taskRegistrar-pool-%d").daemon(true).build(), new ThreadPoolExecutor.CallerRunsPolicy())); }}

运行结果：

可以看出来也成功了，并且覆盖了我们之前设置的ScheduledExecutorService。

在这里插入图片描述

3.2 cron 表达式实现指定时间执行任务

1）cron 表达式详细介绍：

通配符说明：

常用表达式示例：

2）设置每天固定时间执行

    //测试每天下午两点执行
    @Scheduled(cron = "0 0 14 * * ? ")
    public  void testCron2(){
        LOG.info("*********testCron2 run**************");
    }

结果：

在下午两点被执行

14:00:00.005 [taskRegistrar-pool-1] INFO  c.e.s.api.task.AnnotationSchedulTask
 *********testCron2 run**************

3）设定没1分钟执行一次

   //测试每分钟执行一次
    @Scheduled(cron = "0 0/1 * * * ? ")
    public  void testFixedDelay(){
        LOG.info("*********testFixedDelay run**************");
    }

结果：

每分钟执行一次

在这里插入图片描述

4)设定每月几号执行一次

必须指定执行时间不然当天每分钟都会被执行一次。

  //设定每月几号执行一次
    @Scheduled(cron = "0 14 14 3 * ? ")
    public  void testFixedDay(){
        LOG.info("*********testFixedDay run**************");
    }

结果：

在 3号的 14.14 被执行。

在这里插入图片描述

到此这篇关于SpringBoot中定时任务的使用方法解析的文章就介绍到这了,更多相关SpringBoot定时任务内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:
阅读全文