目的

变更日志

快速开始

需要

基于 MAP 的分布式锁

maven 引入

<dependency>    <groupId>com.github.houbb</groupId>    <artifactId>lock-core</artifactId>    <version>1.7.2</version></dependency>

入门例子

ILocklock =LockBs.newInstance();Stringkey ="ddd";try {// 加锁booleanlockFlag =lock.tryLock(key);Assert.assertTrue(lockFlag);}catch (Exceptione) {thrownewRuntimeException(e);}finally {// 释放锁lock.unlock(key);}

接口说明

接口方法文档

tryLock 方法说明

ILockContextlockContext =LockContext.newInstance()        .key(key)        .lockTime(LockConst.DEFAULT_LOCK_TIME)        .waitLockTime(LockConst.DEFAULT_WAIT_LOCK_TIME)        .reentrant(LockConst.DEFAULT_REENTRANT)        .timeUnit(LockConst.DEFAULT_TIME_UNIT);booleanlockFlag =lock.tryLock(lockContext);

锁的一些特性

锁的可重入性

可重入的例子

@TestpublicvoidreTest() {ILocklock =LockBs.newInstance();Stringkey ="ddd";try {// 加锁booleanlockFlag =lock.tryLock(key);//1. 首次获取锁成功Assert.assertTrue(lockFlag);//2. 重新获取锁成功booleanreLockFlag =lock.tryLock(key);Assert.assertTrue(reLockFlag);    }catch (Exceptione) {thrownewRuntimeException(e);    }finally {// 释放锁lock.unlock(key);    }}

不可重入的例子

publicvoidnoReTest() {ILocklock =LockBs.newInstance();Stringkey ="ddd";try {ILockContextlockContext =LockContext.newInstance()                .key(key)                .waitLockTime(5)                .reentrant(false);// 指定不可重入booleanlockFlag =lock.tryLock(lockContext);//1. 首次获取锁成功Assert.assertTrue(lockFlag);//2. 不是重入，第二次获取失败booleanreLockFlag =lock.tryLock(lockContext);Assert.assertFalse(reLockFlag);    }catch (Exceptione) {thrownewRuntimeException(e);    }finally {// 释放锁lock.unlock(key);    }}

配置化

LockBs.newInstance()        .id(Ids.uuid32())//id 生成策略        .cache(JedisRedisServiceFactory.pooled("127.0.0.1",6379))//缓存策略        .lockSupport(newRedisLockSupport())// 锁实现策略        .lockKeyFormat(newLockKeyFormat())// 针对 key 的格式化处理策略        .lockReleaseFailHandler(newLockReleaseFailHandler())//释放锁失败处理        ;

属性配置说明

整合 spring

maven 引入

<dependency>    <groupId>com.github.houbb</groupId>    <artifactId>lock-spring</artifactId>    <version>1.7.2</version></dependency>

指定 bean 使用

启用分布式锁

@Configurable@ComponentScan(basePackages = "com.github.houbb.lock.test.service")@EnableLock@EnableRedisConfigpublic class SpringConfig {}

@EnableLock 注解属性说明

使用 LockBs

@ContextConfiguration(classes =SpringConfig.class)@RunWith(SpringJUnit4ClassRunner.class)publicclassSpringServiceRawTest {@AutowiredprivateUserServiceuserService;@AutowiredprivateLockBslockBs;@TestpublicvoidqueryLogTest() {finalStringkey ="name";try {booleanlockFlag =lockBs.tryLock(key);finalStringvalue =userService.rawUserName(1L);        }catch (Exceptionexception) {thrownewRuntimeException(exception);        }finally {lockBs.unlock(key);        }    }}

aop 注解使用

指定方法注解

@ServicepublicclassUserService {@LockpublicStringqueryUserName(LonguserId) {    }@Lock(value ="#user.name")publicvoidqueryUserName2(Useruser) {    }}

@Lock 注解属性说明

spring boot 整合

maven 引入

<dependency>    <groupId>com.github.houbb</groupId>    <artifactId>lock-springboot-starter</artifactId>    <version>1.7.2</version></dependency>

使用

后期 Road-MAP

拓展阅读

开源矩阵