如何在ASP.NET MVC中将WebAPI数据存储为类似DbContext DbSet的可调用形式

你可以通过封装自定义ApiContext类+缓存的方式，模拟EF Core DbContext的使用体验，全程和你现有DbContext、仓储模式的使用逻辑对齐，不需要修改上层业务代码。

步骤1：定义接口返回对应的实体类 #

和EF实体规则一致，先定义和API返回字段匹配的POCO类：

public class Item
{
    public int Id { get; set; }
    public string Name { get; set; }
    public string Material { get; set; }
}

public class Retailer
{
    public int Id { get; set; }
    public string Name { get; set; }
    public string City { get; set; }
}

步骤2：封装ApiContext模拟DbContext #

封装统一的API调用、缓存逻辑，对外暴露类似DbSet的属性/方法，使用方式和原生DbContext完全一致：

public class ApiContext
{
    private readonly HttpClient _httpClient;
    private readonly IMemoryCache _cache;
    // 缓存过期时长，可根据数据更新频率自行调整
    private const int CacheExpireMinutes = 30;

    public ApiContext(HttpClient httpClient, IMemoryCache cache)
    {
        _httpClient = httpClient;
        _cache = cache;
        // 统一配置你的WebAPI根地址
        _httpClient.BaseAddress = new Uri("替换为你自己的WebAPI根地址");
        // 如果API需要鉴权，可在这里统一加请求头，比如JWT Token
        // _httpClient.DefaultRequestHeaders.Add("Authorization", "Bearer 你的Token");
    }

    // 模拟DbSet<Item>，调用方式和DbContext.Items一致
    public async Task<List<Item>> Items()
    {
        const string cacheKey = "Api_Data_Items";
        // 缓存存在直接返回，否则请求API
        if (!_cache.TryGetValue(cacheKey, out List<Item> items))
        {
            var response = await _httpClient.GetAsync("/api/items");
            response.EnsureSuccessStatusCode();
            items = await response.Content.ReadFromJsonAsync<List<Item>>();
            // 写入缓存并设置过期时间
            _cache.Set(cacheKey, items, TimeSpan.FromMinutes(CacheExpireMinutes));
        }
        return items;
    }

    // 同理实现Retailers的访问方法
    public async Task<List<Retailer>> Retailers()
    {
        const string cacheKey = "Api_Data_Retailers";
        if (!_cache.TryGetValue(cacheKey, out List<Retailer> retailers))
        {
            var response = await _httpClient.GetAsync("/api/retailers");
            response.EnsureSuccessStatusCode();
            retailers = await response.Content.ReadFromJsonAsync<List<Retailer>>();
            _cache.Set(cacheKey, retailers, TimeSpan.FromMinutes(CacheExpireMinutes));
        }
        return retailers;
    }

    // 可选：手动清空缓存方法，确认API数据更新时调用刷新本地缓存
    public void ClearCache(string targetCacheKey = null)
    {
        if (string.IsNullOrEmpty(targetCacheKey))
        {
            _cache.Remove("Api_Data_Items");
            _cache.Remove("Api_Data_Retailers");
            return;
        }
        _cache.Remove(targetCacheKey);
    }
}

步骤3：注册服务到依赖注入容器 #

在Program.cs中添加服务注册，和你注册DbContext的逻辑一致：

// 注册内存缓存、HttpClient和自定义ApiContext
builder.Services.AddMemoryCache();
builder.Services.AddHttpClient<ApiContext>();
// 生命周期和默认DbContext保持一致用Scoped即可，也可根据需求调整
builder.Services.AddScoped<ApiContext>();

步骤4：业务代码中调用 #

直接在控制器、仓储类中注入ApiContext即可使用，和你操作原生DbContext的体验完全相同：

public class TestController : Controller
{
    private readonly ApiContext _apiContext;
    // 原来的DbContext也可以同时注入使用
    private readonly YourLocalDbContext _dbContext;

    public TestController(ApiContext apiContext, YourLocalDbContext dbContext)
    {
        _apiContext = apiContext;
        _dbContext = dbContext;
    }

    public async Task<IActionResult> Index()
    {
        // 拿到数据后可以直接用LINQ查询，和操作DbSet没有区别
        var allItems = await _apiContext.Items();
        var goldItems = allItems.Where(x => x.Material == "Gold").ToList();
        var londonRetailers = (await _apiContext.Retailers()).Where(x => x.City == "London").ToList();
        
        return View(new { GoldItems = goldItems, LondonRetailers = londonRetailers });
    }
}

适配现有仓储模式 #

如果你要和现有仓储逻辑对齐，直接给ApiContext实现你已定义的仓储接口即可，上层业务代码不需要做任何修改。

注意事项 #

• 如果数据实时性要求很高，可以直接去掉缓存逻辑，每次调用都请求最新的API数据
• 如果需要对API数据做增删改操作，在ApiContext中封装对应的Post/Put/Delete方法，调用成功后清空对应缓存即可保证数据一致性

内容的提问来源于stack exchange，提问作者Yvonoa