這篇文章主要為大家展示了“如何解決redis分布式鎖的問(wèn)題”，內(nèi)容簡(jiǎn)而易懂，條理清晰，希望能夠幫助大家解決疑惑，下面讓小編帶領(lǐng)大家一起研究并學(xué)習(xí)一下“如何解決redis分布式鎖的問(wèn)題”這篇文章吧。

10年積累的成都網(wǎng)站建設(shè)、網(wǎng)站建設(shè)經(jīng)驗(yàn)，可以快速應(yīng)對(duì)客戶對(duì)網(wǎng)站的新想法和需求。提供各種問(wèn)題對(duì)應(yīng)的解決方案。讓選擇我們的客戶得到更好、更有力的網(wǎng)絡(luò)服務(wù)。我雖然不認(rèn)識(shí)你，你也不認(rèn)識(shí)我。但先網(wǎng)站設(shè)計(jì)后付款的網(wǎng)站建設(shè)流程，更有雙橋免費(fèi)網(wǎng)站建設(shè)讓你可以放心的選擇與我們合作。

分布式鎖

在分布式環(huán)境中，為了保證業(yè)務(wù)數(shù)據(jù)的正常訪問(wèn)，防止出現(xiàn)重復(fù)請(qǐng)求的問(wèn)題，會(huì)使用分布式鎖來(lái)阻攔后續(xù)請(qǐng)求。我們先寫一段有問(wèn)題的業(yè)務(wù)代碼：

public void doSomething(String userId){
  User user=getUser(userId);
  if(user==null){
   user.setUserName("xxxxx");
   user.setUserId(userId);
   insert(user);
   return;
  }
  update(user);
 }

上面的代碼很簡(jiǎn)單，查詢db中有沒有對(duì)應(yīng)的user數(shù)據(jù)，如果有的話，執(zhí)行更新操作，如果沒有則插入。

我們知道，上面的代碼是線程不安全的，在多線程的環(huán)境中，就會(huì)出現(xiàn)問(wèn)題。為了能夠保證數(shù)據(jù)的正確性，在單機(jī)環(huán)境下，我們可以使用synchronized的方法，來(lái)保證線程安全，具體修改：

public synchronized void doSomething(String userId){
  User user=getUser(userId);
  if(user==null){
   user.setUserName("xxxxx");
   user.setUserId(userId);
   insert(user);
   return;
  }
  update(user);
 }

在單機(jī)器的環(huán)境下，能夠解決線程安全的問(wèn)題，那在分布式環(huán)境下呢？ 這個(gè)時(shí)候需要用到分布式鎖.

分布式鎖需要借助其他組件來(lái)實(shí)現(xiàn)，常用的有redis和zookeeper。下面我們就用redis的實(shí)現(xiàn)，來(lái)說(shuō)明下問(wèn)題，分布式鎖具體的實(shí)現(xiàn)方法如下

public void doSomething(String userId){
  String lock=RedisUtils.get("xxxx"+userId);
  if(StringUtils.isNotEmpty(lock)){//說(shuō)明當(dāng)前userId已經(jīng)被鎖定
   return;
  }
  RedisUtils.set("xxxx"+userId,userId,1000);//鎖定10s
  User user=getUser(userId);
  if(user==null){
   insert(user);
   RedisUtils.delete("xxxx"+userId);
   return;
  }
  update(user);
  RedisUtils.delete("xxxx"+userId);
  
 }

上面的代碼解決了在分布式環(huán)境中的并發(fā)的問(wèn)題。但同樣需要考慮一個(gè)問(wèn)題，如果insert操作和update操作異常了，分布式鎖不會(huì)釋放，后續(xù)的請(qǐng)求還會(huì)被攔截。

所以我們?cè)賰?yōu)化，增加對(duì)異常的捕獲。

public void doSomething(String userId){
  try {
    String lock=RedisUtils.get("xxxx"+userId);
    if(StringUtils.isNotEmpty(lock)){//說(shuō)明當(dāng)前userId已經(jīng)被鎖定
     return;
    }
    RedisUtils.set("xxxx"+userId,userId,1000);//鎖定1s
    User user=getUser(userId);
    if(user==null){
     insert(user);
     return;
    }
    update(user);
  }
  catch(Exception ex){

  }
  finally{
   RedisUtils.delete("xxxx"+userId);
  }
 }

現(xiàn)在即使是程序異常了，鎖會(huì)自動(dòng)釋放。但redis的get和set也會(huì)存在并發(fā)問(wèn)題，我們?cè)倮^續(xù)優(yōu)化，使用redis中的setnx方法

public void doSomething(String userId){
  try {
    boolean lock=RedisUtils.setnx("xxxx"+userId,userId,1000);//鎖定1s
    if(!lock){//說(shuō)明當(dāng)前userId已經(jīng)被鎖定
     return;
    }
    User user=getUser(userId);
    if(user==null){
     insert(user);
     return;
    }
    update(user);
  }
  catch(Exception ex){

  }
  finally{
   RedisUtils.delete("xxxx"+userId);
  }
 }

上面的代碼好像沒有什么問(wèn)題了，但也存在很大的隱患。 我們分析下，假設(shè)第一個(gè)請(qǐng)求過(guò)來(lái)，執(zhí)行鎖定成功，程序開始運(yùn)行，但是insert和update操作阻塞了1s，第二個(gè)請(qǐng)求過(guò)來(lái)，鎖的緩存已經(jīng)過(guò)期，第二個(gè)執(zhí)行鎖定成功，這個(gè)時(shí)候第一個(gè)請(qǐng)求完成了鎖被釋放，第二個(gè)請(qǐng)求的鎖就被第一次請(qǐng)求釋放了，第三次的請(qǐng)求就會(huì)造成線程不安全問(wèn)題。

怎么再去優(yōu)化呢？問(wèn)題主要是出現(xiàn)在第一次請(qǐng)求誤刪鎖的問(wèn)題，所以我們?cè)谝瞥i的時(shí)候要判斷能否移除。

思路：我們?cè)阪i定的時(shí)候，value使用當(dāng)前的時(shí)間戳，刪除時(shí)判斷是否過(guò)期如果不過(guò)期就不要?jiǎng)h除，具體代碼如下：

public void doSomething(String userId){
  try {
    boolean lock=RedisUtils.setnx("xxxx"+userId,LocalDateTime.now(),1000);//鎖定10s
    if(!lock){//說(shuō)明當(dāng)前userId已經(jīng)被鎖定
     return;
    }
    User user=getUser(userId);
    if(user==null){
     insert(user);
     return;
    }
    update(user);
  }
  catch(Exception ex){

  }
  finally{
   LocalDateTime lockTIme= RedisUtils.get("xxxx"+userId);
   if(lockTIme.compare(LocalDateTime.now())<0){
    //說(shuō)明已經(jīng)過(guò)期，可以刪除key
    RedisUtils.delete("xxxx"+userId);
   }
  }
 }

 這樣即使出現(xiàn)阻塞，第二次的時(shí)間戳覆蓋了第一次的鎖定，這樣即使第一次完成了，也不會(huì)釋放鎖。

以上是“如何解決redis分布式鎖的問(wèn)題”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對(duì)大家有所幫助，如果還想學(xué)習(xí)更多知識(shí)，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！

網(wǎng)站欄目：如何解決redis分布式鎖的問(wèn)題-創(chuàng)新互聯(lián)
網(wǎng)頁(yè)URL：http://www.chinadenli.net/article48/dgsdhp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供ChatGPT、企業(yè)網(wǎng)站制作、定制網(wǎng)站、服務(wù)器托管、網(wǎng)站導(dǎo)航、網(wǎng)站營(yíng)銷

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)