分布式锁----Redis实现
分布式锁
为什么需要有分布式锁呢,在单点的时候synchronized 就能解决,但是服务拆分之后,每个服务都是单独的机器,无法解决,所以出现了分布式锁,其实也就是用各种手段,实现获取唯一锁,别人无法得到。
其实在做分布式锁的前提,需要先明白,synchronized 为啥不能使用了,啥原理让他在一个机器上可以使用。
synchronized 的原理
众所周知 Synchronize
关键字是解决并发问题常用解决方案,有以下三种使用方式:
- 同步静态方法,锁的是当前
Class
对象。 - 同步块,锁的是
{}
中的对象。 - 同步普通方法,锁的是当前对象。
实现原理:
JVM
是通过进入、退出对象监视器( Monitor
)来实现对方法、同步块的同步的。
具体实现是在编译之后在同步方法调用前加入一个 monitor.enter
指令,在退出方法和异常处插入 monitor.exit
的指令。
其本质就是对一个对象监视器( Monitor
)进行获取,而这个获取过程具有排他性从而达到了同一时刻只能一个线程访问的目的。
而对于没有获取到锁的线程将会阻塞到方法入口处,直到获取锁的线程 monitor.exit
之后才能尝试继续获取锁。
可以通过使用 javap -c Synchronize
可以查看编译之后的具体信息 ,这里我就不再粘贴了。
所以可以知道,单独的Java虚拟机是可实现锁的,但是多台手就伸不到了,只能在依赖外部的形式去产生一个唯一锁。
以上是参考别人的博客拿到的信息,亲自试用得到,准确 :链接:https://www.jianshu.com/p/2ba154f275ea
Redis实现的分布式锁
主要是利用了redis的set NX的原理,以及对redis的script脚本原子性利用。(个人看法,其实后面一步就看各自的程序逻辑如何去判定到底要不要这一步了)
简单的说一下主要流程:
- 首先设置一个全局唯一的key和一个唯一性的value(value是一个解锁的保障,删除之前判断一下值是否一致)
- 使用Redis的set 方法 以多参数形式配置key,value,nx,px,过期时间 (参数 NX:只有键不存在时,才能对其进行设置操作)
- 利用Redis的script脚本来对key的删除操作,只能自己删除自己的value(删除之前先判断一下value是否是我之前的value,是否被改过,没有就删了)
这是脚本的主要 内容 if redis.call("get",KEYS[1]) == ARGV[1] then return redis.call("del",KEYS[1]) else return 0 end
- @pointcut 切注解类
- 在使用@around环绕对前后做处理
- 前面加锁
- 后面解锁del 使用script脚本
代码主要实现
注解类 DistributedLock
@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
@Documented
public @interface DistributedLock { /**
* 自定义形式添加你对分布式锁的对外配置属性
* 例如:key的规则,锁的超时时间,获取锁的等待时间,等一系列的属性配置
*
*/ }
切面类 DistributedLockAspect
@Aspect
@Component
public class DistributedLockAspect { /**
* 层切点
*/
@Pointcut("@annotation(com.creditease.hardess.common.annotation.DistributedLock)")
public void distributedLockAspect() {} /**
* @param joinPoint 切点
* @return Object 添加分布式锁后,实际调用业务逻辑部分代码的返回值
* @throws Throwable 产生的所有异常,为了避免对异常处理流程产生干扰,所有异常都应该继续抛出
*/
@Around("distributedLockAspect()")
public Object doAround(ProceedingJoinPoint joinPoint) throws Throwable {
/**
*主要写一些锁的获取,和业务逻辑执行,锁的删除等
*
*/
return returnObject;
} /**
* 获取 DistributedLock 注解
*
* @param joinPoint
* @return 代码中定义的注解
* @throws NoSuchMethodException
*/
private static DistributedLock getDistributedLock(ProceedingJoinPoint joinPoint)
throws NoSuchMethodException {
String methodName = joinPoint.getSignature().getName(); Class<?> classTarget = joinPoint.getTarget().getClass();
Class<?>[] par = ((MethodSignature) joinPoint.getSignature()).getParameterTypes();
Method objMethod = classTarget.getMethod(methodName, par); return objMethod.getAnnotation(DistributedLock.class);
} } }
最新文章
- Mysql - 增删改
- JAVA WEB WITH IDEA
- 前端学PHP之数据类型
- 支付宝Payto接口的C#.net实现方法
- RCP:如何移除Search对话框中不需要的项
- UVa 107 - The Cat in the Hat (找规律,注意精度)
- win7录屏工具
- android参考
- hdu 2211
- 使用CSS3+jquery.js 实现微信抽奖转盘效果
- 希腊字母、拉丁字母、Markdown、拼写与读音中英对照表
- VB中的GDI编程-2 画笔
- Android系统--输入系统(十二)Dispatch线程_总体框架
- VMware Mac OS中无法找到适应的分辨率的解决办法
- 工厂模式的进阶复习(Factory)
- python3 模拟鼠标和键盘操作
- Maven项目强制更新,解决Failed to read artifact descriptor for xxx.jar问题
- Maven中央仓库地址整理
- ssh服务器配置
- Red Hat 5.8 CentOS 6.5 共用 输入法
热门文章
- IIS6利用URLScan修复IIS短文件名漏洞
- SPOJ1421_Goods_循环节
- 对新数据库使用 Code First
- Java中常用的url签名防篡改方法
- WPF基于3D对象捕获鼠标点击事件
- 系统学习 Java IO (十四)----字符读写缓存和回退 BufferedReader/BufferedWriter &; PushbackReader
- java创建对象的方式
- PATA 1009. Product of Polynomials (25)
- Python生成word
- 苹果二代TWS无线耳机AirPods调研