分布式锁原理的详细剖析-下
在上篇文章中我们接受了分布式锁的切面实现的全部过程，而在本文中，本人将接着介绍分布式锁的方法级别的实现过程
依旧从自动装配作为入口来分析
ServiceLockAutoConfiguration
public class ServiceLockAutoConfiguration {
/**
* 分布式锁的key解析处理器
* */
@Bean(LockInfoType.SERVICE_LOCK)
public LockInfoHandle serviceLockInfoHandle(){
return new ServiceLockInfoHandle();
}
/**
* 锁管理
* */
@Bean
public ManageLocker manageLocker(RedissonClient redissonClient){
return new ManageLocker(redissonClient);
}
/**
* 锁工厂
* */
@Bean
public ServiceLockFactory serviceLockFactory(ManageLocker manageLocker){
return new ServiceLockFactory(manageLocker);
}
/**
* 分布式锁切面
* */
@Bean
public ServiceLockAspect serviceLockAspect(LockInfoHandleFactory lockInfoHandleFactory,ServiceLockFactory serviceLockFactory){
return new ServiceLockAspect(lockInfoHandleFactory,serviceLockFactory);
}
/**
* 分布式锁工具
* */
@Bean
public ServiceLockTool serviceLockUtil(LockInfoHandleFactory lockInfoHandleFactory,ServiceLockFactory serviceLockFactory){
return new ServiceLockTool(lockInfoHandleFactory,serviceLockFactory);
}
}
ServiceLockAutoConfiguration 是自动装配类，加载了 分布式锁的key解析处理器、分布式锁工厂、分布式锁切面、分布式锁工具的对象，而这个分布式锁工具 就是方法级别操作的api
ServiceLockTool
@AllArgsConstructor
public class ServiceLockTool {
private final LockInfoHandleFactory lockInfoHandleFactory;
private final ServiceLockFactory serviceLockFactory;
/**
* 没有返回值的加锁执行
* @param taskRun 要执行的任务
* @param name 锁的业务名
* @param keys 锁的标识
*
* */
public void execute(TaskRun taskRun,String name,String [] keys) {
execute(taskRun,name,keys,20);
}
/**
* 没有返回值的加锁执行
* @param taskRun 要执行的任务
* @param name 锁的业务名
* @param keys 锁的标识
* @param waitTime 等待时间
*
* */
public void execute(TaskRun taskRun,String name,String [] keys,long waitTime){
execute(LockType.Reentrant,taskRun,name,keys,waitTime);
}
/**
* 没有返回值的加锁执行
* @param lockType 锁类型
* @param taskRun 要执行的任务
* @param name 锁的业务名
* @param keys 锁的标识
*
* */
public void execute(LockType lockType,TaskRun taskRun,String name,String [] keys) {
execute(lockType,taskRun,name,keys,20);
}
/**
* 没有返回值的加锁执行
* @param lockType 锁类型
* @param taskRun 要执行的任务
* @param name 锁的业务名
* @param keys 锁的标识
* @param waitTime 等待时间
*
* */
public void execute(LockType lockType,TaskRun taskRun,String name,String [] keys,long waitTime) {
LockInfoHandle lockInfoHandle = lockInfoHandleFactory.getLockInfoHandle(LockInfoType.SERVICE_LOCK);
String lockName = lockInfoHandle.simpleGetLockName(name,keys);
ServiceLocker lock = serviceLockFactory.getLock(lockType);
boolean result = lock.tryLock(lockName, TimeUnit.SECONDS, waitTime);
if (result) {
try {
taskRun.run();
}finally {
lock.unlock(lockName);
}
}else {
LockTimeOutStrategy.FAIL.handler(lockName);
}
}
/**
* 有返回值的加锁执行
* @param taskCall 要执行的任务
* @param name 锁的业务名
* @param keys 锁的标识
* @return 要执行的任务的返回值
* */
public <T> T submit(TaskCall<T> taskCall,String name,String [] keys){
LockInfoHandle lockInfoHandle = lockInfoHandleFactory.getLockInfoHandle(LockInfoType.SERVICE_LOCK);
String lockName = lockInfoHandle.simpleGetLockName(name,keys);
ServiceLocker lock = serviceLockFactory.getLock(LockType.Reentrant);
boolean result = lock.tryLock(lockName, TimeUnit.SECONDS, 30);
if (result) {
try {
return taskCall.call();
}finally {
lock.unlock(lockName);
}
}else {
LockTimeOutStrategy.FAIL.handler(lockName);
}
return null;
}
/**
* 获得锁
* @param lockType 锁类型
* @param name 锁的业务名
* @param keys 锁的标识
*
* */
public RLock getLock(LockType lockType, String name, String [] keys) {
LockInfoHandle lockInfoHandle = lockInfoHandleFactory.getLockInfoHandle(LockInfoType.SERVICE_LOCK);
String lockName = lockInfoHandle.simpleGetLockName(name,keys);
ServiceLocker lock = serviceLockFactory.getLock(lockType);
return lock.getLock(lockName);
}
/**
* 获得锁
* @param lockType 锁类型
* @param lockName 锁名
*
* */
public RLock getLock(LockType lockType, String lockName) {
ServiceLocker lock = serviceLockFactory.getLock(lockType);
return lock.getLock(lockName);
}
}
付费内容提示
该文档的全部内容仅对「JavaUp项目实战&技术讲解」知识星球用户开放
加入星球后，你可以获得：
- 超级八股文：100万+字的全栈技术知识库，涵盖技术核心、数据库、中间件、分布式等深度剖析的讲解
- 讲解文档：黑马点评Plus、大麦、大麦pro、大麦AI、流量切换、数据中台的从0到1的550+详细文档
- 讲解视频：黑马点评Plus、大麦、大麦pro、大麦AI、流量切换、数据中台的核心业务详细讲解
- 1 对 1 解答：可以对我进行1对1的问题提问，而不仅仅只限于项目
- 针对性服务：有没理解的地方，文档或者视频还没有讲到可以提出，本人会补充
- 面试与简历指导：提供面试回答技巧，项目怎样写才能在简历中具有独特的亮点
- 中间件环境：对于项目中需要使用的中间件，可直接替换成我提供的云环境
- 面试后复盘：小伙伴去面试后，如果哪里被面试官问住了，可以再找我解答
- 远程的解决：如果在启动项目遇到问题，本人可以帮你远程解决
进入星球后，即可享受上述所有服务，保证不会再有其他隐藏费用。
