redission分布式锁释放异常问题

前言:

    线上使用reidsson做分布式锁的实现,经常看到线上会报当前线程未持有锁,不能释放锁异常,慌的一批。异常信息如下:
java.lang.IllegalMonitorStateException: attempt to unlock lock, not locked by current thread by node id: aa9c450d-2b24-4588-a03e-d7f9f4bb7c9a thread-id: 6238
    at org.redisson.RedissonLock$5.operationComplete(RedissonLock.java:564)
    at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:577)
    at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:570)
    at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:549)
    at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:490)
    at io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:615)

加锁demo

boolean lock = false;
            try {
              //获取锁,在10秒内持续获取锁
               lock = redissonClient.getLock("lockName").tryLock(10,TimeUnit.SECONDS);
               if(lock){//模拟业务操作一分钟
                   TimeUnit.MINUTES.sleep(1);
               }
            } catch (InterruptedException e) {
                log.error("系统异常",e);
                Thread.currentThread().interrupt();
            } finally {
                    //释放锁,这里直接释放锁,一般情况下也不会有问题。
                    redissonClient.getLock("lockName").unlock();
            }

一开始看加锁和解锁的代码也没什么异常啊,为啥在线上偶尔会出现上述异常信息?,百思不得其姐。
只能去撸redis源码了...错了,只能先百度看看有没有其他大佬已经碰到并解决这个问题了
持续百度中...
发现还是有大佬碰到相同问题类似的问题的:具体可以参考资料:https://www.jianshu.com/p/b12e1c0b3917
上面blog说的是lock()方法获取锁线程中断导致redis释放锁时抛了IllegalMonitorStateException异常,
然后也给出了对应的复现demo代码
但是,我用的是tryLock()方法,撸了三遍加锁的代码也没找到加锁失败的情况下会调用Thread.currentThread().interrupt();来中断线程。
然后得出结论,呸,然后怀疑最终导致释放锁异常的原因可能是在并发争锁的情况下:
线程1获取到锁,还未释放时,线程2开始获取锁,获取失败,直接走到finally去释放锁,这时后锁的持有者还是线程1,线程2去释放锁会报异常。
写个demo试试?

@Test
    public void testLock(){
        Thread thread_1 = new LockWithoutBoolean("thread-1",redissonClient);
        Thread thread_2 = new LockWithoutBoolean("thread-2",redissonClient);
        thread_1.start();
        try {
            TimeUnit.SECONDS.sleep(2); // 睡2秒钟 为了让thread_1获取到锁
            thread_2.start();
            TimeUnit.SECONDS.sleep(2000); // 让主线程在两子线程之后结束
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }

    }
    static class LockWithoutBoolean extends Thread {
        private String name;
        private RedissonClient redissonClient;
        public LockWithoutBoolean(String name, RedissonClient redissonClient) {
            super(name);
            this.redissonClient=redissonClient;
        }
        public void run() {
           boolean lock = false;
            try {
               lock = redissonClient.getLock("lockName").tryLock(10,TimeUnit.SECONDS);
               if(lock){
                   TimeUnit.MINUTES.sleep(1);
               }
            } catch (InterruptedException e) {
                log.error("系统异常",e);
                Thread.currentThread().interrupt();
            } finally {
                    redissonClient.getLock("lockName").unlock();
            }
        }
    }

结果重现了线上释放锁异常

Exception in thread "thread-2" java.lang.IllegalMonitorStateException: attempt to unlock lock, not locked by current thread by node id: 9e874b6a-7880-44c7-8bdf-ef5abad43484 thread-id: 738
    at org.redisson.RedissonLock$5.operationComplete(RedissonLock.java:564)
    at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:577)
    at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:551)
    at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:490)
    at io.netty.util.concurrent.DefaultPromise.addListener(DefaultPromise.java:183)
    at org.redisson.misc.RedissonPromise.addListener(RedissonPromise.java:124)
    at org.redisson.misc.RedissonPromise.addListener(RedissonPromise.java:42)
    at org.redisson.RedissonLock.unlockAsync(RedissonLock.java:553)
    at org.redisson.RedissonLock.unlock(RedissonLock.java:443)
    at lock.LockTest$LockWithoutBoolean.run(LockTest.java:59)

注意:上述异常,只有在线程1获取到锁,线程2等待获取锁超时的情况下去释放锁才会必现。线上一般获取锁会设置超时时间为5s,也就是说线程1只要在5s内能释放锁也就不会产生上述问题了,所以线上用锁量那么大,也是少部分释放锁会产生异常。
那么,问题来了,释放锁为啥会报这个异常?
我们来看看释放锁的关键源码

protected RFuture<Boolean> unlockInnerAsync(long threadId) {
        return commandExecutor.evalWriteAsync(getName(), LongCodec.INSTANCE, RedisCommands.EVAL_BOOLEAN,
                "if (redis.call('exists', KEYS[1]) == 0) then " +
                        "redis.call('publish', KEYS[2], ARGV[1]); " +
                        "return 1; " +
                        "end;" +
                        "if (redis.call('hexists', KEYS[1], ARGV[3]) == 0) then " +
                        "return nil;" +
                        "end; " +
                        "local counter = redis.call('hincrby', KEYS[1], ARGV[3], -1); " +
                        "if (counter > 0) then " +
                        "redis.call('pexpire', KEYS[1], ARGV[2]); " +
                        "return 0; " +
                        "else " +
                        "redis.call('del', KEYS[1]); " +
                        "redis.call('publish', KEYS[2], ARGV[1]); " +
                        "return 1; "+
                        "end; " +
                        "return nil;",
                Arrays.<Object>asList(getName(), getChannelName()), LockPubSub.unlockMessage, internalLockLeaseTime, getLockName(threadId));

    }

这里是说:
1、如果key不存在,则表示锁不存在,返回成功
2、如果key存在,本线程id获取锁不存在,则表示当前线程不是锁的持有者,释放锁抛异常(上述异常)
3、否则,获取当前线程的锁的使用次数,因为同一个锁在同一个线程是可重入的,每次获取锁,计数+1
所以需要判断锁的使用次数,如果counter>0,则锁持有次数-1,否则直接删除锁,返回成功
4、其他情况都返回异常
最后排查完终于放心了,该异常不会导致死锁,锁续约等问题,因为线程1最终还是会正确的释放锁的,不用担心线上故障
虽然问题不大,但是线上老出这种异常信息看着太难受了,顺便给出解决方案吧
知道问题根源,解决起来就简单了
在上面释放锁的地方加上以下判断即可。只有获取锁成功才去释放锁。

 if(lock){
                    redissonClient.getLock("lockName").unlock();
            }

当然你要觉得low了,你也可以用redisson自带的isLocked(),和isHeldByCurrentThread()方法来判断,区别就是后者的判断需要多请求两次redis,前者只需要在业务代码中标记获取锁成功才去释放,所以,当然用前者啦

 if(lock.isLocked()&&lock.isHeldByCurrentThread()){
                            lock.unlock();
                            log.info("释放分布式锁成功key:{}", key);
                        }

另外:推荐我另外一篇blog,统一来管理分布式锁的加解锁:基于事务实现redis分布式锁自动释放的实现

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 203,937评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,503评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 150,712评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,668评论 1 276
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,677评论 5 366
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,601评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,975评论 3 396
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,637评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,881评论 1 298
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,621评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,710评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,387评论 4 319
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,971评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,947评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,189评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 44,805评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,449评论 2 342

推荐阅读更多精彩内容