SpringBoot并发执行定时任务

偏执的太偏执、 2022-12-26 10:22 162阅读 0赞

刚刚看了下Spring Boot实现定时任务的文章，感觉还不错。Spring Boot 使用Spring自带的Schedule来实现定时任务变得非常简单和方便。在这里个大家分享下。

# 开启缓存注解 #

1.  @SpringBootApplication
2.  @EnableScheduling //开启定时任务
3.  public class Application \{
4.   
5.  public static void main(String\[\] args) \{
6.  SpringApplication.run(Application.class, args);
7.  \}
8.  \}

*  1
 *  2
 *  3
 *  4
 *  5
 *  6
 *  7
 *  8
 *  9

# 编写定时任务 #

1.  @Component
2.  public class ScheduledTasks \{
3.   
4.  private Logger logger = LoggerFactory.getLogger(ScheduledTasks.class);
5.   
6.  // cron接受cron表达式，根据cron表达式确定定时规则
7.  @Scheduled(cron= "0/5 \* \* \* \* ? ") //每5秒执行一次
8.  public void testCron() \{
9.  DateFormat sdf = new SimpleDateFormat( "yyyy-MM-dd HH:mm:ss");
10. logger.info(sdf.format( new Date())+ "\*\*\*\*\*\*\*\*\*每5秒执行一次");
11. \}
12. \}

*  1
 *  2
 *  3
 *  4
 *  5
 *  6
 *  7
 *  8
 *  9
 *  10
 *  11
 *  12
 *  13

# 任务完成 #

启动项目，查看控制台打印信息,发现定时任务已经生效。spring boot 和Scheduled整合完毕。

![1240][]

--------------------

# 存在问题 #

但是后来发现个问题，通过同时测试几个任务发现，所有的任务都是在同一个线程池中的同一个线程来完成的。在实际开发过程中，我们当然不希望所有的任务都运行在一个线程中。

1.  @Scheduled(cron= "0/1 \* \* \* \* ? ") //每1秒执行一次
2.  public void testCron1() \{
3.  DateFormat sdf = new SimpleDateFormat( "yyyy-MM-dd HH:mm:ss");
4.  logger.info(sdf.format( new Date())+ "\*\*\*\*\*\*\*\*\*每1秒执行一次");
5.  \}
6.   
7.  @Scheduled(cron= "0/2 \* \* \* \* ? ") //每2秒执行一次
8.  public void testCron2() \{
9.  DateFormat sdf = new SimpleDateFormat( "yyyy-MM-dd HH:mm:ss");
10. logger.info(sdf.format( new Date())+ "\*\*\*\*\*\*\*\*\*每2秒执行一次");
11. \}
12.  
13. @Scheduled(cron= "0/3 \* \* \* \* ? ") //每3秒执行一次
14. public void testCron3() \{
15. DateFormat sdf = new SimpleDateFormat( "yyyy-MM-dd HH:mm:ss");
16. logger.info(sdf.format( new Date())+ "\*\*\*\*\*\*\*\*\*每3秒执行一次");
17. \}
18.  
19. @Scheduled(cron= "0/4 \* \* \* \* ? ") //每4秒执行一次
20. public void testCron4() \{
21. DateFormat sdf = new SimpleDateFormat( "yyyy-MM-dd HH:mm:ss");
22. logger.info(sdf.format( new Date())+ "\*\*\*\*\*\*\*\*\*每4秒执行一次");
23. \}

*  1
 *  2
 *  3
 *  4
 *  5
 *  6
 *  7
 *  8
 *  9
 *  10
 *  11
 *  12
 *  13
 *  14
 *  15
 *  16
 *  17
 *  18
 *  19
 *  20
 *  21
 *  22
 *  23
 *  24

![1240][1240 1]

--------------------

# 解决方案 #

那么，怎么设计成多线程实现并发呢？在网上看到过这样的解决方案。通过ScheduleConfig配置文件实现SchedulingConfigurer接口，并重写setSchedulerfang方法，我们尝试着配置了一下。

1.   
2.  @Configuration
3.  public class ScheduleConfig implements SchedulingConfigurer \{
4.  @Override
5.  public void configureTasks(ScheduledTaskRegistrar taskRegistrar) \{
6.   
7.  taskRegistrar.setScheduler(Executors.newScheduledThreadPool( 5));
8.  \}
9.  \}

*  1
 *  2
 *  3
 *  4
 *  5
 *  6
 *  7
 *  8
 *  9
 *  10

--------------------

# 整合成功 #

这样就完成了多线程并发的配置？我们启动项目通过控制台输出信息验证一下结果，最后发现所有的任务都在同一个线程池但不同线程中完成，说明这个方案完全可行，这样，我们就完成了spring boot 多线程并发定时任务。

![1240][1240 2]

# 注 #

@Scheduled所支持的参数：

> 1.cron：cron表达式，指定任务在特定时间执行；  
> 2.fixedDelay：表示上一次任务执行完成后多久再次执行，参数类型为long，单位ms；  
> 3.fixedDelayString：与fixedDelay含义一样，只是参数类型变为String；  
> 4.fixedRate：表示按一定的频率执行任务，参数类型为long，单位ms；  
> 5.fixedRateString: 与fixedRate的含义一样，只是将参数类型变为String；  
> 6.initialDelay：表示延迟多久再第一次执行任务，参数类型为long，单位ms；  
> 7.initialDelayString：与initialDelay的含义一样，只是将参数类型变为String；  
> 8.zone：时区，默认为当前时区，一般没有用到。

Cron表达式范例：

> 每隔5秒执行一次：\*/5 \* \* \* \* ?  
> 每隔1分钟执行一次：0 \*/1 \* \* \* ?  
> 每天23点执行一次：0 0 23 \* \* ?  
> 每天凌晨1点执行一次：0 0 1 \* \* ?  
> 每月1号凌晨1点执行一次：0 0 1 1 \* ?  
> 每月最后一天23点执行一次：0 0 23 L \* ?  
> 每周星期天凌晨1点实行一次：0 0 1 ? \* L  
> 在26分、29分、33分执行一次：0 26,29,33 \* \* \* ?  
> 每天的0点、13点、18点、21点都执行一次：0 0 0,13,18,21 \* \* ?

其实不会Cron表达式也不用担心，网上有好多在线Cron生成器，我们完全可以通过在线生成器生成符合要求的cron，也很方便。

[1240]: /images/20221120/4fc3f4706d9a464097f5050e9efae576.png
[1240 1]: /images/20221120/e504753e14f44b78ab72f2318c10aeb0.png
[1240 2]: /images/20221120/1617782ab5b34210ad0b562a561fff86.png