系統(tǒng)分布式鎖的用法

公司框架新增功能分布式鎖：

鎖的性能之王：緩存 > Zookeeper >= 數據庫

鎖的實現

實現原理：核心采用StackExchange.Redis的LockTake方法實現。
支持同步獲取鎖，或者等待直到超時獲取鎖。

/// <summary>/// 分布式鎖，提供全局分布式鎖支持，以resource redis為基礎/// 這個鎖只能通過RpcContext來獲取，通過自己手動釋放/// </summary>public sealed class DistributedLock{private static readonly TimeSpan DefaultAbandonmentCheckFrequency = TimeSpan.FromSeconds(2);public readonly string lockName;private readonly string lockValue;private readonly int checkTimeSpan = 50; //msprivate readonly int autoDelete;private DistributedLock(){}/// <summary>/// /// </summary>/// <param name="lockName"></param>/// <param name="autoDelete">自動刪除，ms,默認 60s</param>/// <param name="checkTimeSpan">如果不能獲取鎖，重復檢查間隔:默認 50ms</param>internal DistributedLock(string lockName, int autoDelete = 60000,int checkTimeSpan = 50){// note that just Global\ is not a valid nameif (string.IsNullOrEmpty(lockName))throw new ArgumentNullException("lockName不能為空");if (null == ResourceCache.Instance)throw new Exception(@"ResourceCache 沒有配置或無法連接");this.checkTimeSpan = Math.Max(checkTimeSpan,1);this.autoDelete = Math.Max(autoDelete,1);this.lockName = lockName;this.lockValue = lockName;}/// <summary>/// 獲取鎖/// </summary>/// <param name="timeout">超時為null，則嘗試一次即返回</param>/// <returns>獲取鎖成功?</returns>internal bool Acquire(TimeSpan? timeout = null){bool bLock = false;var dtStart = DateTime.Now.Ticks;while (!bLock){bLock = TryAcquireOnce();if (timeout == null){break;}if (!bLock){Thread.Sleep(this.checkTimeSpan);}var ts = new TimeSpan(DateTime.Now.Ticks - dtStart);if (ts >= timeout){break;}}return bLock;}//此處采用框架上下文管理分布式事務鎖的釋放，代碼略。//public void Dispose()//{// LockManager.ReleaseLock(this);//}internal void Release(){try{var bRtn = ResourceCache.Instance.LockRelease(this.lockName, this.lockValue);Trace.WriteLine($"釋放鎖 {this.lockName}:{bRtn}");}catch (Exception e){LogTextWriter.Write($"釋放鎖失敗，系統(tǒng)自動超時釋放:{this.lockName}");}}/// <summary>/// 釋放鎖/// </summary>public void ReleaseLock(){LockManager.ReleaseLock(this);}private bool TryAcquireOnce(){try{Trace.WriteLine($"{Thread.CurrentThread.ManagedThreadId}:TryAcquireOnce");var @lock = ResourceCache.Instance.LockTake(this.lockName, this.lockValue, new TimeSpan(0, 0, 0, 0, this.autoDelete));return @lock;}catch (Exception e){return false;}}}

鎖的使用

在當前上下文中獲取一個分布式鎖，第一個獲取鎖的將執(zhí)行依賴當前key（一般為業(yè)務主鍵）的完整業(yè)務流程（包括多個微服務之間的調用和數據庫的訪問;

后來者將無法獲取鎖，根據返回的結果來判斷是否進入流程，如果返回的鎖為null將不能執(zhí)行下面的流程，要么重試等待鎖釋放，要么返回錯誤.

鎖的調用一般流程：

var qtLock=TryGetLock(lockKey);if(qtLock==null) { //提示不能同時執(zhí)行操作return；}else {//進行業(yè)務流程}//最后別忘了qtLock.ReleaseLock();

API 內的范例：

code = StatusCode.OK;//傳入超時時間，可以一直等待到超時過期var lockSaveReceipt = this.Context.TryGetLock($"{nameof(SaveReceipt)}.{valueArgs.ReceiptArgs.ReceiptId}");if (lockSaveReceipt == null){code = PublicErrorCode.SaveReceiptByUsed.ToCode();return null;}try{//todo 業(yè)務操作1//todo 業(yè)務操作2//...}finally{lockSaveReceipt.ReleaseLock();}

總結

以上是生活随笔為你收集整理的.net core 下的分布式事务锁的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。