Springboot定时任务并且持久化到数据库

本文主要是介绍Springboot定时任务并且持久化到数据库，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

因为疫情期间，要弄好多签到，于是就自己写了个定时任务，并支持持久化到数据库。

下载地址：https://gitee.com/lyp_Believer/springbootschudleTask/tree/master/

序言：创建定时任务非常简单，主要有两种创建方式：一、基于注解(@Scheduled) 二、基于接口（SchedulingConfigurer）. 前者相信大家都很熟悉，但是实际使用中我们往往想从数据库中读取指定时间来动态执行定时任务，这时候基于接口的定时任务就大派用场了。

一、静态定时任务（基于注解）

基于注解来创建定时任务非常简单，只需几行代码便可完成。

@Scheduled 除了支持灵活的参数表达式cron之外，还支持简单的延时操作，例如 fixedDelay ，fixedRate 填写相应的毫秒数即可。

@Configuration //1.主要用于标记配置类，兼备Component的效果。
@EnableScheduling // 2.开启定时任务
public class SimpleScheduleConfig {//3.添加定时任务@Scheduled(cron = "0/5 * * * * ?")private void configureTasks() {System.err.println("执行定时任务1: " + LocalDateTime.now());}
}

Cron表达式参数分别表示：
秒（0~59） 例如0/5表示每5秒
分（0~59）
时（0~23）
月的某天（0~31） 需计算
月（0~11）
周几（ 可填1-7 或 SUN/MON/TUE/WED/THU/FRI/SAT）

启动应用，可以看到控制台的信息如下：

二、动态定时任务（基于接口）

为了演示效果，这里选用 Mysql数据库和 Mybatis 来查询和调整定时任务的执行周期，然后观察定时任务的执行情况。

1.引入依赖

    <!--依赖管理 --><dependencies><dependency><!--添加Web依赖 --><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!--mybatis相关--><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>2.1.0</version></dependency><dependency><!--添加MySql依赖 --><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><scope>runtime</scope></dependency><dependency><!--添加Test依赖 --><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies>

2.添加数据库记录

在Navicat 连接本地数据库，随便打开查询窗口，然后执行脚本内容，如下：

DROP DATABASE IF EXISTS `socks`;
CREATE DATABASE `socks`;
USE `SOCKS`;
DROP TABLE IF EXISTS `cron`;
CREATE TABLE `cron`  (`cron_id` varchar(30),`cron` varchar(30) 
);
INSERT INTO `cron` VALUES ('1', '0/5 * * * * ?');

然后在项目中的application.yml 添加数据源：

#application.yml 配置如下：
spring:datasource:url: jdbc:mysql://localhost:3306/socks?useSSL=falseusername: rootpassword: root

3.创建定时器

数据库准备好数据之后，我们编写定时任务，注意这里添加的是TriggerTask，目的是循环读取我们在数据库设置好的执行周期，以及执行相关定时任务的内容。具体代码如下：

@Configuration
@EnableScheduling
public class CompleteScheduleConfig implements SchedulingConfigurer {@Mapperpublic interface CronMapper {@Select("select cron from cron limit 1")String getCron();}@Autowired@SuppressWarnings("all")CronMapper cronMapper;/*** 执行定时任务.*/@Overridepublic void configureTasks(ScheduledTaskRegistrar taskRegistrar) {taskRegistrar.addTriggerTask(//1.添加任务内容(Runnable)() -> System.out.println("执行定时任务2: " + LocalDateTime.now().toLocalTime()),//2.设置执行周期(Trigger)triggerContext -> {//2.1 从数据库获取执行周期String cron = cronMapper.getCron();//2.2 合法性校验.if (StringUtils.isEmpty(cron)) {// Omitted Code ..}//2.3 返回执行周期(Date)return new CronTrigger(cron).nextExecutionTime(triggerContext);});}}