位置：首页-资讯-后端开发

怎么使用Spring Boot集成ShedLock分布式定时任务

2023-06-15 05:01

短信预约 -IT技能 免费直播动态提醒

这篇文章给大家分享的是有关怎么使用Spring Boot集成ShedLock分布式定时任务的内容。小编觉得挺实用的，因此分享给大家做个参考，一起跟随小编过来看看吧。

一、ShedLock是什么？

以下是ShedLock锁提供者，通过外部存储实现锁，由下图可知外部存储集成的库还是很丰富的

怎么使用Spring Boot集成ShedLock分布式定时任务

本篇教程我们基于JdbcTemplate存储为例来使用ShedLock锁。

二、落地实现

1.1 引入依赖包

shedlock所需依赖包：

<dependency>    <groupId>net.javacrumbs.shedlock</groupId>    <artifactId>shedlock-spring</artifactId>    <version>4.23.0</version></dependency> <!--每个外部存储实例所需依赖包不一样，这里是jdbc--><dependency>    <groupId>net.javacrumbs.shedlock</groupId>    <artifactId>shedlock-provider-jdbc-template</artifactId>    <version>4.23.0</version></dependency>

JdbcTemplate依赖包：

<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>

web工程依赖包：

<dependency>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-web</artifactId></dependency>

1.2 配置数据库连接信息

server:  port: 9999spring:  datasource:    url: jdbc:mysql://192.168.31.158: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数据表

# MySQL, MariaDBCREATE TABLE shedlock(name VARCHAR(64) NOT NULL, lock_until TIMESTAMP(3) NOT NULL,    locked_at TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP(3), locked_by VARCHAR(255) NOT NULL, PRIMARY KEY (name));# PostgresCREATE TABLE shedlock(name VARCHAR(64) NOT NULL, lock_until TIMESTAMP NOT NULL,    locked_at TIMESTAMP NOT NULL, locked_by VARCHAR(255) NOT NULL, PRIMARY KEY (name));# OracleCREATE TABLE shedlock(name VARCHAR(64) NOT NULL, lock_until TIMESTAMP(3) NOT NULL,    locked_at TIMESTAMP(3) NOT NULL, locked_by VARCHAR(255) NOT NULL, PRIMARY KEY (name));# MS SQLCREATE TABLE shedlock(name VARCHAR(64) NOT NULL, lock_until datetime2 NOT NULL,    locked_at datetime2 NOT NULL, locked_by VARCHAR(255) NOT NULL, PRIMARY KEY (name));# DB2CREATE TABLE shedlock(name VARCHAR(64) NOT NULL PRIMARY KEY, lock_until TIMESTAMP NOT NULL,    locked_at TIMESTAMP NOT NULL, locked_by VARCHAR(255) NOT NULL);

怎么使用Spring Boot集成ShedLock分布式定时任务

1.4 配置LockProvider

// 标识该类为配置类@Configuration// //开启定时器@EnableScheduling// 开启定时任务锁，指定一个默认的锁的时间30秒@EnableSchedulerLock(defaultLockAtMostFor = "PT30S")public class ShedlockJdbcConfig {        @Bean    public LockProvider lockProvider(DataSource dataSource) {        return new JdbcTemplateLockProvider(                JdbcTemplateLockProvider.Configuration.builder()                        .withJdbcTemplate(new JdbcTemplate(dataSource))                        .usingDbTime()                        .build()        );    }}

1.5 创建定时Job

@Component@CommonsLogpublic class TimeTaskJob {    private static Integer count = 1;    // @SchedulerLock的作用是保证当前定时任务的方法执行时获得锁，忽略其他相同任务的执行    // name必须要指定，ShedLock就是根据这个name进行相同任务判定的    // name：定时任务的名字，就是数据库中的主键(name)    // lockAtMostFor：锁的最大时间单位为毫秒    // lockAtLeastFor：锁的最小时间单位为毫秒        @Scheduled(cron = "0/5 * * * * ? ")    @SchedulerLock(name = "testJob1",lockAtLeastFor = "20000", lockAtMostFor = "30000")    public void scheduledTask1() {        log.info(Thread.currentThread().getName() + "->>>任务1执行第：" + (count++) + "次");    }        @Scheduled(cron = "0/5 * * * * ? ")    @SchedulerLock(name = "testJob2")    public void scheduledTask2() {        log.info(Thread.currentThread().getName() + "->>>任务2执行第：" + (count++) + "次");    }}

1.6 主启动类

@SpringBootApplicationpublic class JdbcApplication {    public static void main(String[] args) {         SpringApplication.run(JdbcApplication.class, args);    }}