日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

spring boot 分布式锁组件 spring-boot-klock-starter

發(fā)布時間:2023/12/20 编程问答 30 豆豆
生活随笔 收集整理的這篇文章主要介紹了 spring boot 分布式锁组件 spring-boot-klock-starter 小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.

基于redis的分布式鎖spring-boot starter組件,使得項目擁有分布式鎖能力變得異常簡單,支持spring boot,和spirng mvc等spring相關項目

快速開始

spring boot項目接入

1.添加lock starter組件依賴,目前還沒上傳到公共倉庫,需要自己下源碼build ,已上傳到maven中央倉庫

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-klock-starter</artifactId><version>1.2-SNAPSHOT</version> </dependency>

2.application.properties配置redis鏈接:spring.klock.address=127.0.0.1:6379

3.在需要加分布式鎖的方法上,添加注解@Klock,如:

@Service public class TestService {@Klock(waitTime = Long.MAX_VALUE)public String getValue(String param) throws Exception {if ("sleep".equals(param)) {//線程休眠或者斷點阻塞,達到一直占用鎖的測試效果Thread.sleep(1000 * 50);}return "success";} }

支持鎖指定的業(yè)務key,如同一個方法ID入?yún)⑾嗤募渔i,其他的放行。業(yè)務key的獲取支持Spel,具體使用方式如下

使用參數(shù)說明

spring.klock.address : redis鏈接地址 spring.klock.password : redis密碼 spring.klock.database : redis數(shù)據(jù)索引 spring.klock.waitTime : 獲取鎖最長阻塞時間(默認:60,單位:秒) spring.klock.leaseTime: 已獲取鎖后自動釋放時間(默認:60,單位:秒) spring.klock.cluster-server.node-addresses : redis集群配置 如 127.0.0.1:7000,127.0.0.1:7001,127.0.0.1:7002 spring.klock.address 和 spring.klock.cluster-server.node-addresses 選其一即可

@Klock注解參數(shù)說明

@Klock可以標注四個參數(shù),作用分別如下 name:lock的name,對應redis的key值。默認為:類名+方法名 lockType:鎖的類型,目前支持(可重入鎖,公平鎖,讀寫鎖)。默認為:公平鎖 waitTime:獲取鎖最長等待時間。默認為:60s。同時也可通過spring.klock.waitTime統(tǒng)一配置 leaseTime:獲得鎖后,自動釋放鎖的時間。默認為:60s。同時也可通過spring.klock.leaseTime統(tǒng)一配置 lockTimeoutStrategy: 加鎖超時的處理策略,可配置為不做處理、快速失敗、阻塞等待的處理策略,默認策略為不做處理 customLockTimeoutStrategy: 自定義加鎖超時的處理策略,需指定自定義處理的方法的方法名,并保持入?yún)⒁恢隆?releaseTimeoutStrategy: 釋放鎖時,持有的鎖已超時的處理策略,可配置為不做處理、快速失敗的處理策略,默認策略為不做處理 customReleaseTimeoutStrategy: 自定義釋放鎖時,需指定自定義處理的方法的方法名,并保持入?yún)⒁恢隆?/span>

鎖超時說明

因為基于redis實現(xiàn)分布式鎖,如果使用不當,會在以下場景下遇到鎖超時的問題:

加鎖超時處理策略(LockTimeoutStrategy):

  • NO_OPERATION 不做處理,繼續(xù)執(zhí)行業(yè)務邏輯
  • FAIL_FAST 快速失敗,會拋出KlockTimeoutException
  • KEEP_ACQUIRE 阻塞等待,一直阻塞,直到獲得鎖,但在太多的嘗試后,會停止獲取鎖并報錯,此時很有可能是發(fā)生了死鎖。
  • 自定義(customLockTimeoutStrategy) 需指定自定義處理的方法的方法名,并保持入?yún)⒁恢?#xff0c;指定自定義處理方法后,會覆蓋上述三種策略,且會攔截業(yè)務邏輯的運行。

釋放鎖時超時處理策略(ReleaseTimeoutStrategy):

  • NO_OPERATION 不做處理,繼續(xù)執(zhí)行業(yè)務邏輯
  • FAIL_FAST 快速失敗,會拋出KlockTimeoutException
  • 自定義(customReleaseTimeoutStrategy) 需指定自定義處理的方法的方法名,并保持入?yún)⒁恢?#xff0c;指定自定義處理方法后,會覆蓋上述兩種策略, 執(zhí)行自定義處理方法時,業(yè)務邏輯已經(jīng)執(zhí)行完畢,會在方法返回前和throw異常前執(zhí)行。

?

轉(zhuǎn)載于:https://www.cnblogs.com/luchangjiang/p/10805733.html

總結(jié)

以上是生活随笔為你收集整理的spring boot 分布式锁组件 spring-boot-klock-starter的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯,歡迎將生活随笔推薦給好友。