redlock java_Redlock分布式鎖

這篇文章主要是對 Redis 官方網站刊登的 Distributed locks with Redis 部分內容的總結和翻譯。

什么是 RedLock

Redis 官方站這篇文章提出了一種權威的基于 Redis 實現分布式鎖的方式名叫 Redlock,此種方式比原先的單節點的方法更安全。它可以保證以下特性:

安全特性:互斥訪問,即永遠只有一個 client 能拿到鎖

避免死鎖:最終 client 都可能拿到鎖,不會出現死鎖的情況,即使原本鎖住某資源的 client crash 了或者出現了網絡分區

容錯性:只要大部分 Redis 節點存活就可以正常提供服務

怎么在單節點上實現分布式鎖

SET resourcename myrandom_value NX PX 30000

主要依靠上述命令,該命令僅當 Key 不存在時(NX保證)set 值,并且設置過期時間 3000ms (PX保證),值 myrandomvalue 必須是所有 client 和所有鎖請求發生期間唯一的,釋放鎖的邏輯是:

ifredis.call("get",KEYS[1])==ARGV[1]then

returnredis.call("del",KEYS[1])

else

return0

end

上述實現可以避免釋放另一個client創建的鎖,如果只有 del 命令的話,那么如果 client1 拿到 lock1 之后因為某些操作阻塞了很長時間,此時 Redis 端 lock1 已經過期了并且已經被重新分配給了 client2,那么 client1 此時再去釋放這把鎖就會造成 client2 原本獲取到的鎖被 client1 無故釋放了,但現在為每個 client 分配一個 unique 的 string 值可以避免這個問題。至于如何去生成這個 unique string,方法很多隨意選擇一種就行了。

Redlock 算法

算法很易懂,起 5 個 master 節點,分布在不同的機房盡量保證可用性。為了獲得鎖,client 會進行如下操作:

得到當前的時間,微妙單位

嘗試順序地在 5 個實例上申請鎖,當然需要使用相同的 key 和 random value,這里一個 client 需要合理設置與 master 節點溝通的 timeout 大小,避免長時間和一個 fail 了的節點浪費時間

當 client 在大于等于 3 個 master 上成功申請到鎖的時候,且它會計算申請鎖消耗了多少時間,這部分消耗的時間采用獲得鎖的當下時間減去第一步獲得的時間戳得到,如果鎖的持續時長(lock validity time)比流逝的時間多的話,那么鎖就真正獲取到了。

如果鎖申請到了,那么鎖真正的 lock validity time 應該是 origin(lock validity time) - 申請鎖期間流逝的時間

如果 client 申請鎖失敗了,那么它就會在少部分申請成功鎖的 master 節點上執行釋放鎖的操作,重置狀態

失敗重試

如果一個 client 申請鎖失敗了,那么它需要稍等一會在重試避免多個 client 同時申請鎖的情況,最好的情況是一個 client 需要幾乎同時向 5 個 master 發起鎖申請。另外就是如果 client 申請鎖失敗了它需要盡快在它曾經申請到鎖的 master 上執行 unlock 操作,便于其他 client 獲得這把鎖,避免這些鎖過期造成的時間浪費,當然如果這時候網絡分區使得 client 無法聯系上這些 master,那么這種浪費就是不得不付出的代價了。

放鎖

放鎖操作很簡單,就是依次釋放所有節點上的鎖就行了

性能、崩潰恢復和 fsync

如果我們的節點沒有持久化機制,client 從 5 個 master 中的 3 個處獲得了鎖,然后其中一個重啟了,這是注意 整個環境中又出現了 3 個 master 可供另一個 client 申請同一把鎖! 違反了互斥性。如果我們開啟了 AOF 持久化那么情況會稍微好轉一些,因為 Redis 的過期機制是語義層面實現的,所以在 server 掛了的時候時間依舊在流逝,重啟之后鎖狀態不會受到污染。但是考慮斷電之后呢,AOF部分命令沒來得及刷回磁盤直接丟失了,除非我們配置刷回策略為 fsnyc = always,但這會損傷性能。解決這個問題的方法是,當一個節點重啟之后,我們規定在 max TTL 期間它是不可用的,這樣它就不會干擾原本已經申請到的鎖,等到它 crash 前的那部分鎖都過期了,環境不存在歷史鎖了,那么再把這個節點加進來正常工作。

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/news/529998.shtml
繁體地址,請注明出處:http://hk.pswp.cn/news/529998.shtml
英文地址,請注明出處:http://en.pswp.cn/news/529998.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

java 兩個數組交叉_java – 如何交叉兩個沒有重復的排序整數數組?

這個問題本質上減少到一個連接操作,然后是一個過濾器操作(刪除重復,只保留內部匹配).由于輸入都已經排序,所以可以通過O(O(size(a)size(b))的merge join來有效地實現連接.過濾器操作將為O(n),因為連接的輸出被排序,并且要刪除重復項,所有您需要做的是檢查每個元素是否與之??前…

java retentionpolicy_Java注解之如何利用RetentionPolicy.SOURCE生存周期

上一篇文章簡單講了下Java注解的學習之元注解說明,學習了Java注解是如何定義的,怎么使用的,但是并沒有介紹Java的注解是怎么起作用的,像Spring Boot里面的那些注解,到底是怎么讓程序這樣子運行起來的?特別是…

在java程序中定義的類有兩種成員_java試題 急需答案 謝謝!!!

三、填空(每小題2分,共10分)1.在Applet中,創建一個具有10行45列的多行文本區對象ta的語句為:2.創建一個標識有“關閉”字樣的標簽對象gb的語句為。3.方法是一種僅有方法頭,沒...三、填空(每小題…

java 同步 變量,在java中的對象上同步,然后更改同步的變量的值

I came across a code like thissynchronized(obj) {obj new Object();}Something does not feel right about this , I am unable to explain, Is this piece of code OK or there is something really wrong in it, please point it out.Thanks解決方案Its probably not wha…

java set泛型_Java 集合二 泛型、Set相關

泛型1、在定義一個類的方法時,因為不確定返回值類型,所以用一個符號代替,這個符號就是泛型eg:ArrayList list new ArrayList();2、泛型的好處:1、提高了數據的安全性,將運行時的問題提前暴露在編譯階段2、避免了強轉的…

java annotation 實現_在Java中如何實現自己的annotation

1. 先定義annotation2. 使用annotation例子:import java.lang.annotation.*;import java.lang.reflect.Method;Target(ElementType.METHOD)Retention(RetentionPolicy.RUNTIME)interface Test {String info() default "";}class Annotated {Test(info &q…

登錄界面攔截java_java攔截通過url訪問頁面,必須通過登錄頁面訪問目標頁面

在web.xml中配置過濾:LoginFiltercom.verification.action.LoginFilterLoginFiltery/form/dealParse.do/* 攔截所有請求/.do 攔截以“.do”結尾的請求/index.jsp 攔截指定的jsp/artery/form/* 攔截該目錄下的所有請求等等攔截器,攔截請求類&#xf…

python textwrap_[Python標準庫]textwrap——格式化文本段落

textwrap——格式化文本段落作用:通過調整換行符在段落中出現的位置來格式化文本。 Python 版本:2.5 及以后版本 需要美觀打印時,可以用 textwrap 模塊來格式化要輸出的文本。這個模塊允許通過編程提供類似段落自動換行或填充…

java 字符串 1_java 字符串操作大全1

1、length() 字符串的長度例:char chars[]{a,b.c};String snew String(chars);int lens.length();2、charAt() 截取一個字符例:char ch;ch"abc".charAt(1); 返回b3、getChars() 截取多個字符void getChars(int sourceStart,int sourceEnd,char…

java實現權限_Java實現權限管理的兩種方式

編輯特別推薦:種方式:利用filter、xml文件和用戶信息表配合使用來實現權限管理。1.過濾器filterpackage cn.com.aaa.bbb.filter;import java.io.IOException;import java.io.InputStream;import java.util.HashMap;import java.util.Iterator;import java.util.List…

java 輸入16進制_嘗試使用十六進制輸入來使用小端和大端

我試圖用這兩個原型編寫C函數:int extract_little (char* str, int ofset, int n);int extract_big(char* str, int ofset, int n);現在一般的想法是我需要從地址str ofset開始以兩種格式返回一個n字節整數 . 附: Ofset還沒有做任何事情,我計…

java gson_Java 中 Gson的使用

JSON 是一種文本形式的數據交換格式,它比XML更輕量、比二進制容易閱讀和編寫,調式也更加方便;解析和生成的方式很多,Java中最常用的類庫有:JSON-Java、Gson、Jackson、FastJson等一、Gson的基本用法Gson提供了fromJson() 和toJson…

spring注入普通java類_普通java類如何取得注入spring Ioc容器的對象

[除了使用XML配置外,還可以選擇使用基于注解(annotation)的配置方式,其依賴于字節碼來織入組件。注解注入在XML注入之前完成,因此在XML配置中可以重載注解注入的屬性。一、建一個SpringUtil類package com.ceopen.eoss.spring; import org.spr…

java web 集成dom4j_[JavaWeb基礎] 031.dom4j寫入xml的方法

上一篇我們講述了dom4j讀取xml的4種方法,甚是精彩,那么怎么樣寫入xml呢?我們直接看下源碼實現。public static void main(String[] args) throws Exception {// 創建文檔Document document DocumentHelper.createDocument();// 設置編碼docu…

java servlet 調試日志 logger sae_java servlet 調試日志 lo

java servlet 調試日志 lo[2021-02-10 08:32:08] 簡介:php去除nbsp的方法:首先創建一個PHP代碼示例文件;然后通過“preg_replace("/(\s|\&nbsp\;| |\xc2\xa0)/", " ", strip_tags($val));”方法去除所有nbsp即可。推薦&#x…

java接口權限管理在哪里_java訪問權限控制

為什么java要有訪問權限的控制?訪問權限的設置和代碼的重構有關。在一個項目中,大多數的時間和金錢都投入到了代碼的維護當中。維護中一定會修改已存在的不合理的代碼。但是在重構的過程中,就出現了這樣的問題:如何保證不影響那些使用了待修…

java8 stream index_Java8的stream用法整理

/***authorindex* date 2020/10/27**/public classTestcollectingAndThen {Testpublic voidtest(){final int NUM 14;List peopleList new ArrayList<>(NUM);String[] names {"小張", "小龍", "小牛", "小豬", "小黑&quo…

memo、 useMemo 和 useCallback語法講解

memo、 useMemo 和 useCallback 緩存組件, 對組件淺比較 (只有組件的props, (對函數,引用要用useCallback包裹)發生變化 緩存值, 依賴項變化&#xff0c;會從新計算。 緩存函數, 依賴項變化,重新生成新函數 useMemo 語法 對返回的值緩存進行優化 const memoizedValue useMem…

java只修改變的字段_java注解之運行時修改字段的注解值操作

今天遇到需求&#xff1a;導入Excel時候列頭會發生變化&#xff0c;客戶是大爺要求你改代碼&#xff0c;導入Excel是用easypoi做的&#xff0c;識別表頭是用注解Excel(name "xxx")通過這個name來匹配那你表頭要動&#xff0c;我這個注解是硬編碼所以就有動態設置這個…

求java簡單計算器源代碼_java簡單計算器源代碼

簡單計算器代碼package calcultorthree;import java.awt.BorderLayout;//導入邊界布局管理器類import java.awt.GridLayout;//導入網格布局管理器類import java.awt.TextField;//導入文本區域類import java.awt.event.ActionEvent;//導入事件類import java.awt.event.ActionLis…