ICode9

精准搜索请尝试: 精确搜索
首页 > 数据库> 文章详细

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

2019-07-19 22:03:18  阅读:210  来源: 互联网

标签:SpringBoot jar 数据库 tag 如下 干货 mysql 分布式


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

一.简介

分布式锁的方式有很多种,通常方案有:

  • 基于mysql数据库
  • 基于redis
  • 基于ZooKeeper

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

 

其实大致思想如下:

  • 1.根据一个值来获取锁(也就是我这里的tag),如果当前不存在锁,那么在数据库插入一条记录,然后进行处理业务,当结束,释放锁(删除锁)。
  • 2.如果存在锁,判断锁是否过期,如果过期则更新锁的有效期,然后继续处理业务,当结束时,释放锁。如果没有过期,那么获取锁失败,退出。
  • JAVA高级架构圈子

二、数据库设计

2.1 数据表介绍

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

 

其中:

  • id:主键
  • tag:锁的标示,以订单为例,可以锁订单id
  • expiration_time:过期时间
  • status:锁状态,0,未锁,1,已经上锁
  • JAVA高级架构圈子

三、.实现

本文使用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=20001 java -jar springboot2_distributed_lock_mysql-0.0.1-SNAPSHOT.jar --server.port=20000 

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

 

 

五、总结

本案例实现的分布式锁只是一个简单的实现方案,还具备很多问题,不适合生产环境使用。

粉丝福利

 

以上技术可以加入JAVA高级架构圈子里面有阿里,百度,点评,架构师直播指导,针对工作1--5的Java程序员提升自己,还有架构学习资料,jvm,手写springmvc,分布式,高可用,高性能,数据结构,springcloud,springboot 获取。
 

标签:SpringBoot,jar,数据库,tag,如下,干货,mysql,分布式
来源: https://blog.csdn.net/qq_39662660/article/details/96503182

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有