c# 如何用lock解决缓存击穿

2023-07-06 01:21:03 274

背景

缓存击穿是指缓存中没有但数据库中有的数据（一般是缓存时间到期），这时由于并发用户特别多，同时读缓存没读到数据，又同时去数据库去取数据，引起数据库压力瞬间增大，造成过大压力。

解决方案

1、设置热点数据永远不过期。

2、加互斥锁，互斥锁参考代码如下：

2.1、根据key生成object()

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

returnlockObject;
}
}

2.2、lock住GetMemoryCacheLockObject(key)

publicTGet(stringkey,FuncgetDataWork,TimeSpanabsoluteExpireTime,boolforceRefresh=false,boolreturnCopy=true)whereT:class
{
try
{
lock(GetMemoryCacheLockObject(key))
{
/*
System.ArgumentNullException:Valuecannotbenull.
atSystem.Threading.Monitor.Enter(Objectobj)
atBQoolCommon.Helpers.Cache.MemoryCacheLayer.Get[T](Stringkey,Func`1getDataWork,TimeSpanabsoluteExpireTime,BooleanforceRefresh,BooleanreturnCopy)inD:\Source\BQoolCommon\BQoolCommon.Helpers\Cache\MemoryCacheLayer.cs:line46
*/
Tresult=CacheObject[key]asT;

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

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

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

if(returnCopy)
{
//複製一份新的參考
stringserialize=JsonConvert.SerializeObject(result);
returnJsonConvert.DeserializeObject(serialize);
}
else
{
returnresult;
}
}
}
catch
{
returngetDataWork();
}
}

总结说明

1、缓存中有数据，直接走下述代码就返回结果了

Tresult=CacheObject[key]asT;

2、缓存中没有数据，第1个进入的线程，获取锁并从数据库去取数据，没释放锁之前，其他并行进入的线程会等待，再重新去缓存取数据。这样就防止都去数据库重复取数据，重复往缓存中更新数据情况出现。

try
{
lock(GetMemoryCacheLockObject(key))
{
/*
System.ArgumentNullException:Valuecannotbenull.
atSystem.Threading.Monitor.Enter(Objectobj)
atBQoolCommon.Helpers.Cache.MemoryCacheLayer.Get[T](Stringkey,Func`1getDataWork,TimeSpanabsoluteExpireTime,BooleanforceRefresh,BooleanreturnCopy)inD:\Source\BQoolCommon\BQoolCommon.Helpers\Cache\MemoryCacheLayer.cs:line46
*/
Tresult=CacheObject[key]asT;

3、取得每个Key专有的lockobject；若同时有多个thread要求相同资料，只会(到数据库)查第一次，剩下的从cache读取。

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

以上就是c#如何用lock解决缓存击穿的详细内容，更多关于c#lock解决缓存击穿的资料请关注毛票票其它相关文章！