C Redis分布式鎖的應用

2021-10-10 14:45:22 字數 2484 閱讀 1251

我們在開發很多業務場景會使用到鎖,例如庫存控制,**等。一般我們會使用記憶體鎖的方式來保證線性的執行。但現在大多站點都會使用分布式部署,那多台伺服器間的就必須使用同乙個目標來判斷鎖。分布式與單機情況下最大的不同在於其不是多執行緒而是多程序。

[分布式站點使用記憶體鎖方式如下圖]

假設有3個使用者同時購買一件商品,商品庫存只剩下1,如果3個使用者同時購買,負載均衡把3個使用者分別指向站點1、2、3,那結果將會是3個使用者都購買成功。下面我們使用分布式鎖解決這個問題。

[分布式站點使用分布式鎖如下圖]

單台伺服器由於可以共享堆記憶體,因此可以簡單的採取記憶體作為標記儲存位置。而多伺服器之間都不在同一臺物理機上,因此需要將標記儲存在乙個所有程序都能看到的地方。

想想我們實現分布式鎖要滿足哪些條件?

1、在分布式系統環境下,乙個鎖在同一時間只能被乙個伺服器獲取;(這是所有分布式鎖的基礎)

2、高效能的獲取鎖和釋放鎖;(鎖用完了,要及時釋放,以供別人繼續使用)

3、具備鎖失效機制,防止死鎖;(防止因為某些意外,鎖沒有得到釋放,那別人將永遠無法使用)

4、具備非阻塞鎖特性,即沒有獲取到鎖將直接返回獲取鎖失敗。(滿足等待鎖的同時,也要滿足非阻塞鎖特性,便於多樣性的業務場景使用)

分布式鎖有很多的實現方式:資料庫排他鎖、zookeeper、快取(redis、memcached)等,本文選用redis實現。原因如下:

1、redis有很高的效能;

2、redis命令對此支援較好,實現起來比較方便;

redis官網上對c#的使用推薦有servicestack.redis和stackexchange.redis

由於stackexchange.redis雖然有提供locktake方法,很方便的使用鎖,但是只支援.net4.5以上。公司很多站點都是3.5和4.0的,所以選用servicestack.redis,自己封裝一下。

1、setnx

setnx key val:當且僅當key不存在時,set乙個key為val的字串,返回1;若key存在,則什麼都不做,返回0。

2、expire

expire key timeout:為key設定乙個超時時間,單位為second,超過這個時間鎖會自動釋放,避免死鎖。

3、delete

delete key:刪除key

在使用redis實現分布式鎖的時候,主要就會使用到這三個命令。

1、鎖方法

////// 分布式鎖////// 鎖key

/// 鎖自動超時時間(秒)

/// 等待鎖時間(秒)

///

public static bool lock(string key, int lockexpiryseconds = 10, double waitlockseconds = 0)

) == 1)

//不等待鎖則返回

if (waitlockseconds == 0) break;

//超過等待時間,則不再等待

if ((datetime.now - begin).totalseconds >= waitlockseconds) break;

thread.sleep(waitintervalms);

}

return false;

}

}

2、釋放鎖

////// 刪除鎖 執行完**以後呼叫釋放鎖//////

public static void dellock(string key)

}

3、業務應用**

try}finally

C Redis分布式快取

六 查詢資料 在c redis實戰 五 中介紹了如何刪除redis中資料,本篇將繼續介紹redis中查詢的寫法。1 使用linq匹配關鍵字查詢 using var redisclient redismanager.getclient var user redisclient.gettypedc.五 ...

C redis 分布式session儲存

乙個基於redis的session儲存擴充套件方案,解決asp.net中session的侷限性和跨應用程式使用的侷限性 1 branch 0 releases 1 contributor c 99.3 asp 0.7 c asp branch master sessionextentionstore...

C redis 分布式session儲存

乙個基於redis的session儲存擴充套件方案,解決asp.net中session的侷限性和跨應用程式使用的侷限性 1 branch 0 releases 1 contributor c 99.3 asp 0.7 c asp branch master sessionextentionstore...