c# - 在 API 中抽象掉对 IMemoryCache 的异步调用

Question

我一直在使用类似于示例 1 的操作来为我的 .NET Core API 异步缓存 json 结果。 MemoryCache 是 IMemoryCache 的实例。

示例 1(按预期工作):

[HttpGet]
public async Task<IActionResult> MyAction() =>
    Json(await MemoryCache.GetOrCreateAsync(
        "MyController_MyAction", 
        entry => myService.GetAllAsync()
    ));

对 Json() 和 MemoryCache.GetOrCreate() 的调用在我的许多操作中都是重复的。在我的真实应用程序中，甚至还有更多重复的实现细节，例如设置 AbsoluteExpirationRelativeToNow 值和为空值返回 NotFound()。我想将所有这些抽象到一个共享方法中，以便每个操作仅将其唯一的细节传递给共享方法的调用。

为此，我为我的操作中的两个变量分别提取了一个变量。例如:

示例 2(缓存既未更新也未从中检索):

[HttpGet]
public async Task<IActionResult> MyAction()
{
    var task = myService.GetAllAsync();
    const string cacheKey = "MyController_MyAction";
    return Json(await MemoryCache.GetOrCreateAsync(cacheKey, entry => task));
}

下一步是提取一个共享方法 Get()，例如:

示例 3(不起作用，因为示例 2 不起作用):

[HttpGet]
public async Task<IActionResult> MyAction()
{
    var task = myService.GetAllAsync();
    const string cacheKey = "MyController_MyAction";
    return await Get(task, cacheKey);
}

protected async Task<IActionResult> Get(Task<T> task, string cacheKey =>
    return Json(await MemoryCache.GetOrCreateAsync(cacheKey, entry => task));

示例 1 成功地从缓存中检索了后续结果。然而，示例 2 在后续请求的缓存中发现 null 并且每次都重新检索数据(通过 temp debug TryGetValue() 语句验证以及监视底层SQL 查询命中我的数据库)。

对我来说，示例 1 和示例 2 应该是相同的。但是，也许我对 async/await 和 Tasks 的理解还不够(很有可能)。

如何从我的操作中抽象出重复的实现细节(例如 Json() 和 MemoryCache.GetOrCreate() 调用)，同时仍然成功地更新和检索IMemoryCache 以异步方式？

Answer 1

var task = myService.GetAllAsync();

这将已经运行 GetAllAsync方法，因此通过这样做，您可以防止内存缓存的惰性行为，即它只会在缓存键不可用时调用该方法。

为了继续这样做，您必须存储一个创建值的实际表达式，因此您必须这样做:

Func<MyObject> createValue = () => myService.GetAllAsync();
const string cacheKey = "MyController_MyAction";
return Json(await MemoryCache.GetOrCreateAsync(cacheKey, entry => createValue()));

因此，将其抽象化，这就是您最终可能得到的:

public Task<IActionResult> MyAction()
    => GetCache("MyController_MyAction", () => myService.GetAllAsync());

该方法将像这样实现:

private async Task<IActionResult> GetCache<T>(string cacheKey, Func<Task<T>> createAction)
{
    var result = await MemoryCache.GetOrCreateAsync(cacheKey, entry => createAction());
    return Json(result);
}

如果缓存键总是<ControllerName>_<ActionName> ，您甚至可以更进一步，并使用 CallerMemberNameAttribute 从调用中自动推断出这一点:

private async Task<IActionResult> GetCache<T>(Func<Task<T>> createAction, [CallerMemberName] string actionName = null)
{
    var cacheKey = GetType().Name + "_" + actionName;
    var result = await MemoryCache.GetOrCreateAsync(cacheKey, entry => createAction());
    return Json(result);
}

所以你可以像这样使用它:

public Task<IActionResult> MyAction()
    => GetCache(() => myService.GetAllAsync());