分散式鎖的Redis實現

来源:https://www.cnblogs.com/Gon-only/archive/2019/10/27/11749583.html
-Advertisement-
Play Games

當我們開始開發項目部署運行時,項目規模不大,只是在一個JVM實例中運行,對同一資源的併發訪問用JDK自帶的鎖機制就可以解決資源同時訪問的問題。而隨著項目的不斷發展,單體應用已經無法滿足日益增長的訪問需求,我們開始考慮多台部署,提高接收客戶端的連接請求,提高項目的吞吐量。一臺變多台,其中不可避免的問題 ...


  當我們開始開發項目部署運行時,項目規模不大,只是在一個JVM實例中運行,對同一資源的併發訪問用JDK自帶的鎖機制就可以解決資源同時訪問的問題。而隨著項目的不斷發展,單體應用已經無法滿足日益增長的訪問需求,我們開始考慮多台部署,提高接收客戶端的連接請求,提高項目的吞吐量。一臺變多台,其中不可避免的問題就是如何控制解決不同線程對同一資源的併發訪問。其中一種手段就是使用redis進行分散式鎖的控制。

  我們可以在獲取訪問資源鎖之前判斷redis中是否存在對應代表該資源鎖key的value,如果存在,則說明已經被獲取,反之還沒有客戶端獲取該資源對應的鎖,可以進行獲取鎖。

 1     boolean lock = false;
 2         try {
 3             lcok = getLock(taskId);   //獲取鎖
 4             if (lock) {
 5                 doSomething();   //業務邏輯
 6             }
 7         } finally {
 8             if (lock) {
 9                 releaseLock(taskId);   //釋放鎖
10             }
11         }

 

1 public static boolean getLock(String taskId) {
2         if (existsKey(taskId)) {
3             return false;
4         } else {
5             setKey(taskId);
6             return true;
7         }
8     }

  上面的部分實現代碼給了一個大概的解決思路,看起來沒有問題的,但是仔細看看還是存在問題滴,存在什麼問題呢?

  當正在執行doSomething()方法時,突然系統宕機掛掉了,無法執行釋放鎖的操作,redis中對應的資源key的鎖一直存在,之後運行代碼就會出現問題。另一個問題就是執行getLock(taskId)方法時,該方法不是原子性的,有可能同時兩個線程都判斷為不存在該資源鎖,都執行了setKey方法,導致同時獲得鎖資源的情況。

  如何解決上面的兩個問題呢?從Redis官方API中有SET my_key my_value NX PX milliseconds的方法,得到瞭解決方案。它提供了一個只有在某個key不存在的情況下才會設置key的值的原子命令,該命令也能設置key值過期時間。其中,NX表示只有當鍵key不存在的時候才會設置key的值,PX表示設置鍵key的過期時間,單位是毫秒。

  到現在是否完全解決了併發獲取鎖的問題了呢?系統可能存在這種情況,當客戶端A獲取鎖之後,執行業務代碼的時間超過了之前設置的過期時間,導致鎖的自動釋放,而客戶端B剛好獲得新的資源鎖,但客戶端A恰好執行完業務操作,釋放鎖的時候,該鎖是客戶端B重新獲得的鎖,導致出現問題。這時,我們想到可以在設置key值時給定一個隨機數,在釋放資源鎖的同時,判斷是否和之前設置的value值相同,相同則釋放,反之不釋放。

1     if(getKey(taskId)==random_value){
2             deleteKey(taskId);
3         }

  很可惜,上面的整個if操作也不是原子性的,getKey方法和deleteKey方法之間由於某種原因而延遲1秒鐘操作了,而這1秒內剛好設置的的超時時間而鎖釋放,被新的客戶端獲得鎖,1秒之後執行deleteKey方法又會誤刪除新客戶端的鎖,問題依舊存在。接下來我們只要想辦法解決上面判斷的原子性就能解決誤刪除鎖的問題。Redis可以使用Lua腳本保證操作的原子性。

1 if redis.call("get",KEYS[1]) == ARGV[1] then
2     return redis.call("del",KEYS[1])
3 else
4     return 0
5 end

  其中ARGV[1]表示設置key時指定的隨機值。由於Lua腳本的原子性,在Redis執行該腳本的過程中,其他客戶端的命令都需要等待該Lua腳本執行完才能執行,所以不會出現上面所說的誤刪除鎖問題。至此,使用Redis實現分散式鎖的方案就相對完善了。上述分散式鎖的實現方案中,都是針對單節點Redis而言的。

  


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

-Advertisement-
Play Games
更多相關文章
  • 背景 上一文我們講到瞭如何去搭建註冊中心,這一次我們講述如何使用nacos作為註冊中心 spring cloud alibaba basis 創建基礎依賴 首先我們創建一個spring cloud alibaba basis 基礎依賴 工程裡面制定我們要用到的公用的版本 spring boot 版本 ...
  • gitlab就相當於我們自己內網搭建的git服務,相當於公司內的github。 拉取鏡像docker pull gitlab/gitlab-ce 創建宿主機的數據目錄mkdir -p /mnt/gitlab/etcmkdir -p /mnt/gitlab/logmkdir -p /mnt/gitla ...
  • 我們知道,在Eureka中,可以使用如下方法使Eureka主動下線,那麼本篇文章就來分析一下子這個下線的流程 主要做了這麼幾件事: 1. 解除狀態監聽器 2. 取消心跳、刷新線程 3. 向服務端發起下線通知 4. 停止各個監聽器 服務端接受下線消息 下線消息的處理在 類中 先看具體的下線邏輯,與租約 ...
  • 場景 喜馬拉雅電臺: https://www.ximalaya.com/ 找到一步小說音頻,這裡以下麵為例 https://www.ximalaya.com/youshengshu/16411402/ 博客:https://blog.csdn.net/badao_liumang_qizhi關註公眾號 ...
  • 7 18 輸出10個不重覆的英文字母 (50 分) 隨機輸入一個字元串,把最左邊的10個不重覆的英文字母(不區分大小寫)挑選出來。 如沒有10個英文字母,顯示信息“not found” 輸入格式: 在一行中輸入字元串 輸出格式: 在一行中輸出最左邊的10個不重覆的英文字母或顯示信息“not foun ...
  • 新聞 "F eXchange 2020——徵文通知" "FSSF在忙什麼?2019年第三季度版本" "Miguel強烈推薦使用TensorFlow.NET" "運行在ASP.NET Core 3上的SAFE BookStore" "新的Thoth.Json站點" "Rider 2019.3早期可訪問 ...
  • 1 介紹 集合類可謂是學習必知、編程必用、面試必會的,而且集合的操作十分重要;本文主要講解如何合併集合類,如合併兩個數組,合併兩個List等。通過例子講解幾種不同的方法,有JDK原生的方法,還有使用第三庫的方法。 2 第三方庫 引入十分常用的優秀的第三方庫 和`Apache Commons pom. ...
  • A. Equalize Prices Again time limit per test 1 second memory limit per test 256 megabytes input standard input output standard output You are both a s ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...