这篇文章给大家分享的是有关怎么使用Spring Boot集成ShedLock分布式定时任务的内容。小编觉得挺实用的,因此分享给大家做个参考,一起跟随小编过来看看吧。
一、ShedLock是什么?
以下是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);
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); }}
1.7 执行成功分析
可以看到两个任务交替执行,并且我们的count每次自加1都是有序的。但是这里说明一下ShedLock是单线程执行的。
1.8 修改表名
shedLock支持关系型数据库,以mysql为例,配置mysql以及表名;shedLock默认表名为shedlock,可以设置自定义表名。
核心思想:通过对公用的数据库中的某个表进行记录和加锁,使得同一时间点只有第一个执行定时任务并成功在数据库表中写入相应记录的节点能够成功执行而其他节点直接跳过该任务。
springboot是什么
springboot一种全新的编程规范,其设计目的是用来简化新Spring应用的初始搭建以及开发过程,SpringBoot也是一个服务于框架的框架,服务范围是简化配置文件。
感谢各位的阅读!关于“怎么使用Spring Boot集成ShedLock分布式定时任务”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,让大家可以学到更多知识,如果觉得文章不错,可以把它分享出去让更多的人看到吧!