中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

溫馨提示×

您好，登錄后才能下訂單哦！

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

SpringBoot怎么集成ShedLock實現分布式定時任務

發布時間：2023-02-24 13:45:32 來源：億速云 閱讀：132 作者：iii 欄目：開發技術

本文小編為大家詳細介紹“SpringBoot怎么集成ShedLock實現分布式定時任務”，內容詳細，步驟清晰，細節處理妥當，希望這篇“SpringBoot怎么集成ShedLock實現分布式定時任務”文章能幫助大家解決疑惑，下面跟著小編的思路慢慢深入，一起來學習新知識吧。

    一、背景

    在項目服務是集群部署的時候，代碼在每個人都會有定時任務，但是如果讓每個節點都去跑定時任務是不大合適的。SpringBoot 中的 ShedLock 可以很好解決這個問題，下面我將為大家詳細介紹 SpringBoot 如何集成 ShedLock，而 ShedLock 又是如何實現分布式定時的。

    二、ShedLock是什么

    以下是ShedLock鎖提供者，通過外部存儲實現鎖，由下圖可知外部存儲集成的庫還是很豐富:

    SpringBoot怎么集成ShedLock實現分布式定時任務

    三、落地實現

    1.1 引入依賴包

    shedlock所需依賴包：

    <!-- web工程依賴包 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>net.javacrumbs.shedlock</groupId>
    <artifactId>shedlock-spring</artifactId>
    <version>4.2.0</version>
</dependency>
 <!--每個外部存儲實例所需依賴包不一樣，這里是jdbc-->
<dependency>
    <groupId>net.javacrumbs.shedlock</groupId>
    <artifactId>shedlock-provider-jdbc-template</artifactId>
    <version>4.2.0</version>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <scope>runtime</scope>
</dependency>

    依賴包樹形圖：

    SpringBoot怎么集成ShedLock實現分布式定時任務

    1.2 配置數據庫連接信息

    server:
      port: 8105
    spring:
      datasource:
        url: jdbc:mysql://127.0.0.1:3306/testjdbc?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
        username: root
        password: 123456
        driver-class-name: com.mysql.cj.jdbc.Driver
        type: com.mysql.cj.jdbc.MysqlDataSource

    1.3 創建Mysql數據表

    CREATE TABLE `shedlock` (
	`name`  varchar(64) NOT NULL COMMENT 'name' ,
	`lock_until`  timestamp(3) NULL DEFAULT NULL ,
	`locked_at`  timestamp(3) NULL DEFAULT NULL ,
	`locked_by`  varchar(255) NULL DEFAULT NULL ,
	PRIMARY KEY (`name`)
)
ENGINE=InnoDB
DEFAULT CHARACTER SET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci
ROW_FORMAT=DYNAMIC
;

    1.4 配置LockProvider

    ShedLockConfig.java:

    import net.javacrumbs.shedlock.core.LockProvider;
import net.javacrumbs.shedlock.provider.jdbctemplate.JdbcTemplateLockProvider;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import javax.sql.DataSource;
/**
 * @description: Shedlock集成Jdbc配置類
 */
@Component
public class ShedLockConfig {
    @Resource
    private DataSource dataSource;
    @Bean
    private LockProvider lockProvider() {
        return new JdbcTemplateLockProvider(dataSource);
    }
}

    springboot主啟動類MerakQuartzApplication：

    import net.javacrumbs.shedlock.spring.annotation.EnableSchedulerLock;
import org.mybatis.spring.annotation.MapperScan;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.security.servlet.SecurityAutoConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import java.util.concurrent.Executor;
import java.util.concurrent.ThreadPoolExecutor;
/**
 * @version 1.0
 * @ClassName: MerakQuartzApplication
 * @description: 工單任務調度
 */
// 開啟定時器
@EnableScheduling
// 開啟定時任務鎖，指定一個默認的鎖的時間30秒
@EnableSchedulerLock(defaultLockAtMostFor = "PT30S")
@EnableAsync
@MapperScan(basePackages = {"com.merak.hyper.automation.persist.**.mapper"})
@SpringBootApplication(scanBasePackages = {"com.merak.hyper.automation.**"}, exclude = {SecurityAutoConfiguration.class})
public class MerakQuartzApplication {
    public static final Logger log = LoggerFactory.getLogger(MerakQuartzApplication.class);
    public static void main(String[] args) {
        SpringApplication.run(MerakQuartzApplication.class, args);
    }
    private int taskSchedulerCorePoolSize = 15;
    private int awaitTerminationSeconds = 60;
    private String threadNamePrefix = "taskExecutor-";
    /**
     * @description: 實例化ThreadPoolTaskScheduler對象，用于創建ScheduledFuture<?> scheduledFuture
     */
    @Bean
    public ThreadPoolTaskScheduler threadPoolTaskScheduler() {
        ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
        taskScheduler.setPoolSize(taskSchedulerCorePoolSize);
        taskScheduler.setThreadNamePrefix(threadNamePrefix);
        taskScheduler.setWaitForTasksToCompleteOnShutdown(false);
        taskScheduler.setAwaitTerminationSeconds(awaitTerminationSeconds);
        /**需要實例化線程*/
        taskScheduler.initialize();
//        isinitialized = true;
        log.info("初始化ThreadPoolTaskScheduler ThreadNamePrefix=" + threadNamePrefix + ",PoolSize=" + taskSchedulerCorePoolSize
                + ",awaitTerminationSeconds=" + awaitTerminationSeconds);
        return taskScheduler;
    }
    /**
     * @description: 實例化ThreadPoolTaskExecutor對象，管理線程
     */
    @Bean("asyncTaskExecutor")
    public Executor taskExecutor() {
        ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
        taskExecutor.setCorePoolSize(5);
        taskExecutor.setMaxPoolSize(50);
        taskExecutor.setQueueCapacity(200);
        taskExecutor.setKeepAliveSeconds(60);
        taskExecutor.setThreadNamePrefix("asyncTaskExecutor-");
        taskExecutor.setWaitForTasksToCompleteOnShutdown(true);
        taskExecutor.setAwaitTerminationSeconds(60);
        //修改拒絕策略為使用當前線程執行
        taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        //初始化線程池
        taskExecutor.initialize();
        return taskExecutor;
    }
}

    1.5 創建定時Job

    DigitalEmpTask：

    package com.merak.hyper.automation.quartz.task;
import net.javacrumbs.shedlock.spring.annotation.SchedulerLock;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.util.List;
/**
 * @version 1.0
 * @ClassName: BizOrderTask
 * @description: 任務隊列服務調度
 */
@Component
public class DigitalEmpTask {
    public static final Logger log = LoggerFactory.getLogger(DigitalEmpTask.class);
    @Scheduled(cron = "0/30 * * * * ?")
    @SchedulerLock(name = "digitalEmpTaskScheduler", lockAtMostFor = "PT25S", lockAtLeastFor = "PT25S")
    protected void digitalEmpTaskScheduler() {
        log.info("云執行調度中心1:任務開始執行,時間:" + DateUtils.dateTimeNow(DateUtils.YYYY_MM_DD_HH_MM_SS));
        try { 
        } catch (Exception e) {
            log.error("云執行調度中心1調度失敗，原因：" + e.getMessage());
        }  
    }
}

    四、結果分析

    1.分別啟動兩個服務節點，配置如下：

    server:
      port: 12105
      servlet:
        context-path: /automation-quartz-one

    server:
      port: 12106
      servlet:
        context-path: /automation-quartz-two

    2.運行日志(片斷）

    節點automation-quartz-one 運行日志：
    2023-02-22 12:01:00.143 [taskExecutor-1] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:01:00
    2023-02-22 12:05:00.114 [taskExecutor-3] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:05:00
    2023-02-22 12:05:30.122 [taskExecutor-6] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:05:30
    2023-02-22 12:19:30.110 [taskExecutor-3] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:19:30

    節點automation-quartz-two運行日志：
    2023-02-22 12:01:30.109 [taskExecutor-3] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:01:30
    2023-02-22 12:02:00.101 [taskExecutor-1] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:02:00
    2023-02-22 12:02:30.105 [taskExecutor-2] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:02:30
    2023-02-22 12:03:00.118 [taskExecutor-3] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:03:00
    2023-02-22 12:03:30.101 [taskExecutor-4] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:03:30
    2023-02-22 12:04:00.110 [taskExecutor-1] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:04:00
    2023-02-22 12:04:30.111 [taskExecutor-5] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:04:30
    2023-02-22 12:06:00.114 [taskExecutor-13] INFO <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:06:00
    2023-02-22 12:06:30.108 [taskExecutor-14] INFO <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:06:30
    2023-02-22 12:07:00.114 [taskExecutor-15] INFO <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:07:00
    2023-02-22 12:07:30.115 [taskExecutor-1] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:07:30
    2023-02-22 12:08:00.102 [taskExecutor-5] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:08:00
    2023-02-22 12:08:30.103 [taskExecutor-11] INFO <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:08:30
    2023-02-22 12:09:00.099 [taskExecutor-6] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:09:00
    2023-02-22 12:09:30.113 [taskExecutor-3] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:09:30
    2023-02-22 12:10:00.107 [taskExecutor-7] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:10:00
    2023-02-22 12:10:30.110 [taskExecutor-15] INFO <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:10:30
    2023-02-22 12:11:00.111 [taskExecutor-1] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:11:00
    2023-02-22 12:11:30.100 [taskExecutor-5] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:11:30
    2023-02-22 12:12:00.112 [taskExecutor-11] INFO <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:12:00
    2023-02-22 12:12:30.102 [taskExecutor-6] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:12:30
    2023-02-22 12:13:00.097 [taskExecutor-3] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:13:00
    2023-02-22 12:13:30.107 [taskExecutor-14] INFO <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:13:30
    2023-02-22 12:14:00.111 [taskExecutor-4] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:14:00
    2023-02-22 12:14:30.106 [taskExecutor-8] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:14:30
    2023-02-22 12:15:00.095 [taskExecutor-9] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:15:00
    2023-02-22 12:15:30.101 [taskExecutor-10] INFO <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:15:30
    2023-02-22 12:16:00.105 [taskExecutor-2] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:16:00
    2023-02-22 12:16:30.130 [taskExecutor-12] INFO <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:16:30
    2023-02-22 12:17:00.107 [taskExecutor-13] INFO <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:17:00
    2023-02-22 12:17:30.113 [taskExecutor-7] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:17:30
    2023-02-22 12:18:00.104 [taskExecutor-15] INFO <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:18:00
    2023-02-22 12:18:30.112 [taskExecutor-1] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:18:30
    2023-02-22 12:19:00.103 [taskExecutor-5] INFO  <DigitalEmpTask:46> - 云執行調度中心1:任務開始執行,時間:2023-02-22 12:19:00

    3、shedlock表記錄信息：

    SpringBoot怎么集成ShedLock實現分布式定時任務

    讀到這里，這篇“SpringBoot怎么集成ShedLock實現分布式定時任務”文章已經介紹完畢，想要掌握這篇文章的知識點還需要大家自己動手實踐使用過才能領會，如果想了解更多相關內容的文章，歡迎關注億速云行業資訊頻道。

    向AI問一下細節

    免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。

    AI
    助
    手
    财经| 九龙城区| 泗阳县| 泰宁县| 永济市| 将乐县| 龙口市| 汝州市| 永州市| 东辽县| 昌都县| 靖西县| 莱阳市| 宁河县| 孝感市| 康平县| 汶川县| 含山县| 崇左市| 元阳县| 清水河县| 芦山县| 阜城县| 江北区| 富民县| 武乡县| 三河市| 海门市| 德安县| 团风县| 阳新县| 蒙阴县| 郁南县| 长汀县| 清水河县| 西青区| 乐都县| 黄石市| 中阳县| 丽江市| 永丰县|