Spring Boot 创建定时任务（配合数据库动态执行）.docx

在Spring Boot中，创建定时任务是一项常见的需求，用于在特定的时间点执行某些任务。本文将详细介绍如何使用Spring Boot配合数据库来动态执行定时任务。 Spring Boot提供了两种创建定时任务的方式：基于注解(@Scheduled)和基于接口(SchedulingConfigurer)。在基于注解的方式下，我们可以使用`@Scheduled`来标记一个方法，该方法将在指定的CRON表达式时间执行。例如： ```java @Configuration @EnableScheduling public class SimpleScheduleConfig { @Scheduled(cron = "0/5 * * * * ?") private void configureTasks() { System.err.println("执行定时任务1: " + LocalDateTime.now()); } } ``` 这里的`cron = "0/5 * * * * ?"`表示每5秒执行一次任务。CRON表达式的参数分别是：秒、分、时、日、月、周几。 然而，当需要根据数据库中存储的执行周期动态调整定时任务时，基于注解的方式就显得不够灵活。此时，我们可以使用基于接口的方式，即实现`SchedulingConfigurer`接口，这样可以在运行时动态地改变任务的执行策略。 为了实现动态定时任务，我们需要以下步骤： 1. **添加依赖**： - 添加Spring Boot的Web依赖，因为我们需要使用HTTP服务来接收和响应更改定时任务的请求。 - 引入Mybatis，以便与数据库交互。 - 添加MySQL驱动，作为数据存储。 - 添加测试依赖，以便进行单元测试。 ```xml <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>1.3.1</version> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <scope>runtime</scope> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies> ``` 2. **创建数据库和表**： 创建名为`socks`的数据库，并在其中创建一个名为`cron`的表，用于存储定时任务的CRON表达式。 ```sql 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 * * * * ?'); ``` 3. **配置数据源**： 在`application.yml`中配置数据库连接信息，如URL、用户名和密码。 4. **编写定时任务**： 创建一个类，实现`SchedulingConfigurer`接口，通过查询数据库获取定时任务的执行周期，并使用`ConcurrentTaskScheduler`来调度任务。 ```java @Configuration @EnableScheduling public class DynamicScheduleConfig implements SchedulingConfigurer { @Autowired private CronRepository cronRepository; // 假设有一个CronRepository用于与数据库交互 @Override public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { taskRegistrar.setTaskScheduler(new ConcurrentTaskScheduler()); taskRegistrar.addTriggerTask( () -> configureTasks(), triggerContext -> { CronTrigger cronTrigger = new CronTrigger(cronRepository.getDefaultCron()); return cronTrigger.nextExecutionTime(triggerContext); }); } private void configureTasks() { // 执行具体的任务逻辑 System.err.println("执行动态定时任务: " + LocalDateTime.now()); } } ``` 在这个例子中，`configureTasks`方法将被按照数据库中默认的CRON表达式执行。当数据库中的CRON表达式发生变化时，定时任务的执行周期也会随之动态更新，无需重启应用。 总结来说，Spring Boot结合数据库动态执行定时任务，既满足了开发需求的灵活性，又避免了因频繁调整而需要重启应用的不便。通过上述步骤，我们可以构建一个能够根据数据库中存储的CRON表达式实时调整的任务调度系统。同时，这样的设计也使得任务管理变得更加便捷，便于在实际生产环境中进行维护和扩展。