溪云阁：专注编程教学，架构，JAVA，Python，微服务，机器学习等领域，欢迎关注，一起学习。

前言

先声明：XXL-JOB非常好，我一直用它，只是作为IT工作者，永远对技术保持着敬畏之心与探索之心。

为什么需要分布式定时任务

1、单点任务调度特性:

单点定时任务有个最大的特性就是用起来非常方便，特别是SpringBoot提供了非常便捷的解决方案。

但是它也有比较明显的缺点，交互性比较差，部署效率太低，无法动态部署，开发成本，运维成本都很高，无法满足各个系统的管理及管控，特别是现在微服务的时代，后端的服务越来越多，可控性太差，单机部署的话还容易出现单点问题，整个的任务跟踪及执行状态都无法做到事实监控。

2、分布式任务调度特性：

首先在开发成本及维护成本上，通过集群的方式进行统一的任务管理调度。

分布式部署，从高可用，负载均衡，伸缩性，容错性等几个方面都有着非常大的提高。

存在一定的控制台可以实现定时任务的管理，启动，停止，更新任务时间，查看执行状态等都可以直接办到。

任务信息持久化等。

现在常用的任务调度平台有哪些

这个其实非常多，开 源 中 国一搜索就有很多，不过用得最多的还是XXL-JOB

SpringBoot实现任务调度

1、单点任务调度

@Configuration 
@EnableScheduling
public class SingleScheduleConfig {
  //添加定时任务
  @Scheduled(cron = "0/10 * * * * ?")
  private void singleTasks() {
    System.out.println("定时任务 1:" + LocalDateTime.now());
  }
}

实现单点非常简单，只需要两个关键性注解：@EnableScheduling，@Scheduled

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

动态任务调度

我们用Mysql来实现动态任务调度

<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>2.2.0</version>
    </dependency>
    <dependency>
      <groupId>mysql</groupId>
      <artifactId>mysql-connector-java</artifactId>
    </dependency>
  </dependencies>

创建数据库表并插入数据

DROP DATABASE IF EXISTS `boots`;
CREATE DATABASE `boots`;
USE `BOOTS`;
DROP TABLE IF EXISTS `crons`;
CREATE TABLE `crons` (
 `cron_id` varchar(10),
 `cron` varchar(50)
);
INSERT INTO `crons` VALUES ('1', '0/10 * * * * ?');

添加数据源配置

spring:
 datasource:
  url: jdbc:mysql://localhost:3306/boots?useSSL=false
  username: root
  password: 123456

创建动态任务器

@Configuration
@EnableScheduling
public class DynamicScheduleConfig implements SchedulingConfigurer {
  
  @Autowired
  private CronMapper cronMapper;
  
  @Mapper
  public interface CronMapper {
    @Select("select cron from cron limit 1")
    String getCronInfo();
  }

  /**
    * 团队详情
    * @author 林溪
    * @date: 2021/10/9 11:07
    * @param: taskRegistrar
    * @return: void
    */
  @Override
  public void configureTasks(ScheduledTaskRegistrar task) {
    // 开始注册定时任务
    task.addTriggerTask(
        // 开始添加任务
        () -> System.out.println("动态执行定时任务:" + LocalDateTime.now().toLocalTime()),
        // 开始设置定时任务执行的周期
        triggerContext -> {
          // 从数据库获取数据
          String cron = cronMapper.getCronInfo();
          //合法性校验.
          if (StringUtils.isEmpty(cron)) {
            // dosomething
          }
          //加载并返回任务周期
          return new CronTrigger(cron).nextExecutionTime(triggerContext);
        }
    );
  }
}

到此就核心搞定了，接下来你只需要开发一个web管理平台来实现数据库的管理就搞定了。

附上咱们种花家的兔子

--END--

作者：@溪云阁

原创作品，抄袭必究

如需要源码，请转发，关注后私信我

部分图片或代码来源网络，如侵权请联系删除，谢谢！