本文环境搭建:Springoot + Redisson 3.12.3 + Maven 3.6.1 +lombok
1、业务需求分析
项目部署在多个服务器,当我们有业务需要在每天凌晨,拉取数据写入数据库的时候,所有服务器上的定时器都在凌晨一起运行,数据库负荷太大,这时候如何解决呢?当多线程处理业务,因为线程不安全,导致数据紊乱,如何解决呢?Redis的分布式锁就能处理这些场景,这篇文章主要介绍的是redisson分布式锁的使用实例。
2、redis分布式锁基本特性
互斥性:这是最基本的特性,保证多个线程进入的情况下,只有一个线程可以获取到锁。
容错率:可以用unlock自己解锁,而且解铃还须系铃人,哪个线程上的锁,就由谁来解锁。
唯一性:redis分布式锁第一个参数和第二个参数会保证其唯一性,我在业务中第二个参数用的是uuid。
防止死锁:给获取锁的线程一个过期时间,保证业务处理出现异常,时间过期后,锁也能正常释放。
Redisson是一个高级的分布式协调Redis客户端,在项目中直接引入redisson的maven包,使用分布式锁会事半功倍。
注意事项,redisson使用trylock上锁的时候,最好带参数,否则在unlock释放所得时候,若当前线程没有获取锁,会报错,即使用locked先判断一下也不行,因为locked底层源码是任意线程上锁都会返回true。
纸上得来终觉浅,绝知此事要躬行,话不多说,直接撸代码。
3、实例代码:
先导入需要的maven包,在写一个redisson装入bean容器,方便后面依赖注入,先导入需要的maven包,在写一个redisson装入bean容器,方便后面依赖注入,例子中lock和trylock实例全部都有,若没有开启分布式锁,则线程不安全,会导致数据紊乱,甚至多消费,开启之后,控制台显示消费正常。
最后结果可以看到,分布式情况下消费很安全,不会出现消费紊乱,多消费。