redisson特性及优雅实现示例

目录

redisson的几大特性

可重入性阻塞能力续约

初始化timer的代码

redisson的几大特性

相信看了这个标题的同学，对这个问题以已经非常不陌生了，信手拈来redisson的几大特性：

可重入性

【多个业务线同一时刻n条扣款，如果用setnx，我怎么监控的加锁解锁线程？死锁不得发生呐？】
redisson使用hash结构，业务名称作为key,uuid+线程id作为field，加锁次数作为value，这不就解决上述问题了吗

阻塞能力

【加锁有两个策略，一是互斥，二是阻塞。互斥比如说定时任务，同一时刻我需要只执行一次就行。阻塞的话-例如多个业务线同一时刻n条扣款，我不能互斥掉吧，那不得被喷死。我得写个while死循环【标准用语就是自旋】一段时间在获取一次，保证系统都能处理这些请求】

续约

加锁过期时间短-加锁逻辑还没执行完就解锁了是不是很尴尬，过长的话-宕机恢复时间又变长
redisson默认30秒给你执行，30秒没执行完就续约30s，宕机的话恢复时间也不会太长。
原理呢就是使用了netty的时间轮实现。简单点说就是环形数组。
直通车：

1. RedissonLock --> renewExpiration -->TimerTask
2. Timeout task = commandExecutor.getConnectionManager().newTimeout(new TimerTask() {
3.     @Override
4.     public void run(Timeout timeout) throws Exception {
5.         ExpirationEntry ent = EXPIRATION_RENEWAL_MAP.get(getEntryName());
6.         if (ent == null) {
7.             return;
8.         }
9.         Long threadId = ent.getFirstThreadId();
10.         if (threadId == null) {
11.             return;
12.         }
13.         RFuture<Boolean> future = renewExpirationAsync(threadId);
14.         future.onComplete((res, e) -> {
15.             if (e != null) {
16.                 log.error("Can't update lock " + getName() + " expiration", e);
17.                 return;
18.             }
19.             if (res) {
20.                 // reschedule itself
21.                 renewExpiration();
22.             }
23.         });
24.     }
25. }, internalLockLeaseTime / 3, TimeUnit.MILLISECONDS);
26. // internalLockLeaseTime默认30s，因此这里默认延迟10s后执行
27. // 其中TimerTask引用的就是netty中的TimerTask

复制代码

初始化timer的代码

1. protected void initTimer(MasterSlaveServersConfig config) {
2.     int[] timeouts = new int[]{config.getRetryInterval(), config.getTimeout()};
3.     Arrays.sort(timeouts);
4.     int minTimeout = timeouts[0];
5.     if (minTimeout % 100 != 0) {
6.         minTimeout = (minTimeout % 100) / 2;
7.     } else if (minTimeout == 100) {
8.         minTimeout = 50;
9.     } else {
10.         minTimeout = 100;
11.     }
12.     // 就是分成了1024个格子，每个格子默认100ms
13.     timer = new HashedWheelTimer(new DefaultThreadFactory("redisson-timer"), minTimeout, TimeUnit.MILLISECONDS, 1024, false);
14.     connectionWatcher = new IdleConnectionWatcher(this, config);
15.     subscribeService = new PublishSubscribeService(this, config);
16. }

复制代码

大白话讲就是：例如将一个圆分成4等分，1，2，3，4，从1到2需要100ms，那么我需要计算延迟500ms需要走几步，下标是多少？
既然是时间总要跳动嘛，没猜错就是sleep

红锁

如果redis节点宕机大部分节点同意获取锁，才能获取到锁。

联锁

全部节点加锁成功才算加锁成功。

加锁流程

lua判断锁是否存在
--> 不存在创建hash，当前业务key，uuid+线程id为field，value =1 ，设置过期时间并返回
--> 存在检查uuid+线程id是否一致，一致递增value更新过期时间返回。存在锁检查uuid+线程id不一致，判断是否到期，没到期我就帮你续期，自己加锁也没有成功，就以当前业务key发布消息订阅pubsub，等收到解锁消息在重试

解锁逻辑

lua判断锁是否存在
-->不存在则直接发布解锁消息并返回
-->存在就检查uuid+线程id是否一致，不一致就报错，因为加锁线程不一致。如果一致，就递减value，判断是否大于0，如果等于0，删除key并发布解锁消息
以上就是redisson特性及优雅实现示例的详细内容，更多关于redisson特性及实现的资料请关注中国红客联盟其它相关文章！