聊聊使用RedisTemplat實現(xiàn)簡單的分布式鎖的問題
不使用redisson框架實現(xiàn)Redis分布式鎖
準備工作:
導(dǎo)入依賴
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency>
編寫RedisConfig類
@Configuration public class RedisConfig { @Bean public RedisTemplate<String , Object> redisTemplate(RedisConnectionFactory redisConnectionFactory){ RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>(); //String類型 key序列器 redisTemplate.setKeySerializer(new StringRedisSerializer()); //String類型 value序列器 redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer()); //Hash類型 key序列器 redisTemplate.setHashKeySerializer(new StringRedisSerializer()); //Hash類型 value序列器 redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer()); //將連接工廠注入 redisTemplate.setConnectionFactory(redisConnectionFactory); return redisTemplate; } }
1.在SpringBootTest中編寫測試模塊
1.1:使用占位符加鎖:
占位符加鎖問題
:出現(xiàn)異常時無法釋放鎖,導(dǎo)致后繼進入的線程成為死鎖
@SpringBootTest class ApplicationTests { @Autowired private RedisTemplate redisTemplate; @Test public void lodsTest01(){ ValueOperations valueOperations = redisTemplate.opsForValue(); //創(chuàng)建一個占位符,如果key不存在才可以設(shè)置成功 Boolean isLock = valueOperations.setIfAbsent("k1", "v1"); //如果占位成功,進行正常操作 if (isLock){ //設(shè)置一個name存到redis valueOperations.set("name","xxxx"); //從redis取出name String name = (String) valueOperations.get("name"); System.out.println("name = " + name); //手動制造異常 Integer.parseInt("xxxx"); //操作結(jié)束刪除鎖 redisTemplate.delete("k1"); }else{ System.out.println("有線程在用,請稍后在試"); } } }
測試
第一個線程出現(xiàn)異常無法釋放鎖:
之后所有線程都無法訪問:
解決方案
:為鎖加一個有效時間。
1.2:使用占位符設(shè)置有效時間解決死鎖問題:
占位符設(shè)置有效時間問題
:即使某線程出現(xiàn)異常,但占位符過了有效時間,鎖就會釋放。但是在大量線程同時訪問時,如果線程1被外界因素影響(網(wǎng)絡(luò)波動,服務(wù)器出問題等等),線程1的業(yè)務(wù)還沒完成,但鎖的有效時間到了的話,下一個線程就會進來,就會出現(xiàn)線程不安全的情況,出現(xiàn)線程互相刪鎖的情況。
@Test public void testLock02() { ValueOperations valueOperations = redisTemplate.opsForValue(); //如果key不存在才可以設(shè)置成功,設(shè)置一個有效時間防止線程異常出現(xiàn)死鎖 Boolean isLock = valueOperations.setIfAbsent("k1", "v1",5, TimeUnit.SECONDS); //如果占位成功,進行正常操作 if (isLock){ //設(shè)置一個name存到redis valueOperations.set("name","xxxx"); //從redis取出name String str = (String) valueOperations.get("name"); System.out.println("name = " + str); //制造異常 Integer.parseInt("xxxx"); //操作結(jié)束刪除鎖 redisTemplate.delete("k1"); }else{ System.out.println("有線程在用,請稍后在試"); } }
解決方案:
使用lua腳本,給每個鎖的key對應(yīng)的value設(shè)置一個隨機數(shù)
1.3:使用lua腳本解決線程不安全問題:
lua腳本可以寫在Redis服務(wù)器上:優(yōu)點
: 在服務(wù)器上運行速度快
缺點
: 修改代碼時比較麻煩
lua腳本可以通過java發(fā)送優(yōu)點:
修改代碼方便
缺點:
每次發(fā)送請求時都需要占用網(wǎng)絡(luò)資源
1.3.1:編寫lua腳本
if redis.call("get",KEYS[1])==ARGV[1] then return redis.call("del",KEYS[1]) else return 0 end
1.3.2:修改ReidsConfig類
@Bean public DefaultRedisScript<Boolean> defaultRedisScript(){ DefaultRedisScript<Boolean> redisScript = new DefaultRedisScript<>(); //lock.lua腳本位置和application.yml同級目錄 redisScript.setLocation(new ClassPathResource("lock.lua")); //設(shè)置類型為boolean redisScript.setResultType(Boolean.class); return redisScript; }
1.3.3:編寫測試模塊
@Test public void testLock03(){ ValueOperations valueOperations = redisTemplate.opsForValue(); String value = UUID.randomUUID().toString(); //如果key不存在才可以設(shè)置成功,設(shè)置一個value為隨機數(shù)的值,防止出現(xiàn)線程太多 導(dǎo)致線程不安全 Boolean isLock = valueOperations.setIfAbsent("k1", value, 5, TimeUnit.SECONDS); //如果占位成功,進行正常操作 if (isLock){ //設(shè)置一個name存到redis valueOperations.set("name","xxxx"); //從redis取出name String name = (String) valueOperations.get("name"); System.out.println("name = " + name); //為redis發(fā)送lua腳本刪除鎖對應(yīng)的value Boolean aBoolean = (Boolean) redisTemplate.execute(redisScript, Collections.singletonList("k1"), value); System.out.println(aBoolean); }else{ System.out.println("有線程在用,請稍后在試"); } }
測試結(jié)果:
順利把name值存到redis中并把鎖刪除并返回true
鎖會被正常刪除只留下name:
到此這篇關(guān)于使用RedisTemplat實現(xiàn)簡單的分布式鎖的文章就介紹到這了,更多相關(guān)RedisTemplat分布式鎖內(nèi)容請搜索本站以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持本站!
版權(quán)聲明:本站文章來源標(biāo)注為YINGSOO的內(nèi)容版權(quán)均為本站所有,歡迎引用、轉(zhuǎn)載,請保持原文完整并注明來源及原文鏈接。禁止復(fù)制或仿造本網(wǎng)站,禁止在非www.sddonglingsh.com所屬的服務(wù)器上建立鏡像,否則將依法追究法律責(zé)任。本站部分內(nèi)容來源于網(wǎng)友推薦、互聯(lián)網(wǎng)收集整理而來,僅供學(xué)習(xí)參考,不代表本站立場,如有內(nèi)容涉嫌侵權(quán),請聯(lián)系alex-e#qq.com處理。