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

目录
相关文章
FeignClient打印请求失败的日志,打印所有feignCliet接口请求失败的错误日志,方便排查原因
FeignClient打印请求失败的日志,打印所有feignCliet接口请求失败的错误日志,方便排查原因
362 0
|
Java 应用服务中间件 Android开发
IDEA 编译时 报 “常量字符串过长” 解决办法
IDEA 编译时 报 “常量字符串过长” 解决办法
3321 0
|
10月前
|
关系型数据库 MySQL API
|
9月前
|
JSON API 开发工具
淘宝实时 API 接口丨淘宝商品详情接口(Taobao.item_get)
淘宝商品详情接口(Taobao.item_get)允许开发者获取商品的详细信息,包括基本信息、描述、卖家资料、图片、属性及销售情况等。开发者需注册账号、创建应用并获取API密钥,通过构建请求获取JSON格式数据,注意遵守平台规则,合理使用接口,确保数据准确性和时效性。
1062 9
ly~
|
12月前
|
传感器 存储 供应链
大数据在供应链管理中的具体应用案例
以下是大数据在供应链管理中的具体应用案例:沃尔玛通过整合内外部数据进行需求预测,提前调配应急物资;亚马逊利用大数据优化库存管理,提高周转率并降低成本;DHL通过传感器收集数据优化物流路线,提升运输效率。大数据的优势在于提高需求预测准确性、优化库存管理、提升物流效率、增强供应商管理和提高供应链可视性,从而实现全方位的供应链优化。
ly~
2811 2
|
移动开发 JavaScript 小程序
uView NoNetwork 无网络提示
uView NoNetwork 无网络提示
135 0
|
人工智能 IDE Java
Copilot在IDEA中的应用:提升编码效率的得力助手
Copilot在IDEA中的应用:提升编码效率的得力助手
2401 3
springboot WebMvcConfigurer详解自定义配置请求静态资源
springboot WebMvcConfigurer详解自定义配置请求静态资源
311 0
|
XML 前端开发 Java
Spring高手之路2——深入理解注解驱动配置与XML配置的融合与区别
本文旨在深入探讨Spring框架的注解驱动配置与XML配置,揭示两者之间的相似性与差异。我们首先介绍了配置类的编写与Bean的注册,然后比较了注解驱动的IOC依赖注入与XML依赖注入。文章进一步解析了Spring的组件注册与组件扫描,包括使用@ComponentScan和XML启用component-scan的情况,以及不使用@ComponentScan的场景。接下来,我们深入探讨了其他相关的组件注册注解。最后,我们展示了如何将注解驱动的配置与XML驱动的配置结合使用,并通过思考总结部分提出了一些重要的问题
321 1
Spring高手之路2——深入理解注解驱动配置与XML配置的融合与区别
|
JSON 应用服务中间件 nginx
在Nginx日志中记录请求的header和请求body
在Nginx日志中记录请求的header和请求body
1372 0

热门文章

最新文章