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

.NET Core 中如何实现缓存的预热？

article 2025/3/15 12:16:12

在构建高性能的 .NET Core 应用时，缓存是提升系统响应速度、减轻数据库压力的利器。然而，缓存并非一蹴而就，它也需要“热身”才能发挥最佳性能。这就是缓存预热的意义所在。

一、什么是缓存预热？

缓存预热，顾名思义，就是在系统启动或缓存失效后，主动将热点数据加载到缓存中，避免用户首次请求时直接访问数据库，造成性能瓶颈。

二、为什么需要缓存预热？

提升用户体验: 缓存预热可以避免用户首次访问时出现延迟，提升用户体验。
降低数据库压力: 缓存预热可以将数据库的访问压力分散到系统启动阶段，避免高峰期数据库过载。
提高系统稳定性: 缓存预热可以避免缓存击穿和缓存雪崩等问题，提高系统稳定性。

三、.NET Core 中实现缓存预热的方式

.NET Core 提供了多种缓存机制，例如内存缓存、分布式缓存等。我们可以根据不同的缓存类型，选择不同的预热方式。

1. 内存缓存预热

启动时预热: 在 Startup.cs 文件的 Configure 方法中，通过 IHostApplicationLifetime 接口注册应用启动事件，在应用启动时加载数据到内存缓存中。

public void Configure(IApplicationBuilder app, IHostApplicationLifetime lifetime)
{
    lifetime.ApplicationStarted.Register(() =>
    {
        var cache = app.ApplicationServices.GetService<IMemoryCache>();
        // 从数据库加载热点数据
        var hotData = GetHotDataFromDatabase();
        // 将数据存入缓存
        cache.Set("HotData", hotData);
    });
}

定时任务预热: 使用 IHostedService 接口创建后台服务，定时从数据库加载数据到内存缓存中。

public class CacheWarmupService : IHostedService, IDisposable
{
    private readonly IMemoryCache _cache;
    private Timer _timer;

    public CacheWarmupService(IMemoryCache cache)
    {
        _cache = cache;
    }

    public Task StartAsync(CancellationToken cancellationToken)
    {
        _timer = new Timer(DoWork, null, TimeSpan.Zero, TimeSpan.FromMinutes(10));
        return Task.CompletedTask;
    }

    private void DoWork(object state)
    {
        // 从数据库加载热点数据
        var hotData = GetHotDataFromDatabase();
        // 将数据存入缓存
        _cache.Set("HotData", hotData);
    }

    public Task StopAsync(CancellationToken cancellationToken)
    {
        _timer?.Change(Timeout.Infinite, 0);
        return Task.CompletedTask;
    }

    public void Dispose()
    {
        _timer?.Dispose();
    }
}

2. 分布式缓存预热

启动时预热: 与内存缓存类似，可以在应用启动时加载数据到分布式缓存中。

public void Configure(IApplicationBuilder app, IHostApplicationLifetime lifetime)
{
    lifetime.ApplicationStarted.Register(() =>
    {
        var cache = app.ApplicationServices.GetService<IDistributedCache>();
        // 从数据库加载热点数据
        var hotData = GetHotDataFromDatabase();
        // 将数据存入缓存
        cache.SetString("HotData", JsonConvert.SerializeObject(hotData));
    });
}