redisson的锁的类型_厉害了，中间件Redisson原来这么好用！

点击上方[全栈开发者社区]→右上角[...]→[设为星标⭐]

20a7efa873c297a651f9cdcf69406739.gif

作者：bravoban
原文：http://tech.lede.com/2017/03/08/rd/server/Redisson/

针对项目中使用的分布式锁进行简单的示例配置以及源码解析，并列举源码中使用到的一些基础知识点，但是没有对redisson中使用到的netty知识进行解析。

本篇主要是对以下几个方面进行了探索

  • Maven配置

  • RedissonLock简单示例

  • 源码中使用到的Redis命令

  • 源码中使用到的lua脚本语义

  • 源码分析

Maven配置

<dependency><groupId>org.redissongroupId><artifactId>redissonartifactId><version>2.2.12version>dependency><dependency><groupId>com.fasterxml.jackson.coregroupId><artifactId>jackson-annotationsartifactId><version>2.6.0version>dependency>

RedissonLock简单示例

redission支持4种连接redis方式，分别为单机、主从、Sentinel、Cluster 集群，项目中使用的连接方式是Sentinel。
redis服务器不在本地的同学请注意权限问题。

Sentinel配置

Config config = new Config();config.useSentinelServers().addSentinelAddress("127.0.0.1:6479", "127.0.0.1:6489").setMasterName("master").setPassword("password").setDatabase(0);
RedissonClient redisson = Redisson.create(config);`

简单使用

RLock lock = redisson.getLock("test_lock");try{
    boolean isLock=lock.tryLock();if(isLock){
        doBusiness();
    }
}catch(exception e){
}finally{lock.unlock();
}

源码中使用到的Redis命令

分布式锁主要需要以下redis命令，这里列举一下。在源码分析部分可以继续参照命令的操作含义。

1.EXISTS key :当 key 存在，返回1；若给定的 key 不存在，返回0。
2.GETSET key value:将给定 key 的值设为 value ，并返回 key 的旧值 (old value)，当 key 存在但不是字符串类型时，返回一个错误，当key不存在时，返回nil。
3.GET key:返回 key 所关联的字符串值，如果 key 不存在那么返回 nil。
4.DEL key [KEY …]:删除给定的一个或多个 key ,不存在的 key 会被忽略,返回实际删除的key的个数(integer)。
5.HSET key field value：给一个key 设置一个{field=value}的组合值，如果key没有就直接赋值并返回1，如果field已有，那么就更新value的值，并返回0.
6.HEXISTS key field:当key中存储着field的时候返回1，如果key或者field至少有一个不存在返回0。
7.HINCRBY key field increment:将存储在key中的哈希(Hash)对象中的指定字段field的值加上增量increment。如果键key不存在，一个保存了哈希对象的新建将被创建。如果字段field不存在，在进行当前操作前，其将被创建，且对应的值被置为0，返回值是增量之后的值
8.PEXPIRE key milliseconds：设置存活时间，单位是毫秒。expire操作单位是秒。
9.PUBLISH channel message:向channel post一个message内容的消息，返回接收消息的客户端数。

源码中使用到的lua脚本语义

Redisson源码中，执行redis命令的是lua脚本，其中主要用到如下几个概念。

  • redis.call() 是执行redis命令.

  • KEYS[1] 是指脚本中第1个参数

  • ARGV[1] 是指脚本中第一个参数的值

  • 返回值中nil与false同一个意思。

需要注意的是，在redis执行lua脚本时，相当于一个redis级别的锁，不能执行其他操作，类似于原子操作，也是redisson实现的一个关键点。
另外，如果lua脚本执行过程中出现了异常或者redis服务器直接宕掉了，执行redis的根据日志回复的命令，会将脚本中已经执行的命令在日志中删除。

源码分析

RLOCK结构

public interface RLock extends Lock, RExpirable {void lockInterruptibly(long leaseTime, TimeUnit unit) throws InterruptedException;boolean tryLock(long waitTime, long leaseTime, TimeUnit unit) throws InterruptedException;void lock(long leaseTime, TimeUnit unit);void forceUnlock();boolean isLocked();boolean isHeldByCurrentThread();int getHoldCount();Future unlockAsync();Future tryLockAsync();Future lockAsync();Future lockAsync(long leaseTime, TimeUnit unit);Future tryLockAsync(long waitTime, TimeUnit unit);Future tryLockAsync(long waitTime, long leaseTime, TimeUnit unit);
}

该接口主要继承了Lock接口, 并扩展了部分方法, 比如:boolean tryLock(long waitTime, long leaseTime, TimeUnit unit)新加入的leaseTime主要是用来设置锁的过期时间, 如果超过leaseTime还没有解锁的话, redis就强制解锁. leaseTime的默认时间是30s

RedissonLock获取锁 tryLock源码

Future tryLockInnerAsync(long leaseTime, TimeUnit unit, long threadId) {
       internalLockLeaseTime = unit.toMillis(leaseTime);return commandExecutor.evalWriteAsync(getName(), LongCodec.INSTANCE, RedisCommands.EVAL_LONG,"if (redis.call('exists', KEYS[1]) == 0) then " +"redis.call('hset', KEYS[1], ARGV[2], 1); " +"redis.call('pexpire', KEYS[1], ARGV[1]); " +"return nil; " +"end; " +"if (redis.call('hexists', KEYS[1], ARGV[2]) == 1) then " +"redis.call('hincrby', KEYS[1], ARGV[2], 1); " +"redis.call('pexpire', KEYS[1], ARGV[1]); " +"return nil; " +"end; " +"return redis.call('pttl', KEYS[1]);",
                   Collections.singletonList(getName()), internalLockLeaseTime, getLockName(threadId));
   }

其中，
KEYS[1] 表示的是 getName() ，代表的是锁名 test_lock
ARGV[1] 表示的是 internalLockLeaseTime 默认值是30s
ARGV[2] 表示的是 getLockName(threadId) 代表的是 id:threadId 用锁对象id+线程id， 表示当前访问线程，用于区分不同服务器上的线程.
逐句分析：

if (redis.call('exists', KEYS[1]) == 0) then 
         redis.call('hset', KEYS[1], ARGV[2], 1); 
         redis.call('pexpire', KEYS[1], ARGV[1]); return nil;end;

  • if (redis.call(‘exists’, KEYS[1]) == 0) 如果锁名称不存在

  • then redis.call(‘hset’, KEYS[1], ARGV[2],1) 则向redis中添加一个key为test_lock的set，并且向set中添加一个field为线程id，值=1的键值对，表示此线程的重入次数为1

  • redis.call(‘pexpire’, KEYS[1], ARGV[1]) 设置set的过期时间，防止当前服务器出问题后导致死锁，return nil; end;返回nil 结束

if (redis.call('hexists', KEYS[1], ARGV[2]) == 1) then 
         redis.call('hincrby', KEYS[1], ARGV[2], 1); 
         redis.call('pexpire', KEYS[1], ARGV[1]);return nil; end;

  • if (redis.call(‘hexists’, KEYS[1], ARGV[2]) == 1) 如果锁是存在的，检测是否是当前线程持有锁，如果是当前线程持有锁

  • then redis.call(‘hincrby’, KEYS[1], ARGV[2], 1)则将该线程重入的次数++

  • redis.call(‘pexpire’, KEYS[1], ARGV[1]) 并且重新设置该锁的有效时间

  • return nil; end;返回nil，结束

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

  • 锁存在, 但不是当前线程加的锁，则返回锁的过期时间。

RedissonLock解锁 unlock源码

@Overridepublic void unlock() {
        Boolean opStatus = commandExecutor.evalWrite(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.asList(getName(), getChannelName()), LockPubSub.unlockMessage, internalLockLeaseTime, getLockName(Thread.currentThread().getId()));if (opStatus == null) {throw new IllegalMonitorStateException("attempt to unlock lock, not locked by current thread by node id: "
                    + id + " thread-id: " + Thread.currentThread().getId());
        }if (opStatus) {
            cancelExpirationRenewal();
        }
    }

其中，
KEYS[1] 表是的是getName() 代表锁名test_lock
KEYS[2] 表示getChanelName() 表示的是发布订阅过程中使用的Chanel
ARGV[1] 表示的是LockPubSub.unLockMessage 是解锁消息，实际代表的是数字 0，代表解锁消息
ARGV[2] 表示的是internalLockLeaseTime 默认的有效时间 30s
ARGV[3] 表示的是getLockName(thread.currentThread().getId())，是当前锁id+线程id
语义分析:

if (redis.call('exists', KEYS[1]) == 0) then
         redis.call('publish', KEYS[2], ARGV[1]);return 1;end;

  • if (redis.call(‘exists’, KEYS[1]) == 0) 如果锁已经不存在(可能是因为过期导致不存在，也可能是因为已经解锁)

  • then redis.call(‘publish’, KEYS[2], ARGV[1]) 则发布锁解除的消息

  • return 1; end 返回1结束

if (redis.call('hexists', KEYS[1], ARGV[3]) == 0) then return nil;end;

  • if (redis.call(‘hexists’, KEYS[1], ARGV[3]) == 0) 如果锁存在，但是若果当前线程不是加锁的线

  • then return nil;end 则直接返回nil 结束

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;

  • local counter = redis.call(‘hincrby’, KEYS[1], ARGV[3], -1) 如果是锁是当前线程所添加，定义变量counter，表示当前线程的重入次数-1,即直接将重入次数-1

  • if (counter > 0)如果重入次数大于0，表示该线程还有其他任务需要执行

  • then redis.call(‘pexpire’, KEYS[1], ARGV[2]) 则重新设置该锁的有效时间

  • return 0 返回0结束

  • else redis.call(‘del’, KEYS[1]) 否则表示该线程执行结束，删除该锁

  • redis.call(‘publish’, KEYS[2], ARGV[1]) 并且发布该锁解除的消息

  • return 1; end;返回1结束

return nil;

  • 其他情况返回nil并结束

if (opStatus == null) {throw new IllegalMonitorStateException("attempt to unlock lock, not locked by current thread by node id: "
                    + id + " thread-id: " + Thread.currentThread().getId());
        }

脚本执行结束之后，如果返回值不是0或1，即当前线程去解锁其他线程的加锁时，抛出异常。

RedissonLock强制解锁源码

@Overridepublic void forceUnlock() {get(forceUnlockAsync());
    }Future forceUnlockAsync() {
        cancelExpirationRenewal();return commandExecutor.evalWriteAsync(getName(), LongCodec.INSTANCE, RedisCommands.EVAL_BOOLEAN,"if (redis.call('del', KEYS[1]) == 1) then "
                + "redis.call('publish', KEYS[2], ARGV[1]); "
                + "return 1 "
                + "else "
                + "return 0 "
                + "end",
                Arrays.asList(getName(), getChannelName()), LockPubSub.unlockMessage);
    }

以上是强制解锁的源码,在源码中并没有找到forceUnlock()被调用的痕迹(也有可能是我没有找对),但是forceUnlockAsync()方法被调用的地方很多，大多都是在清理资源时删除锁。此部分比较简单粗暴，删除锁成功则并发布锁被删除的消息，返回1结束，否则返回0结束。

总结

这里只是简单的一个redisson分布式锁的测试用例，并分析了执行lua脚本这部分，如果要继续分析执行结束之后的操作，需要进行netty源码分析 ，redisson使用了netty完成异步和同步的处理

推荐：《Python网络爬虫开发-从入门到精通》

7dee3bccd72ea8b079051dafe0a800c1.png

编辑推荐：(1)没有高深的理论，每一章都是以实例为主，读者参考源码，修改实例，就能得到自己想要的结果。目的是让读者看得懂、学得会、做得出。　　(2)实训与问答，10多章章节实训与问答，目的是让读者看完之后，能做到举一反三，学以致用。　　(3)内容系统，实战性强。本书从零开始讲解，然后逐步深入相关爬虫技能，从而达到从入门到精通的学习效果。　　(4)配套资源丰富。案例源码，Python 常见面试题精选(50 道)，“微信高手技巧随身查”“QQ 高手技巧随身查”“手机办公 10 招就够”3 本电子书，“5 分钟学会番茄工作法”视频教程““10 招精通超级时间整理术”视频教程。

如何购买：点击小程序购买或阅读全文了解更多，也可坚持留言打卡获得！

如何赠送：留言集赞数大于30赞且排名第一的同学赠送一本，集赞截止时间2020.3.4 23:00，定价89RMB。

觉得本文对你有帮助？请分享给更多人

关注「全栈开发者社区」加星标，提升全栈技能

本公众号会不定期给大家发福利，包括送书、学习资源等，敬请期待吧！

如果感觉推送内容不错，不妨右下角点个在看转发朋友圈或收藏，感谢支持。

好文章，我在看❤️

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/343635.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

探探自动配对PHP_CentOS7 - 安装Apache HTTP Server和PHP

探探自动配对PHP_CentOS7 - 安装Apache HTTP Server和PHP

安装Apache HTTP Server和PHP你可能听说过LAMP的缩写&#xff0c;它代表Linux&#xff0c;Apache&#xff0c;MySQL和PHP。 它指的是用于提供网站和Web应用程序的流行技术配对。 本文教您如何安装Apache HTTP Server(简称Apache)并将其配置为与PHP一起使用以提供动态Web内容.Ap…
阅读更多...
网管型交换机比普通交换机有哪些明显优势

网管型交换机比普通交换机有哪些明显优势

现在网络这么普及&#xff0c;对于交换机的需求也就越发的重要了&#xff0c;而市面上交换机的型号这么多&#xff0c;之前我们也分析过按照不同的情况怎么区分交换机&#xff0c;但浏览名称的时候我们也会发现&#xff0c;许多交换机的简介都会写着网管型交换机和非网管型交换…
阅读更多...
cryptojs支持rsa加密_新特性解读 | 从 wireshark 看 MySQL 8.0 加密连接

cryptojs支持rsa加密_新特性解读 | 从 wireshark 看 MySQL 8.0 加密连接

作者&#xff1a;秦福朗爱可生 DBA 团队成员&#xff0c;负责项目日常问题处理及公司平台问题排查。热爱 IT&#xff0c;喜欢在互联网里畅游&#xff0c;擅长摄影、厨艺&#xff0c;不会厨艺的 DBA 不是好司机&#xff0c;didi~本文来源&#xff1a;原创投稿*爱可生开源社区出品…
阅读更多...
sap-erp实施心得_实施动态代理-比较

sap-erp实施心得_实施动态代理-比较

sap-erp实施心得有时需要拦截某些方法调用&#xff0c;以便每次调用被拦截方法时都执行自己的逻辑。 如果您不属于Java EE的CDI领域&#xff0c;并且不想使用诸如Aspectj之类的AOP框架&#xff0c;那么您将有一个简单而有效的替代方法。 从1.5版开始&#xff0c;JDK附带了类ja…
阅读更多...
保存点云数据_PCL入门系列三——PCL进行数据读写

保存点云数据_PCL入门系列三——PCL进行数据读写

本节课我们将了解到以下内容&#xff1a;基本的PCL中的数据类型&#xff1b;使用PCL进行简单编程&#xff1a;写文件与读文件。一、PCL库基本数据类型上一节课&#xff0c;我们使用PCL库在本地写入了一个名为test_pcd.pcd的文件。我们划分一下程序的任务步骤&#xff1a;构造pc…
阅读更多...
win8系统的计算机共享在哪里设置方法,win10系统设置与win8系统局域网文件共享的方案...

win8系统的计算机共享在哪里设置方法,win10系统设置与win8系统局域网文件共享的方案...

win10系统使用久了&#xff0c;好多网友反馈说关于对win10系统设置与win8.1系统局域网文件共享设置的方法&#xff0c;在使用win10系统的过程中经常不知道如何去对win10系统设置与win8.1系统局域网文件共享进行设置&#xff0c;有什么好的办法去设置win10系统设置与win8.1系统局…
阅读更多...
光端机的使用方法

光端机的使用方法

光端机是一种不仅可以传输视频信号&#xff0c;还能传输音频、电话、网络、和很多种控制信号的以太网介质传输设备&#xff0c;目前主要使用安防监控行业。那么&#xff0c;光端机是怎么使用的&#xff0c;接下来就由飞畅科技的小编来为大家详细介绍下光端机的使用方法吧&#…
阅读更多...
用香港服务器建收费网站,使用香港站群服务器搭建网站的好处有哪些？

用香港服务器建收费网站,使用香港站群服务器搭建网站的好处有哪些？

香港站群服务器搭建网站的作用&#xff1a;1、香港站群服务器有利于提高网站被搜索引擎收录情况;2、搭建站群能够有效降低网站被封的风险;3、当网站遭受攻击时&#xff0c;可快速通过带有独立IP的网站来查出问题所在&#xff0c;从而有效提高服务器的维护。香港站群服务器搭建站…
阅读更多...
分数化简_分数应用题七讲 （一） 图示法解分数应用题

分数化简_分数应用题七讲 （一） 图示法解分数应用题

一、今日一讲图示法就是用线段图(或其它图形)把题目中的已知条件和问题表示出来&#xff0c;这样可以把抽象的数量关系具体化&#xff0c;往往可以从图中找到解题的突破口。运用图示法教学应用题&#xff0c;是培养思维能力的有效方法之一。图示法不仅可以形象地、直观地反映分…
阅读更多...
发送广播_DHCP服务器什么时候发送？为什么request要广播发送？那还不看？

发送广播_DHCP服务器什么时候发送？为什么request要广播发送？那还不看？

动态主机配置协议&#xff1a;DHCP 用来集中管理、分配IP地址&#xff0c;使网络环境中的主机能够动态获取IP地址、网关地址、DNS服务器地址等信息&#xff1b;DHCP采用客户端服务器模式&#xff0c;端口号&#xff1a;客户端为68(中继模式下67)&#xff0c;服务器端为67版本一…
阅读更多...
开关量光端机指示灯说明及常见故障问题处理方法

开关量光端机指示灯说明及常见故障问题处理方法

开关量光端机可以使开关量信号通过光缆在光纤上传输双向控制。全数字光传输通道&#xff0c;确保高质量的信号传输。面板上有电源指示灯、光信号指示灯数据信号指示灯&#xff0c;可以直观的检测电源、光信号、数据信号状态。单向系列开关量光端机是高性能&#xff0c;高可靠性…
阅读更多...
为特使建立控制平面的指南-部署权衡

为特使建立控制平面的指南-部署权衡

部署控制平面组件 构建并设计了控制平面后&#xff0c;您将需要确切确定如何部署其组件。 在这里&#xff0c;您可以选择将控制平面与数据平面共置一处以集中控制平面。 这里还有一个中间立场&#xff1a;部署与控制平面位于同一位置的某些组件&#xff0c;并使某些组件保持集中…
阅读更多...
大牛服务器超时位置模拟失败,大牛模拟定位掉线怎么办 | 手游网游页游攻略大全...

大牛服务器超时位置模拟失败,大牛模拟定位掉线怎么办 | 手游网游页游攻略大全...

发布时间&#xff1a;2016-07-07在第四期"微分享"活动中,有许多游戏大牛向小智讲述了关于玩游戏的妙招.巧招和绝招,现小智将这些内容推送给大家! 1.如何在3v3中取得好名次?(由"天才的小白"玩家供稿) 打3v3 ...标签&#xff1a;游乐网 游戏攻略发布时间&am…
阅读更多...
宋佳乐博客全站正版PHP源码下载丨自助建站源码丨音乐外链源码丨最新图床源码丨官方网站源码丨网页跳转源码丨云相册源码丨打包下载

宋佳乐博客全站正版PHP源码下载丨自助建站源码丨音乐外链源码丨最新图床源码丨官方网站源码丨网页跳转源码丨云相册源码丨打包下载

本套源码共包含了六套网站系统&#xff0c;请在下方看演示站&#xff1a; 一&#xff1a;主页跳转演示地址&#xff1a;http://ssl.songjiale.com&#xff08;无演示图&#xff09; 二&#xff1a;官方网站演示地址&#xff1a;http://ssl.songjiale.com/upload &#xff08;…
阅读更多...
css3怎么排除第一个,css怎么排除第一个子元素

css3怎么排除第一个,css怎么排除第一个子元素

css排除第一个子元素的方法&#xff1a;1、通过使用伪类选择器“:not”实现排除&#xff1b;2、通过使用“nth-of-type”或者“nth-child”实现排除&#xff1b;3、通过使用“”或者“~”兄弟选择符实现获取排除第一个之外的子元素。本文操作环境&#xff1a;windows7系统、HTM…
阅读更多...
如何解决光端机的开关量问题？

如何解决光端机的开关量问题？

光端机开关量问题可以说是光端机的常见问题之一&#xff0c;对监控效果有比较大的影响&#xff0c;那么&#xff0c;我们应该如何解决光端机的开关量问题呢&#xff1f;接下来就由杭州飞畅科技的小编来为大家详细讲解下吧&#xff0c;感兴趣的朋友就一起来了解下&#xff01; …
阅读更多...
什么是电视光端机？电视光端机是怎么分类的？

什么是电视光端机？电视光端机是怎么分类的？

现如今&#xff0c;随着国内通信网络的发展&#xff0c;电视光端机应用的监控范围也越来越广。在高速公路、银行、电力、电信等的监控领域都要求对视频信号进行远程的传输&#xff0c;目前主要的解决方法是利用光端机将视频信号转化为数字信号通过光纤进行传输。那么&#xff0…
阅读更多...
mysql存储过程语法 if_mysql存储过程语法 if

mysql存储过程语法 if_mysql存储过程语法 if

MySql存储过程MySQL 存储过程是从 MySQL 5.0 开始增加的新功能。存储过程的优点有一箩筐。不过最主要的还是执行效率和SQL 代码封装。特别是 SQL 代码封装功能&#xff0c;如果没有存储过程&#xff0c;在外部程序访问数据库时(例如 PHP)&#xff0c;要组织很多 SQL 语句。特别…
阅读更多...
什么是模拟量光端机？模拟光端机品牌有哪些？

什么是模拟量光端机？模拟光端机品牌有哪些？

模拟光端机采用了 PFM 调制技术实时传输图象信号。发射端将模拟视频信号先进行 PFM 调制后&#xff0c;再进行电-光转换&#xff0c;光信号传到接收端后&#xff0c;进行光电转换&#xff0c;然后进行 PFM 解调&#xff0c;恢复出视频信号。由于采用了PFM 调制技术&#xff0c;…
阅读更多...
什么是物理隔离？物理隔离光端机是什么？

什么是物理隔离？物理隔离光端机是什么？

什么是物理隔离&#xff1f; 物理隔离&#xff0c;是指采用物理方法将内网与外网隔离从而避免入侵或信息泄露的风险的技术手段。物理隔离主要用来解决网络安全问题的&#xff0c;尤其是在那些需要绝对保证安全的保密网&#xff0c;专网和特种网络与互联网进行连接时&#xff0c…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023