DefaultResponseCacheProvider.cs

using Microsoft.Extensions.Caching.Memory;
using System;
using System.Threading.Tasks;

namespace WebApiClientCore.Implementations
{
    /// <summary>
    /// 表示Api响应结果缓存提供者的接口
    /// </summary>
    sealed class DefaultResponseCacheProvider : Disposable, IResponseCacheProvider
    {
        /// <summary>
        /// 内存缓存
        /// </summary>
        private readonly IMemoryCache cache;

        /// <summary>
        /// 获取提供者的友好名称
        /// </summary>
        public string Name { get; } = nameof(DefaultResponseCacheProvider);

        /// <summary>
        /// Api响应结果缓存提供者的接口
        /// </summary>
        /// <param name="cache"></param>
        public DefaultResponseCacheProvider(IMemoryCache cache)
        {
            this.cache = cache;
        }

        /// <summary>
        /// 从缓存中获取响应实体
        /// </summary>
        /// <param name="key">键</param>
        /// <returns></returns>
        public Task<ResponseCacheResult> GetAsync(string key)
        {
            if (this.cache.TryGetValue(key, out var value) == false)
            {
                var result = ResponseCacheResult.NoValue;
                return Task.FromResult(result);
            }
            else
            {
                var val = value as ResponseCacheEntry;
                var result = new ResponseCacheResult(val, true);
                return Task.FromResult(result);
            }
        }

        /// <summary>
        /// 设置响应实体到缓存
        /// </summary>
        /// <param name="key">键</param>
        /// <param name="entry">缓存实体</param>
        /// <param name="expiration">有效时间</param>
        /// <returns></returns>
        public Task SetAsync(string key, ResponseCacheEntry entry, TimeSpan expiration)
        {
            this.cache.Set(key, entry, DateTimeOffset.Now.Add(expiration));
            return Task.CompletedTask;
        }

        /// <summary>
        /// 释放资源
        /// </summary>
        /// <param name="disposing"></param>
        protected override void Dispose(bool disposing)
        {
            this.cache.Dispose();
        }
    }
}