当前位置：首页 > article >正文

如何在.NET Core中解决缓存穿透、缓存雪崩和缓存击穿问题：多级缓存策略详解

article 2025/3/5 4:31:19

在构建高性能的分布式系统时，缓存是一个必不可少的组件。它能显著提高系统的响应速度，减少对数据库的访问压力。然而，缓存机制的设计需要注意一些常见的问题，如缓存穿透、缓存雪崩和缓存击穿，这些问题若处理不当，会导致系统性能下降，甚至系统崩溃。

本文将详细介绍如何在.NET Core中解决这些问题，尤其是通过多级缓存策略来提高系统的性能和稳定性。

一、缓存穿透：如何避免查询无效数据

什么是缓存穿透？

缓存穿透是指查询的数据既不在缓存中，也不在数据库中。当发生缓存穿透时，所有的请求都会直接访问数据库，导致数据库压力增大，系统性能下降。典型的例子是，用户查询的某个数据根本不存在，但是每个请求都会直接访问数据库进行查询。

解决方法：

缓存空数据：为了避免每次请求都查询数据库，可以在缓存中保存“空数据”。当查询的数据不存在时，我们将空结果（例如null或空字符串）缓存一定时间，之后的相同请求将直接从缓存中获取空数据，从而避免重复查询数据库。

public async Task<string> GetDataAsync(string key)
{
    var cachedResult = await _cache.GetStringAsync(key);
    if (cachedResult == null)
    {
        // 查询数据库
        var dbResult = GetDataFromDatabase(key);
        
        if (dbResult == null)
        {
            // 数据库中也不存在，缓存空结果
            await _cache.SetStringAsync(key, string.Empty, TimeSpan.FromMinutes(5));  // 设置一个较短的过期时间
            return null;
        }
        
        // 数据库查询结果缓存
        await _cache.SetStringAsync(key, dbResult, TimeSpan.FromMinutes(30));
        return dbResult;
    }

    return cachedResult == string.Empty ? null : cachedResult;
}

请求参数校验：在查询数据库之前，对请求参数进行校验。如果请求的参数无效（例如非法的ID或格式错误），则可以直接返回错误信息，避免恶意请求或无效请求进入缓存查询逻辑。

例如，检查用户请求的ID是否符合合法格式，若不合法，直接返回错误提示。

二、缓存雪崩：避免大量数据同时失效

什么是缓存雪崩？

缓存雪崩是指缓存中大量数据在同一时刻失效，导致大量请求直接访问数据库。这种情况通常发生在缓存的失效时间设置过于集中，导致大量缓存同时过期，从而给数据库带来巨大的负载。

解决方法：

随机过期时间：为每个缓存项设置不同的过期时间，通过加入随机偏移量来避免大量缓存同时过期，分散过期的时间点，减少数据库的压力。

public void SetCacheWithRandomExpiration(string key, string value)
{
    var randomOffset = new Random().Next(1, 60); // 随机生成1到60分钟的偏移量
    _cache.Set(key, value, TimeSpan.FromMinutes(30 + randomOffset)); // 设置缓存，过期时间是30分钟加上偏移量
}

缓存预热（提前加载缓存）：可以在系统流量较低时（例如凌晨）主动预加载缓存，将热点数据提前加载到缓存中，以避免高峰期大量请求直接访问数据库。
```
public void PreloadCache()
{
    var data = GetDataFromDatabase();
    _cache.Set("some_key", data, TimeSpan.FromMinutes(30));  // 预热缓存
}
```
使用滑动过期：滑动过期是一种缓存过期策略，不是在固定时间点过期，而是根据缓存的访问时间来重新计算过期时间。例如，每次访问缓存时，过期时间会重新设置。
```
_cache.Set("some_key", value, new MemoryCacheEntryOptions
{
    SlidingExpiration = TimeSpan.FromMinutes(30) // 滑动过期
});
```

三、缓存击穿：避免热门数据失效时压力剧增

什么是缓存击穿？

缓存击穿是指某一热点数据的缓存失效，导致大量请求同时访问数据库。通常发生在某些热点数据（如用户信息、商品详情等）缓存过期时。如果没有有效的控制措施，所有请求都将同时查询数据库，给数据库带来巨大的压力。

解决方法：

分布式锁机制：使用分布式锁可以保证同一时刻只有一个请求能够查询数据库并更新缓存，其他请求则等待获取最新的缓存结果。这样可以避免多个请求同时查询数据库，造成数据库的压力。

public async Task<string> GetDataWithLockAsync(string key)
{
    var lockKey = $"{key}_lock";
    
    // 获取分布式锁，确保只有一个线程查询数据库
    var lockAcquired = await _redisLock.TryAcquireLockAsync(lockKey, TimeSpan.FromSeconds(10));
    if (!lockAcquired)
    {
        // 锁被其他请求持有，稍后重试
        await Task.Delay(1000);
        return await GetDataWithLockAsync(key);
    }
    
    try
    {
        // 查询缓存
        var cachedResult = await _cache.GetStringAsync(key);
        if (cachedResult != null)
        {
            return cachedResult;
        }
        
        // 缓存没有，查询数据库
        var dbResult = GetDataFromDatabase(key);
        await _cache.SetStringAsync(key, dbResult, TimeSpan.FromMinutes(30));
        return dbResult;
    }
    finally
    {
        // 释放锁
        await _redisLock.ReleaseLockAsync(lockKey);
    }
}

多级缓存：本地缓存与分布式缓存结合使用 使用多级缓存策略，首先尝试从本地缓存（如 MemoryCache）获取数据，如果本地缓存中没有，再尝试从分布式缓存（如 Redis）获取，如果Redis中也没有，则最后查询数据库。通过这种方式，我们可以减轻数据库压力，提高缓存命中率。

public async Task<string> GetDataWithMultiLevelCache(string key)
{
    // 1. 从本地缓存中查找
    var localCache = _memoryCache.Get<string>(key);
    if (localCache != null)
    {
        return localCache;
    }
    
    // 2. 从分布式缓存（如 Redis）获取
    var distributedCache = await _redisCache.GetStringAsync(key);
    if (distributedCache != null)
    {
        // 设置本地缓存
        _memoryCache.Set(key, distributedCache, TimeSpan.FromMinutes(30));
        return distributedCache;
    }
    
    // 3. 从数据库获取
    var dbResult = GetDataFromDatabase(key);
    if (dbResult != null)
    {
        _memoryCache.Set(key, dbResult, TimeSpan.FromMinutes(30));
        await _redisCache.SetStringAsync(key, dbResult, TimeSpan.FromMinutes(30));
    }
    
    return dbResult;
}