Nepxion Aquarius中Lock实现思路学习

本文涉及的产品
云数据库 Tair(兼容Redis),内存型 2GB
Redis 开源版,标准版 2GB
推荐场景:
搭建游戏排行榜
简介: Nepxion Aquarius中Lock实现思路学习

Nepxion Aquarius是一款基于Redis + Zookeeper的分布式应用组件集合,包含分布式锁,缓存,ID生成器,限速限流器。它采用Nepxion Matrix AOP框架进行切面架构,提供注解调用方式,也提供API调用方式。开源项目的地址:https://gitee.com/nepxion/Aquarius.git

lock的实现分为三类:普通锁、基于redission的分布式锁、基于zookeeper的分布式锁。分为三类:

一、基于Aop切面实现


1.需要先对需要执行的业务逻辑在接口添加注解

2.@Lock(name = "lock", key = "#id1 + "-" + #id2", leaseTime = 5000L, waitTime = 60000L, async = false, fair = false)

3.LockInterceptor锁拦截器会拦截带@Lock的注解,并且提取注解中带的相关属性信息

4.根据注解获取lock类型,使用spel表达式进行填充,然后基于当前的compositeKey

5.执行委托的invoke方法,此时需要执行tryLock和unlock操作

6.获取锁的过程实质是一个lock.tryLock的过程,而这个过程中,会首先会根据是否采用lock缓存来进行判断,如果使用lock缓存,则会首次从map中获取,否则创建一个新的lock,然后执行lock操作

7.可以看到创建新锁的时候,会根据传入的锁类型,进行创建,如果缓存中存在,则直接返回,否则创建新的lock

可以看到锁分类:普通锁、读锁、写锁

8.拿到之后,执行tryLock操作


二、基于Redission实现


1.借助LockExecutor调用tryLock执行lock操作。

2.此时首先会检查Redisson是否是启动状态

3.如果启动成功,则根据当前是否是异步还是同步lock,如果是同步,则获取RLock锁

4.如果开启了lock缓存,则从缓存中获取,如果缓存中不存在,则创建新的RLock,并将其放入到LockMap中

5.可以看到锁类型,此时分为公平锁、非公平锁、读锁、写锁类型,拿到之后,执行tryLock操作,可以看到此时的tryLock基于Redission的


三、基于zookeeper实现,实现的思路与前面redission实现类似,借助Delegate类,来实现调用LockExecutorImpl,从而实现tryLock操作。


三种实现的本质是实现对lock对象key的锁定。同时相比于其他实现,项目中的亮点是基于锁的粒度要更加细化,可以读锁和写锁实现分布式锁。

基于上面的实现思路,作者使用切面或者调用redis类似实现了limit限流的操作。

代码的具体实现可以参考开源项目:https://gitee.com/nepxion/Aquarius.git

相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore     ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库 ECS 实例和一台目标数据库 RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
目录
相关文章
|
2月前
|
安全 Java 开发者
Lock锁和AQS之间的关系与区别:基于第一原理的深入分析
【11月更文挑战第26天】在Java并发编程中,锁(Lock)和队列同步器(AbstractQueuedSynchronizer,简称AQS)是两个核心概念。它们为多线程环境下的同步和互斥提供了强大的支持。本文将从第一原理出发,深入探讨Lock锁和AQS之间的关系与区别,同时分析它们的相关概念、业务场景、历史背景、功能点以及底层原理,并使用Java代码进行模拟实现。
29 1
|
5月前
|
Java 测试技术
Java多线程同步实战:从synchronized到Lock的进化之路!
Java多线程同步实战:从synchronized到Lock的进化之路!
109 1
|
5月前
|
Java
【多线程面试题十三】、说一说synchronized与Lock的区别
这篇文章讨论了Java中`synchronized`和`Lock`接口在多线程编程中的区别,包括它们在实现、使用、锁的释放、超时设置、锁状态查询以及锁的属性等方面的不同点。
|
7月前
|
Python
Python多线程中递归锁如何解决死锁问题的详细阐述
Python多线程中递归锁如何解决死锁问题的详细阐述
|
8月前
|
安全 Java 程序员
【Java多线程】面试常考——锁策略、synchronized的锁升级优化过程以及CAS(Compare and swap)
【Java多线程】面试常考——锁策略、synchronized的锁升级优化过程以及CAS(Compare and swap)
72 0
|
8月前
|
安全 Python
Lock的学习与使用
Lock的学习与使用 在多线程编程中,为了保证线程之间的同步,经常需要使用锁。在Python中,可以通过Lock对象来实现线程的同步。
|
存储 安全 Java
大白话讲解synchronized锁升级套路
synchronized锁是啥?锁其实就是一个对象,随便哪一个都可以,Java中所有的对象都是锁,换句话说,Java中所有对象都可以成为锁。 这次我们主要聊的是synchronized锁升级的套路
135 0
|
安全 Java 调度
72. 对并发熟悉吗?说一下synchronized与Lock的区别与使用
72. 对并发熟悉吗?说一下synchronized与Lock的区别与使用
85 0
72. 对并发熟悉吗?说一下synchronized与Lock的区别与使用
synchronized锁升级原理剖析 ✨ 每日积累
synchronized锁升级原理剖析 ✨ 每日积累
synchronized锁升级原理剖析 ✨ 每日积累
|
存储 安全 Java
不懂什么是锁?看看这篇你就明白了(三)
Java 中的锁有很多,可以按照不同的功能、种类进行分类,下面是我对 Java 中一些常用锁的分类,包括一些基本的概述
96 0
不懂什么是锁?看看这篇你就明白了(三)