快捷導(dǎo)航

c# 如何用lock解決緩存擊穿

更新時間：2021年02月01日 11:59:48 作者：UP技術(shù)控

這篇文章主要介紹了c# 如何用lock解決緩存擊穿，幫助大家更好的理解和使用c#，感興趣的朋友可以了解下

1、緩存中有數(shù)據(jù)，直接走下述代碼就返回結(jié)果了
2、緩存中沒有數(shù)據(jù)，第1個進入的線程，獲取鎖并從數(shù)據(jù)庫去取數(shù)據(jù)，沒釋放鎖之前，其他并行進入的線程會等待，再重新去緩存取數(shù)據(jù)。這樣就防止都去數(shù)據(jù)庫重復(fù)取數(shù)據(jù)，重復(fù)往緩存中更新數(shù)據(jù)情況出現(xiàn)。
3、取得每個 Key專有的 lock object；若同時有多個 thread要求相同資料，只會(到數(shù)據(jù)庫)查第一次，剩下的從 cache讀取。

背景

緩存擊穿是指緩存中沒有但數(shù)據(jù)庫中有的數(shù)據(jù)（一般是緩存時間到期），這時由于并發(fā)用戶特別多，同時讀緩存沒讀到數(shù)據(jù)，又同時去數(shù)據(jù)庫去取數(shù)據(jù)，引起數(shù)據(jù)庫壓力瞬間增大，造成過大壓力。

解決方案

1、設(shè)置熱點數(shù)據(jù)永遠(yuǎn)不過期。

2、加互斥鎖，互斥鎖參考代碼如下：

2.1、根據(jù)key生成object()

private static object GetMemoryCacheLockObject(string key)
    {
      string cacheLockKey = string.Format(MemoryCacheLockObjectFormat, key);
      lock (CacheObject)
      {
        var lockObject = CacheObject[cacheLockKey];
        if (lockObject == null)
        {
          // 取得每個 Key專屬的 lock object；若同時有多個 thread要求相同資料，只會(到資料庫)查第一次，剩下的從 cache讀取
          lockObject = new object();
          CacheObject.Set(
            cacheLockKey,
            lockObject,
            new System.Runtime.Caching.CacheItemPolicy()
            {
              AbsoluteExpiration = DateTimeOffset.UtcNow.AddMinutes(10)
            }
          );
        }

        return lockObject;
      }
    }

2.2、lock住GetMemoryCacheLockObject(key)

public T Get<T>(string key, Func<T> getDataWork, TimeSpan absoluteExpireTime, bool forceRefresh = false, bool returnCopy = true) where T : class
    {
      try
      {
        lock (GetMemoryCacheLockObject(key))
        {
          /*
System.ArgumentNullException: Value cannot be null.
at System.Threading.Monitor.Enter(Object obj)
at BQoolCommon.Helpers.Cache.MemoryCacheLayer.Get[T](String key, Func`1 getDataWork, TimeSpan absoluteExpireTime, Boolean forceRefresh, Boolean returnCopy) in D:\Source\BQoolCommon\BQoolCommon.Helpers\Cache\MemoryCacheLayer.cs:line 46
           */
          T result = CacheObject[key] as T;

          if (result != null && forceRefresh)
          {// 是否清除Cache，強制重查
            result = null;
          }

          if (result == null)
          {
            //執(zhí)行取得資料的委派作業(yè)
            result = getDataWork();

            if (result != null)
            {
              Set(key, result, absoluteExpireTime);
            }
          }

          if (returnCopy)
          {
            //複製一份新的參考
            string serialize = JsonConvert.SerializeObject(result);
            return JsonConvert.DeserializeObject<T>(serialize);
          }
          else
          {
            return result;
          }
        }
      }
      catch
      {
        return getDataWork();
      }
    }

總結(jié)說明

1、緩存中有數(shù)據(jù)，直接走下述代碼就返回結(jié)果了

 T result = CacheObject[key] as T;

2、緩存中沒有數(shù)據(jù)，第1個進入的線程，獲取鎖并從數(shù)據(jù)庫去取數(shù)據(jù)，沒釋放鎖之前，其他并行進入的線程會等待，再重新去緩存取數(shù)據(jù)。這樣就防止都去數(shù)據(jù)庫重復(fù)取數(shù)據(jù)，重復(fù)往緩存中更新數(shù)據(jù)情況出現(xiàn)。

try
      {
        lock (GetMemoryCacheLockObject(key))
        {
          /*
System.ArgumentNullException: Value cannot be null.
at System.Threading.Monitor.Enter(Object obj)
at BQoolCommon.Helpers.Cache.MemoryCacheLayer.Get[T](String key, Func`1 getDataWork, TimeSpan absoluteExpireTime, Boolean forceRefresh, Boolean returnCopy) in D:\Source\BQoolCommon\BQoolCommon.Helpers\Cache\MemoryCacheLayer.cs:line 46
           */
          T result = CacheObject[key] as T;

3、取得每個 Key專有的 lock object；若同時有多個 thread要求相同資料，只會(到數(shù)據(jù)庫)查第一次，剩下的從 cache讀取。

string cacheLockKey = string.Format(MemoryCacheLockObjectFormat, key);
      lock (CacheObject)
      {
        var lockObject = CacheObject[cacheLockKey];
        if (lockObject == null)
        {
          // 取得每個 Key專屬的 lock object；若同時有多個 thread要求相同資料，只會(到資料庫)查第一次，剩下的從 cache讀取
          lockObject = new object();

以上就是c# 如何用lock解決緩存擊穿的詳細(xì)內(nèi)容，更多關(guān)于c# lock解決緩存擊穿的資料請關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: