分布式锁-Redis实现【黑马大数据培训】

  分布式锁

---

      synchronized 的原理 　　同步静态方法，锁的是当前 Class 对象。同步块，锁的是 {} 中的对象。 同步普通方法，锁的是当前对象。

---

　　Redis实现的分布式锁首先设置一个全局唯一的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   　　 对其解释： 根据 get 获取到 key 的值 ，判断key的值是否跟你传的值相等，相等则 执行del  key 否则返回0 结束 　　 对此推荐去看一下redis的Lua脚本，给个简单的：http://redisdoc.com/script/eval.html 　　在实际场景中可以利用AOP的切点切面形式，实现具体是什么地方需要分布式锁，搭配分布式锁，再搭配注解方式，来实现想要的自定义设置那里需要就点哪里 　　AOP的主要实现是 @pointcut 切注解类在使用@around环绕对前后做处理前面加锁后面解锁del  使用script脚本 　　

---

　　代码主要实现 　　注解类 DistributedLock [url=][/url] @Retention(RetentionPolicy.RUNTIME)@Target(ElementType.METHOD)@Documentedpublic @interface DistributedLock {    /**     * 自定义形式添加你对分布式锁的对外配置属性       * 例如：key的规则，锁的超时时间，获取锁的等待时间，等一系列的属性配置     *      */}[url=][/url] 　　切面类 DistributedLockAspect[url=][/url] @Aspect@Componentpublic 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);    }}}[url=][/url]