在實(shí)際的項(xiàng)目開發(fā)工作中，我們經(jīng)常會遇到需要做一些定時任務(wù)的工作，那么在Spring Cloud中是如何實(shí)現(xiàn)的？今天來介紹下其中的一種解決方案——輕量級分布式定時鎖ShedLock

ShedLock

ShedLock是一個在分布式環(huán)境中使用的定時任務(wù)框架，用于解決在分布式環(huán)境中的多個實(shí)例的相同定時任務(wù)在同一時間點(diǎn)重復(fù)執(zhí)行的問題。

解決思路是通過對公用的數(shù)據(jù)庫中的某個表進(jìn)行記錄和加鎖，使得同一時間點(diǎn)只有第一個執(zhí)行定時任務(wù)并成功在數(shù)據(jù)庫表中寫入相應(yīng)記錄的節(jié)點(diǎn)能夠成功執(zhí)行而其他節(jié)點(diǎn)直接跳過該任務(wù)。
目前已經(jīng)實(shí)現(xiàn)的支持?jǐn)?shù)據(jù)存儲類型不僅僅只有關(guān)系型數(shù)據(jù)庫，還包括MongoDB，Zookeeper，Redis，Hazelcast。

1. pom文件添加相關(guān)依賴

在pom文件中添加shedLock相關(guān)依賴

 <!--shedlock-->
    <dependency>
      <groupId>net.javacrumbs.shedlock</groupId>
      <artifactId>shedlock-spring</artifactId>
      <version>2.2.0</version>
    </dependency>
    <dependency>
      <groupId>net.javacrumbs.shedlock</groupId>
      <artifactId>shedlock-provider-jdbc-template</artifactId>
      <version>2.2.0</version>
    </dependency>

2. 添加相關(guān)配置

在啟動類添加@EnableScheduling和@EnableSchedulerLock(defaultLockAtMostFor = "PT30S")注解，表示要啟動ShedLock定時任務(wù)

defaultLockAtMostFor要設(shè)置值，不設(shè)置會報(bào)錯；設(shè)置值一般設(shè)置比定時任務(wù)大點(diǎn)值，一般在每個定時任務(wù)中都會配置defaultLockAtMostFor值，會覆蓋啟動類中的值

@EnableScheduling
@EnableSchedulerLock(defaultLockAtMostFor = "PT30S")
public class OneStopServiceApplication {
  public static void main(String[] args) {
    SpringApplication.run(OneStopServiceApplication.class, args);
  }

}

3.添加ShedLock配類

shedLock支持關(guān)系型數(shù)據(jù)庫，以mysql為例，配置mysql以及表名；shedLock默認(rèn)表名為shedlock,可以設(shè)置自定義表名。

@Configuration
public class ScheduledLockConfig {
  @Bean
  public LockProvider lockProvider(DataSource dataSource) {
    //自定義表名
    return new JdbcTemplateLockProvider(dataSource,"ccsy_shedlock");
  }
}

4.ShedLock定時任務(wù)

@Component
public class HourTask {
  /**
   * 最小鎖定時間,一般設(shè)置成定時任務(wù)小一點(diǎn)
   */
  private static final int MIN_LOCK_TIME = 1000;//單位毫秒
  /**
   * 最大鎖定時間,一般設(shè)置成比正常執(zhí)行時間長的值
   */
  private static final int MAX_LOCK_TIME = 1000 * 2;//單位毫秒

  
  @Scheduled(cron = "0/1 * * * * ? ")
  @SchedulerLock(name = "測試", lockAtMostFor = MAX_LOCK_TIME, lockAtLeastFor = MIN_LOCK_TIME)
  public void visitCountTaskByTwoHour() {
    SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    System.out.println("現(xiàn)在時間是" + format.format(new Date())+ Thread.currentThread().getName());
  }
}

@SchedulerLock注解一共支持五個參數(shù)，分別是

• name 用來標(biāo)注一個定時服務(wù)的名字，被用于寫入數(shù)據(jù)庫作為區(qū)分不同服務(wù)的標(biāo)識，如果有多個同名定時任務(wù)則同一時間點(diǎn)只有一個執(zhí)行成功
• lockAtMostFor 成功執(zhí)行任務(wù)的節(jié)點(diǎn)所能擁有獨(dú)占鎖的最長時間，單位是毫秒ms
• lockAtMostForString 成功執(zhí)行任務(wù)的節(jié)點(diǎn)所能擁有的獨(dú)占鎖的最長時間的字符串表達(dá)，例如“PT14M”表示為14分鐘
• lockAtLeastFor 成功執(zhí)行任務(wù)的節(jié)點(diǎn)所能擁有獨(dú)占所的最短時間，單位是毫秒ms
• lockAtLeastForString 成功執(zhí)行任務(wù)的節(jié)點(diǎn)所能擁有的獨(dú)占鎖的最短時間的字符串表達(dá)，例如“PT14M”表示為14分鐘

5.創(chuàng)建mysql數(shù)據(jù)庫中定時任務(wù)ccsy_shedlock表

CREATE TABLE ccsy_shedlock (
 NAME VARCHAR ( 64 ),
 lock_until TIMESTAMP ( 3 ) NULL,
 locked_at TIMESTAMP ( 3 ) NULL,
locked_by VARCHAR ( 255 ),
PRIMARY KEY ( NAME ))

到此這篇關(guān)于Spring Cloud分布式定時器之ShedLock的實(shí)現(xiàn)的文章就介紹到這了,更多相關(guān)Spring Cloud分布式定時器內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評論