分布式锁@SHEDLOCK解决集群定时任务问题@SCHEDULED，SPRINGBOOT

Shedlock是个分布式锁，大致实现，就是针对多个服务，提供一个公有的存储，来维护这个锁（类似悲观锁机制）

因为拿不到就跳过本次执行这个策略，所以非常适定时任务（实际上就是为定时任务设计的），
先看下不加锁，模拟集群、分布式（多套服务同一套代码）

    @Scheduled(cron = "0/5 * * * * ?")
    //@SchedulerLock(name = "qpsStatisticsTask", lockAtLeastForString = "PT60S", lockAtMostForString = "PT1800S")
    public void qpsStatisticsSchedule(){
        qpsStatisticsService.statisticsQps();
        log.info("qpsStatisticsTask task end 1");
    }

    @Scheduled(cron = "0/5 * * * * ?")
    //@SchedulerLock(name = "qpsStatisticsTask", lockAtLeastForString = "PT60S", lockAtMostForString = "PT1800S")
    public void qpsStatisticsSchedule1(){
        qpsStatisticsService.statisticsQps();
        log.info("qpsStatisticsTask task end 2");
        }12345678910111213

看下日志记录，两个同时执行了，

开始使用shedlock
1、添加依赖

<dependency>
			<groupId>net.javacrumbs.shedlock</groupId>
			<artifactId>shedlock-spring</artifactId>
			<version>2.1.0</version>
		</dependency>

		<dependency>
			<groupId>net.javacrumbs.shedlock</groupId>
			<artifactId>shedlock-provider-jdbc-template</artifactId>
			<version>2.1.0</version>
		</dependency>1234567891011

2、配置数据源

@Configuration@EnableScheduling@EnableSchedulerLock(defaultLockAtMostFor = "PT5S")   //defaultLockAtMostFor  默认锁定时间public class ScheduleConfig {
    @Bean
    public LockProvider lockProvider(DataSource dataSource) {
        return new JdbcTemplateLockProvider(dataSource);
    }}123456789

3、建表,表名默认用这个shedlock，改其它的需要额外配置，字段也是固定的，使用时候只需要建好这个表就可以了，不需要额外操作

CREATE TABLE `shedlock` (
  `name` varchar(64) COLLATE utf8_bin NOT NULL,
  `lock_until` timestamp(3) NULL DEFAULT NULL,
  `locked_at` timestamp(3) NULL DEFAULT NULL,
  `locked_by` varchar(255) COLLATE utf8_bin DEFAULT NULL,
  PRIMARY KEY (`name`)) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin;1234567

4、注解加锁，name:锁名字，因为不止一个定时任务，多个定时任务，就要维护多个锁，各自有各自的名字(只需注解中配置)，
lockAtLeastForString：最小锁定时间（这里是60s），lockAtMostForString：最大锁定时间（这里是1800s）

@Scheduled(cron = "1 * * * * ?")
    @SchedulerLock(name = "qpsStatisticsTask", lockAtLeastForString = "PT60S", lockAtMostForString = "PT1800S")
    public void qpsStatisticsSchedule(){
        qpsStatisticsService.statisticsQps();
        log.info("qpsStatisticsTask task end 1");
    }

    @Scheduled(cron = "1 * * * * ?")
    @SchedulerLock(name = "qpsStatisticsTask", lockAtLeastForString = "PT60S", lockAtMostForString = "PT1800S")
    public void qpsStatisticsSchedule1(){
        qpsStatisticsService.statisticsQps();
        log.info("qpsStatisticsTask task end 2");
        }12345678910111213

5、执行下试试？？从日志看到，每隔一分钟只有一个定时任务执行（这里三次都是第一个任务强到了锁，所以都是它执行）；

6、看下数据库数据，锁只持续了5s，那我们配置中的最大最小值是干嘛的呢？是程序异常时候给与的保护，比如定时任务写数据比较慢类似，到了最大时间还没有执行完毕，就会强行释放锁，不耽误下次任务

7、缺点
因为使用数据库维护锁，写比较耗时，所以只适合粗粒度的定时任务，对于比较细粒度的定时任务，比如秒级、毫秒级等等，不适合