redis中RedissonLock如何实现等待锁

技术redis中RedissonLock如何实现等待锁今天就跟大家聊聊有关redis中RedissonLock如何实现等待锁,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有

今天我就来和大家聊聊如何实现redis中的等待锁。很多人可能不太了解。为了让大家更好的了解,边肖为大家总结了以下内容。希望你能从这篇文章中有所收获。

00-1010,总有一个需求,就是在一个查询界面中,第一次查询的时候,如果没有查询,就要执行初始化的方法,初始化的数据就会出来,然后数据库中的数据就可以被后续的查询直接查询了。这种设计的目的是,如果要初始化的数据太大,无法通过再次调用方法来处理,或者如果不是每一条数据都需要初始化,在这种情况下,首先要查询的数据将首先被初始化。

前言

这种方案会引起问题。众所周知,接口自然是幂等的,所以不需要做幂等处理。但是在方案中,这个查询不仅仅是一个查询。当找不到查询时,将执行初始化方法,这本质上是一个插入逻辑。这要求我们自己做幂等运算。

00-1010单服务,我们可以用Java锁实现幂等性,并且把每一条数据的主键id作为锁。但是现在基本上都是分布式服务。正如上一篇文章所说,我们可以用分布式锁RedissonLock来实现它们。

当与第一个请求并发时,竞争RedissonLock。得到锁的人将执行初始化方法。如果没有锁请求,您可以设置等待时间来等待锁被释放。解除锁定后,可以先检查数据是否已经初始化,完成后直接检查数据库。这里,我们来谈谈RedissonLock如何等待。

问题

redisonlock在加锁方法中提供了一个api,并提供了一个参数waitTime,即等待时间。

Publibooleantylock(长等待时间、长租用时间、时间单位)将在等待期间订阅消息。这里使用了redis本身的发布和订阅功能。

rfutureresolvenlockentrysubscribefuture=subscribe(threadId);

if(!subscribeFuture.await(时间,时间单位。毫秒)){ 0

if(!subscribe future . cancel(false)){ 0

subscribe future . on complete((RES,e)-{ 0

if(e==null){ 0

取消订阅(subscribeFuture,threadId);

}

});

}

acquire failed(threadId);

returnfalse

}这样,当锁被释放时,消息也同时被释放。所有监听锁的线程都会得到通知,然后这些线程会再次争夺锁,从而实现我们需要的幂等函数。我们在看开锁的逻辑。你发布消息了吗?

方案

protected futuredeborbonunlockinerasync(longthreadId){ 0

returncommandxecutor . evalwriteasync(getName()、LongCodec。实例,RedisCommands。EVAL_BOOLEAN

if(redis.call('hexists ',KEYS[1],ARGV[3])==0)然后

' returnnil'

' end'

local counter=redis . call(' hin crby ',KEYS[1],ARGV[3],-1);'

if(count 0)then’

redis . call(' PEX fire ',KEYS[1],ARgV[2]);

返回0;'

“否则”

redis.call('del ',KEYS[1]);

redis.call('publish ',KEYS[2],ARgV[1]);

' return1'

' end'

' returnnil',

数组。ObjectasList(getName()、getChannelName())、LockPubSub。UNLOCK_MESSAGE,internalLockLeaseTime,getLockName(threadId));

}可以看到,在unlockInnerAsync方法中,执行的是lua脚本,在脚本中,我们很容易看到执行的是publish命令。

Redisson巧妙地利用Redis的发布订阅功能,实现分布式锁的等待功能。

看完以上内容,你对redis中如何实现等待锁有更好的理解吗?如果您想了解更多知识或相关内容,请关注行业资讯频道,感谢您的支持。

内容来源网络,如有侵权,联系删除,本文地址:https://www.230890.com/zhan/84020.html

(0)

相关推荐

  • 吃大米会发胖吗,大米和小麦哪个吃了更容易发胖

    技术吃大米会发胖吗,大米和小麦哪个吃了更容易发胖大米和小麦哪个吃了更容易发胖?七星老农认为大米和小麦都是主粮食物吃大米会发胖吗,从它们的营养比例来看,并不是什么高脂肪食品,吃了并不会导致人体发胖,只不过七星老农认为,无论

    生活 2021年10月21日
  • Python解释器种类以及特点是什么

    技术Python解释器种类以及特点是什么这篇文章将为大家详细讲解有关Python解释器种类以及特点是什么,文章内容质量较高,因此小编分享给大家做个参考,希望大家阅读完这篇文章后对相关知识有一定的了解。python解释器是

    攻略 2021年12月4日
  • 什么是java非公平锁

    技术什么是java非公平锁这篇文章主要介绍“什么是java非公平锁”,在日常操作中,相信很多人在什么是java非公平锁问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”什么是java非公平锁”

    攻略 2021年10月20日
  • Angular中非父子组件间是如何通讯的

    技术Angular中非父子组件间是如何通讯的本篇内容介绍了“Angular中非父子组件间是如何通讯的”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大

    攻略 2021年11月15日
  • 电脑手机互传文件,怎样通过电脑给手机发送文件

    技术电脑手机互传文件,怎样通过电脑给手机发送文件通过电脑给手机发送文件电脑手机互传文件,可以通过电脑QQ传到我到手机设备中,然后在从手机QQ下载到自己的手机就行了,具体的方法如下: 1、首先在电脑上的QQ页面点击【我的设

    生活 2021年10月24日
  • 蹚的意思,“赴汤蹈火”的意思是什么

    技术蹚的意思,“赴汤蹈火”的意思是什么“赴汤蹈火”的意思是:沸水敢蹚,烈火敢踏。比喻不避艰险,奋勇向前。赴汤蹈火 [ fù tāng dǎo huǒ ]:沸水敢蹚,烈火敢踏。比喻不避艰险,奋勇向前。(赴:走往;汤:热水;

    生活 2021年10月23日