干货分享：SpringBoot基于数据库实现简单的分布式锁

发布于 2019-08-08 | 作者: Java飞鱼 | 来源: 网易号 | 转载于: 网易号

本文介绍SpringBoot基于数据库实现简单的分布式锁。

一、简介

分布式锁的方式有很多种，通常方案有：

基于mysql数据库

基于redis

基于ZooKeeper

网上的实现方式有很多，本文主要介绍的是如果使用mysql实现简单的分布式锁，加锁流程如下图：

其实大致思想如下：

1.根据一个值来获取锁（也就是我这里的tag），如果当前不存在锁，那么在数据库插入一条记录，然后进行处理业务，当结束，释放锁（删除锁）。

2.如果存在锁，判断锁是否过期，如果过期则更新锁的有效期，然后继续处理业务，当结束时，释放锁。如果没有过期，那么获取锁失败，退出。

二、数据库设计

2.1 数据表介绍

数据库表是由JPA自动生成的，稍后会对实体进行介绍，内容如下：

其中：

id：主键

tag：锁的标示，以订单为例，可以锁订单id

expiration_time：过期时间

status：锁状态，0，未锁，1，已经上锁

三、实现

本文使用SpringBoot 2.0.3.RELEASE，MySQL 8.0.16，ORM层使用的JPA。

3.1 pom

新建项目，在项目中加入jpa和mysql依赖，完整内容如下：

3.2 配置文件

配置文件配置了一下数据库信息和jpa的基本配置，如下：

3.3 实体类

实体类如下，这里给tag字段设置了唯一索引，防止重复插入相同的数据：

3.4 repository

repository层只添加了两个简单的方法，根据tag查找锁和根据tag删除锁的操作，内容如下：

3.5 service

service接口定义了两个方法，获取锁和释放锁，内容如下：

实现类对上面方法进行了实现，其内容与上述流程图中一致，这里不在做介绍，完整内容如下：

3.6 测试类

创建了一个测试的controller进行测试，里面写了一个test方法，方法在获取锁的时候会sleep 2秒，便于我们进行测试。完整内容如下:

四、测试

项目使用maven打包，分别使用两个端口启动，分别是20000和20001。

java -jar springboot2_distributed_lock_mysql-0.0.1-SNAPSHOT.jar --server.port=20001java -jar springboot2_distributed_lock_mysql-0.0.1-SNAPSHOT.jar --server.port=20000

分别访问两个端口的项目，如图所示，只有一个请求可以获取锁。