基于redissonzookeeper实现的分布式锁kyli

　　1、简介1。1、开源项目kylinlock：麒麟分布式锁支持redisson、zookeeper重入锁、读写锁、联锁、红锁、公平锁
　　已上传jar到中央仓库，可直接引入依赖1。2、介绍支持redisson、zookeeper分布式锁redisson支持重入锁、读写锁、联锁、红锁、公平锁zookeeper支持重入锁、不可重入锁、读写锁、联锁支持注解、方法调用、函数式编程等方式加锁支持多注解，对同一方法加不同的锁锁的key支持SpEL表达式支持自定义全局、方法级加锁失败回调方法级失败回调：方法名、参数类型列表相同，支持相同类型的返回1。3分布式锁注解KylinLock字段使用说明name：锁的key一部分，为空则会使用：包名。类名。方法名keys：锁的key一部分支持SpEL表达式，锁的keyprefix：namekeysexpire：过期时间单位：毫秒acquireTimeout：获取锁超时时间单位：毫秒executor：锁执行器lockType：锁类型，默认重入锁keySuffix：联锁、红锁个数以及其中每个锁的后缀key，默认：｛1，2，3｝，支持SpEL表达式lockFailure：加锁失败回调类2、使用说明2。1、引入依赖dependencygroupIdcom。gitee。wangjkuigroupIdkylinlockspringbootstarterartifactIdversionLatestVersionversiondependency2。2、配置2。2。1、application。ymlspring：redis：redisson：file：classpath：redisson。yml分布式锁kylin：lock：acquiretimeout：3000获取锁超时时间默认值3000L单位：毫秒expire：30000过期时间，默认值30000L单位：毫秒retryinterval：100获取锁失败时重试时间间隔，默认值100L单位：毫秒lockkeyprefix：kylinlock锁前缀默认配置primaryexecutor：com。wjk。kylin。lock。executor。redisson。RedissonLockExecutor默认执行器。默认redissonzookeeperredisson：true是否开启redisson默认truezookeeper：zkservers：127。0。0。1：2181zk的server地址，多个server之间使用英文逗号分隔开。配置地址则开启zookeepersessiontimeout：60000会话超时时间，默认值60000单位：毫秒connectiontimeout：15000连接超时时间，默认值15000单位：毫秒basesleeptimems：5000初始sleep时间，默认值5000单位：毫秒maxretries：3最大失败重试次数namespace：curatorkylinlock命名空间2。2。2、redisson。yml单节点配置singleServerConfig：连接空闲超时，单位：毫秒idleConnectionTimeout：10000连接超时，单位：毫秒connectTimeout：10000命令等待超时，单位：毫秒timeout：3000命令失败重试次数，如果尝试达到retryAttempts（命令失败重试次数）仍然不能将命令发送至某个指定的节点时，将抛出错误。如果尝试在此限制之内发送成功，则开始启用timeout（命令等待超时）计时。retryAttempts：3命令重试发送时间间隔，单位：毫秒retryInterval：1500密码password：redis123单个连接最大订阅数量subscriptionsPerConnection：5客户端名称clientName：axin节点地址address：redis：127。0。0。1：6379发布和订阅连接的最小空闲连接数subscriptionConnectionMinimumIdleSize：1发布和订阅连接池大小subscriptionConnectionPoolSize：50最小空闲连接数connectionMinimumIdleSize：32连接池大小connectionPoolSize：64数据库编号database：2DNS监测时间间隔，单位：毫秒dnsMonitoringInterval：5000线程池数量，默认值：当前处理核数量2threads：0Netty线程池数量，默认值：当前处理核数量2nettyThreads：0编码codec：！org。redisson。codec。JsonJacksonCodec｛｝传输模式transportMode：NIO2。3、使用案例2。3。1、重入锁KylinLock（namereentrantkey，expire60000）publicvoiddemoMethod2（）｛System。out。println（demoMethod2startgetClass（））；try｛Thread。sleep（4000）；｝catch（InterruptedExceptione）｛e。printStackTrace（）；｝重入锁indexService。demoMethod2（）；System。out。println（demoMethod2endgetClass（））；｝2。3。2、读写锁OverrideKylinLock（namereadwrite，acquireTimeout0，lockTypeLockType。READ）publicvoidread1（Stringkey）｛try｛Thread。sleep（5000）；｝catch（InterruptedExceptione）｛e。printStackTrace（）；｝System。out。println（执行方法read1，当前线程：Thread。currentThread（）。getName（）threadId：Thread。currentThread（）。getId（））；｝2。3。3、联锁KylinLock（lockTypeLockType。MULTI）publicvoiddemoMethod6（）｛System。out。println（demoMethod6startgetClass（））；try｛Thread。sleep（40000）；｝catch（InterruptedExceptione）｛e。printStackTrace（）；｝System。out。println（demoMethod6endgetClass（））；｝2。3。4、红锁KylinLock（lockTypeLockType。RED，keySuffix｛user。id，red2｝，executorRedissonLockExecutor。class）publicvoiddemoMethod11（Useruser）｛System。out。println（demoMethod11startgetClass（））；try｛Thread。sleep（40000）；｝catch（InterruptedExceptione）｛e。printStackTrace（）；｝System。out。println（demoMethod11id：user。getId（），name：user。getName（））；｝2。3。5、公平锁KylinLock（namefairlockkey，lockTypeLockType。FAIR，executorRedissonLockExecutor。class）publicvoiddemoMethod8（）｛System。out。println（demoMethod8startgetClass（））；try｛Thread。sleep（4000）；｝catch（InterruptedExceptione）｛e。printStackTrace（）；｝indexService。demoMethod8（）；System。out。println（demoMethod8endgetClass（））；｝2。3。6、多注解KylinLock（namereentrantkey1，expire60000）KylinLock（namereentrantkey2，expire60000）KylinLock（namereentrantkey3，expire60000）publicvoiddemoMethod3（）｛System。out。println（demoMethod3startgetClass（））；try｛Thread。sleep（4000）；｝catch（InterruptedExceptione）｛e。printStackTrace（）；｝System。out。println（demoMethod3endgetClass（））；｝2。3。7、函数式编程publicvoidexecute1（Stringkey）｛IntegernumlockTemplate。execute（key，IndexServiceImpl：：getNumber）；System。out。println（执行execute方法1，当前线程：Thread。currentThread（）。getName（），获取的返回值是：num）；｝publicstaticIntegergetNumber（）｛try｛Thread。sleep（40000）；｝catch（InterruptedExceptione）｛e。printStackTrace（）；｝System。out。println（执行getNumber方法，当前线程：Thread。currentThread（）。getName（））；return1；｝2。3。8、自定义加锁失败执行方法加锁失败，会调用DemoLockFailureCallBack中方法名称、参数类型列表相同的方法KylinLock（acquireTimeout0，lockFailureDemoLockFailureCallBack。class）publicIntegerdemoMethod14（Integernum）｛System。out。println（demoMethod12start，num：num）；try｛Thread。sleep（4000）；｝catch（InterruptedExceptione）｛e。printStackTrace（）；｝System。out。println（demoMethod12end，num：num）；returnnum2；｝Slf4jComponentpublicclassDemoLockFailureCallBackimplementsLockFailureCallBack｛方法名称、参数类型列表相同publicIntegerdemoMethod14（Integernum）｛log。error（demoMethod14方法自定义失败回调，入参num：｛｝，num）；return1；｝｝