C#中如何配置数据库的查询缓存？使用MemoryCache？-C#.Net教程-PHP中文网

C#中如何配置数据库的查询缓存？使用MemoryCache？

煙雲

发布： 2025-10-14 08:57:01

原创

619人浏览过

MemoryCache适用于单机环境下的数据库查询缓存，通过减少数据库访问提升性能。1. 使用MemoryCache因其实现简单、读取高效，适合数据变更少、查询复杂度高、重复请求多的场景。2. 基本用法为封装查询逻辑并以唯一键存储结果，设置绝对或滑动过期策略。3. 缓存失效可通过定时过期或数据更新时主动清除实现，如更新产品后移除对应分类缓存。4. 注意缓存键设计唯一、避免缓存大对象导致内存溢出，监控内存使用，并在多服务器场景下改用Redis等分布式方案。合理控制缓存粒度与更新机制可有效防止脏数据，适用于中小型项目。

c#中如何配置数据库的查询缓存？使用memorycache？

在C#中配置数据库查询缓存，MemoryCache 是一个简单有效的选择，尤其适用于单机应用或不需要分布式缓存的场景。它能减少对数据库的频繁访问，提升响应速度。

1. 为什么使用 MemoryCache？

MemoryCache 是 .NET 提供的内存缓存类，运行在应用程序进程中，读取速度快，适合缓存短时间内的数据库查询结果。

适用场景：

数据变更不频繁
查询开销大（如复杂 Join 或聚合）
多请求重复访问相同数据

2. 基本用法：封装查询 + 缓存

以下是一个使用 MemoryCache 缓存数据库查询结果的示例：

using System.Runtime.Caching;

public class ProductService
{
    private readonly MemoryCache _cache = MemoryCache.Default;

    public List<Product> GetProducts(int categoryId)
    {
        string cacheKey = $"products_category_{categoryId}";

        // 尝试从缓存获取
        var products = _cache.Get(cacheKey) as List<Product>;
        if (products != null)
            return products;

        // 缓存未命中，查询数据库
        products = QueryDatabase(categoryId);

        // 写入缓存，设置过期策略
        var policy = new CacheItemPolicy
        {
            AbsoluteExpiration = DateTimeOffset.Now.AddMinutes(10), // 10分钟后过期
            // 或使用滑动过期：SlidingExpiration = TimeSpan.FromMinutes(5)
        };
        _cache.Set(cacheKey, products, policy);

        return products;
    }

    private List<Product> QueryDatabase(int categoryId)
    {
        // 模拟数据库查询
        using var conn = new SqlConnection("your_connection_string");
        // ... 查询逻辑
        return new List<Product>(); // 返回实际数据
    }
}

登录后复制

3. 缓存更新与失效策略

缓存的关键是保证数据不过时。常见做法：

MyBatis3.2.3帮助文档中文CHM版

MyBatis 是支持普通 SQL 查询,存储过程和高级映射的优秀持久层框架。MyBatis 消除了几乎所有的 JDBC 代码和参数的手工设置以及结果集的检索。MyBatis 使用简单的 XML 或注解用于配置和原始映射,将接口和 Java 的 POJOs(Plan Old Java Objects,普通的 Java 对象)映射成数据库中的记录。有需要的朋友可以下载看看

查看详情

定时过期：设置 AbsoluteExpiration 或 SlidingExpiration
主动清除：当数据更新时手动移除缓存项

例如，在更新产品后清除缓存：

public void UpdateProduct(Product product)
{
    // 执行数据库更新
    ExecuteUpdate(product);

    // 清除相关缓存
    _cache.Remove($"products_category_{product.CategoryId}");
}

登录后复制