分散式鎖----Redis實現

来源:https://www.cnblogs.com/zhouguanglin/archive/2019/07/26/11246239.html
-Advertisement-
Play Games

分散式鎖 為什麼需要有分散式鎖呢,在單點的時候synchronized 就能解決,但是服務拆分之後,每個服務都是單獨的機器,無法解決,所以出現了分散式鎖,其實也就是用各種手段,實現獲取唯一鎖,別人無法得到。 其實在做分散式鎖的前提,需要先明白,synchronized 為啥不能使用了,啥原理讓他在一 ...


   分散式鎖

  為什麼需要有分散式鎖呢,在單點的時候synchronized 就能解決,但是服務拆分之後,每個服務都是單獨的機器,無法解決,所以出現了分散式鎖,其實也就是用各種手段,實現獲取唯一鎖,別人無法得到。

  其實在做分散式鎖的前提,需要先明白,synchronized  為啥不能使用了,啥原理讓他在一個機器上可以使用。

  


      synchronized 的原理   

      眾所周知 Synchronize 關鍵字是解決併發問題常用解決方案,有以下三種使用方式:

  • 同步靜態方法,鎖的是當前 Class 對象。
  • 同步塊,鎖的是 {} 中的對象。
  •  同步普通方法,鎖的是當前對象。

  實現原理:
  JVM 是通過進入、退出對象監視器( Monitor )來實現對方法、同步塊的同步的。

  具體實現是在編譯之後在同步方法調用前加入一個 monitor.enter 指令,在退出方法和異常處插入 monitor.exit 的指令。

  其本質就是對一個對象監視器( Monitor )進行獲取,而這個獲取過程具有排他性從而達到了同一時刻只能一個線程訪問的目的。

  而對於沒有獲取到鎖的線程將會阻塞到方法入口處,直到獲取鎖的線程 monitor.exit 之後才能嘗試繼續獲取鎖。

 

可以通過使用 javap -c Synchronize 可以查看編譯之後的具體信息 ,這裡我就不再粘貼了。

所以可以知道,單獨的Java虛擬機是可實現鎖的,但是多台手就伸不到了,只能在依賴外部的形式去產生一個唯一鎖。

以上是參考別人的博客拿到的信息,親自試用得到,準確   :鏈接:https://www.jianshu.com/p/2ba154f275ea


  Redis實現的分散式鎖

  主要是利用了redis的set NX的原理,以及對redis的script腳本原子性利用。(個人看法,其實後面一步就看各自的程式邏輯如何去判定到底要不要這一步了)

  簡單的說一下主要流程:

  1. 首先設置一個全局唯一的key和一個唯一性的value(value是一個解鎖的保障,刪除之前判斷一下值是否一致)
  2. 使用Redis的set 方法 以多參數形式配置key,value,nx,px,過期時間 (參數 NX:只有鍵不存在時,才能對其進行設置操作)
  3. 利用Redis的script腳本來對key的刪除操作,只能自己刪除自己的value(刪除之前先判斷一下value是否是我之前的value,是否被改過,沒有就刪了)
   這是腳本的主要 內容 if redis.call("get",KEYS[1]) == ARGV[1] then return redis.call("del",KEYS[1]) else  return 0 end      對其解釋: 根據 get 獲取到 key 的值 ,判斷key的值是否跟你傳的值相等,相等則 執行del  key 否則返回0 結束    對此推薦去看一下redis的Lua腳本,給個簡單的:http://redisdoc.com/script/eval.html
     在實際場景中可以利用AOP的切點切麵形式,實現具體是什麼地方需要分散式鎖,搭配分散式鎖,再搭配註解方式,來實現想要的自定義設置那裡需要就點哪裡   AOP的主要實現是
  1. @pointcut 切註解類
  2. 在使用@around環繞對前後做處理
  3. 前面加鎖
  4. 後面解鎖del  使用script腳本
  

  代碼主要實現

   註解類 DistributedLock

  

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
@Documented
public @interface DistributedLock {

    /**
     * 自定義形式添加你對分散式鎖的對外配置屬性  
     * 例如:key的規則,鎖的超時時間,獲取鎖的等待時間,等一系列的屬性配置
     * 
     */

}
  切麵類 DistributedLockAspect
@Aspect
@Component
public class DistributedLockAspect {
    
     /**
     * 層切點
     */
    @Pointcut("@annotation(com.creditease.hardess.common.annotation.DistributedLock)")
    public void distributedLockAspect() {}

/**
     * @param joinPoint 切點
     * @return Object 添加分散式鎖後,實際調用業務邏輯部分代碼的返回值
     * @throws Throwable 產生的所有異常,為了避免對異常處理流程產生干擾,所有異常都應該繼續拋出
     */
    @Around("distributedLockAspect()")
    public Object doAround(ProceedingJoinPoint joinPoint) throws Throwable {
     /**
      *主要寫一些鎖的獲取,和業務邏輯執行,鎖的刪除等
      *
     */
     return returnObject;
    }

   /**
     * 獲取 DistributedLock 註解
     * 
     * @param joinPoint
     * @return 代碼中定義的註解
     * @throws NoSuchMethodException
     */
    private static DistributedLock getDistributedLock(ProceedingJoinPoint joinPoint)
            throws NoSuchMethodException {
        String methodName = joinPoint.getSignature().getName();

        Class<?> classTarget = joinPoint.getTarget().getClass();
        Class<?>[] par = ((MethodSignature) joinPoint.getSignature()).getParameterTypes();
        Method objMethod = classTarget.getMethod(methodName, par);

        return objMethod.getAnnotation(DistributedLock.class);
    }

}




}

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 1 計算得來的屬性 2 3 4 如果需要使用表達式來創建屬性鍵,那麼需要使用方括弧。否則屬性名稱不會進行計算: 5 6 var obj = { 'b'+'ar': 'foo' }; 7 // SyntaxError: missing : after property id 8 9 把計算表達式放置到... ...
  • 一下內容為筆者個人理解,如有出入還請大佬指出不勝感激 頁面有數據未保存,用戶離開頁面分為兩種 1 . 直接關閉瀏覽器標簽 或者點擊瀏覽器後退按鈕 離開當前頁面 2. 在頁面內改變路由,或則刷新頁面(不包含新標簽頁打開頁面‘target=_blank’) 先說第1種情況 通過關閉頁簽和後退按鈕 1 通 ...
  • html: <section> <nav id="nav"> <a class="on">tab1</a> <a>tab2</a> <a>tab3</a> <a>tab4</a> </nav> <div id="contentBox"> <div class="box active">內容一</di ...
  • 一、使用vue-cli搭建項目 註意:在mac執行該命令會報錯 改用管理員許可權執行以下命令即可 $ sudo npm install -g vue-cli$ vue init webpack tcloud$ cd tcloud$ npm run dev 完成了利用腳手架創建並啟動一個vue的項目,可 ...
  • 1 try catch的使用,永遠應該放在你的控制範圍之內,而不應該防範未知的錯誤。也就是說你很清楚知道這裡是有可能”出錯“的,而且你很清楚知道什麼前提下會出錯,你就是要故意利用報錯信息來區分錯誤,後續的程式會解決所有的出錯,讓程式繼續執行。如果讓用戶先發現你根本沒預料到的錯誤,而不是你先發現錯誤, ...
  • 在設計網站的過程中你們註意到banner和導航欄嗎?瞭解它們的用途可以更快更好的進行網站建設。經常瀏覽網頁的朋友們可能都會註意到,當打開一個網頁的時候最先映入眼帘的是個人企業logo和banner等。Banner的作用相當於市場上拉的橫幅,優秀的banner讓人一眼看出宣傳主題,也能鮮明的表達情感思 ...
  • 由於跨域策略,從另一個域請求文件可能會導致問題。從另一個域請求外部腳本沒有此問題。JSONP使用此優勢,並使用腳本標記而不是XMLHttpRequest對象請求文件。 ...
  • 流量紅利正逐漸走向終結,這已經不再是什麼秘密。後互聯網時代,如何維繫住用戶群,提升用戶在平臺上的體驗是整個行業都需要考慮的事情。正是出於這一原因,現在全行業都在關註會員體系的搭建,這也是馬蜂窩 2019 年重點投入的方向之一。 面對這個全行業都在發力的會員市場,要對「馬蜂窩特色」的會員體系進行有力的 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...