redis深入淺出分佈式鎖實現上篇
問題描述
隨著業務發展的需要,原單體單機部署的系統被演化成分佈式集群系統後,由於分佈式系統多線程、多進程並且分佈在不同機器上,這將使原單機部署情況下的並發控制鎖策略失效,單純的Java API並不能提供分佈式鎖的能力。為瞭解決這個問題就需要一種跨JVM的互斥機制來控制共享資源的訪問,這就是分佈式鎖要解決的問題!
分佈式鎖主流的實現方案:
1. 基於數據庫實現分佈式鎖
2. 基於緩存(Redis等)
3. 基於Zookeeper
每一種分佈式鎖解決方案都有各自的優缺點:
1. 性能:redis最高
2. 可靠性:zookeeper最高
這裡,我們就基於redis實現分佈式鎖。
解決方案
使用redis實現分佈式鎖
redis:命令
# set sku:1:info “OK” NX PX 10000
EX second :設置鍵的過期時間為 second 秒。 SET key value EX second 效果等同於 SETEX key second value 。
PX millisecond :設置鍵的過期時間為 millisecond 毫秒。 SET key value PX millisecond 效果等同於 PSETEX key millisecond value 。
NX :隻在鍵不存在時,才對鍵進行設置操作。 SET key value NX 效果等同於 SETNX key value 。
XX :隻在鍵已經存在時,才對鍵進行設置操作。
1. 多個客戶端同時獲取鎖(setnx)
2. 獲取成功,執行業務邏輯{從db獲取數據,放入緩存},執行完成釋放鎖(del)
3. 其他客戶端等待重試
編寫代碼
Redis:
set num 0
@GetMapping("testLock") public void testLock(){ //1獲取鎖,setne Boolean lock = redisTemplate.opsForValue().setIfAbsent("lock", "111"); //2獲取鎖成功、查詢num的值 if(lock){ Object value = redisTemplate.opsForValue().get("num"); //2.1判斷num為空return if(StringUtils.isEmpty(value)){ return; } //2.2有值就轉成成int int num = Integer.parseInt(value+""); //2.3把redis的num加1 redisTemplate.opsForValue().set("num", ++num); //2.4釋放鎖,del redisTemplate.delete("lock"); }else{ //3獲取鎖失敗、每隔0.1秒再獲取 try { Thread.sleep(100); testLock(); } catch (InterruptedException e) { e.printStackTrace(); } } }
重啟,服務集群,通過網關壓力測試:
ab -n 1000 -c 100 http://192.168.140.1:8080/test/testLock
查看redis中num的值:
基本實現。
問題:setnx剛好獲取到鎖,業務邏輯出現異常,導致鎖無法釋放
解決:設置過期時間,自動釋放鎖。
優化之設置鎖的過期時間
設置過期時間有兩種方式:
1. 首先想到通過expire設置過期時間(缺乏原子性:如果在setnx和expire之間出現異常,鎖也無法釋放)
2. 在set時指定過期時間(推薦)
設置過期時間:
壓力測試肯定也沒有問題。自行測試
問題:可能會釋放其他服務器的鎖。
場景:如果業務邏輯的執行時間是7s。執行流程如下
index1業務邏輯沒執行完,3秒後鎖被自動釋放。index2獲取到鎖,執行業務邏輯,3秒後鎖被自動釋放。index3獲取到鎖,執行業務邏輯index1業務邏輯執行完成,開始調用del釋放鎖,這時釋放的是index3的鎖,導致index3的業務隻執行1s就被別人釋放。最終等於沒鎖的情況。
解決:setnx獲取鎖時,設置一個指定的唯一值(例如:uuid);釋放前獲取這個值,判斷是否自己的鎖
優化之UUID防誤刪
到此這篇關於redis深入淺出分佈式鎖實現上篇的文章就介紹到這瞭,更多相關redis分佈式鎖內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet!
推薦閱讀:
- redis深入淺出分佈式鎖實現下篇
- 關於SpringBoot 使用 Redis 分佈式鎖解決並發問題
- 詳解Redis實現限流的三種方式
- 如何用redis setNX命令來加鎖
- 詳解redis分佈式鎖(優化redis分佈式鎖的過程及Redisson使用)