.Net Core缓存组件(Redis)源码解析

public void ConfigureServices(IServiceCollection services){ ?????services.AddMvc(); ?????services.AddDistributedRedisCache(option => ?????{ ??????????option.Configuration = "121.41.55.55:6379";//连接字符串 ??????????option.InstanceName = "test"; ?????});}

public class ValuesController : Controller{ ???????private readonly IDistributedCache redisCache; ???????public ValuesController(IDistributedCache redisCache) ???????{ ???????????this.redisCache = redisCache; ???????} ???????[HttpGet] ???????public IEnumerable<string> Get() ???????{ ???????????redisCache.SetAsync("key1", Encoding.UTF8.GetBytes("value1"), new DistributedCacheEntryOptions() ???????????{ ???????????????AbsoluteExpiration = DateTime.Now.AddSeconds(10)//设置过期时间，时间一到缓存立刻就被移除了 ???????????}); ???????????redisCache.SetString("key2", "value2");//没有设置缓存过期时间，表示是永久缓存 ???????????return new string[] { "value1", "value2" }; ???????}}

 ???????public static IServiceCollection AddDistributedRedisCache(this IServiceCollection services, Action<RedisCacheOptions> setupAction) ???????{ ???????????if (services == null) ???????????{ ???????????????throw new ArgumentNullException(nameof(services)); ???????????} ???????????if (setupAction == null) ???????????{ ???????????????throw new ArgumentNullException(nameof(setupAction)); ???????????} ???????????services.AddOptions(); ???????????services.Configure(setupAction); ???????????services.Add(ServiceDescriptor.Singleton<IDistributedCache, RedisCache>());//注入一个单例 ???????????return services; ???????}

public void Set(string key, byte[] value, DistributedCacheEntryOptions options) ?????
 ?{ ?????????　//省略一些逻辑判断 ???????????Connect(); ???????????var creationTime = DateTimeOffset.UtcNow;　　　　　　　//对于一个缓存可以设置为绝对过期时间，相对于现在时间的过期时间和滑动过期时间三种(上一篇文章有例子)，其实前两种时间类型可以相互转换。
　　　　　　　//下面这一步就是 如果设置了绝对过期时间或者相对于现在时间的过期时间，装换为绝对过期时间 ???????????var absoluteExpiration = GetAbsoluteExpiration(creationTime, options);　　　　　　　//调用了StackExchange.Redis的API 插入缓存 ???????????var result = _cache.ScriptEvaluate(SetScript, new RedisKey[] { _instance + key },//这里的key是实例名称+key=Redis中的key,当然我们在查找缓存的时候，并不需要我们手动拼接，只需要传我们复制的key，不需要实例名称
　　　　　　 ???????????????new RedisValue[] ???????????????{ ???????????????????????absoluteExpiration?.Ticks ?? NotPresent, ???????????????????????options.SlidingExpiration?.Ticks ?? NotPresent,
　　　　　　　　　　　　　　　//如果对于一个缓存同时设置了绝对过期时间和滑动过期时间，则取即将到期的时间，也就是最小的那个时间。 ???????????????????????GetExpirationInSeconds(creationTime, absoluteExpiration, options) ?? NotPresent, ???????????????????????value ???????????????}); ???????}

上面的添加缓存中，使用了脚本插入。
private const string SetScript = (@" ???????????????redis.call(‘HMSET‘, KEYS[1], ‘absexp‘, ARGV[1], ‘sldexp‘, ARGV[2], ‘data‘, ARGV[4])//设置key、绝对过期时间、滑动过期时间、和value的值 ???????????????if ARGV[3] ~= ‘-1‘ then ?????????????????redis.call(‘EXPIRE‘, KEYS[1], ARGV[3])//设置缓存的时间 ????????????????end ???????????????return 1");

internal static class RedisExtensions ???{ ???????private const string HmGetScript = (@"return redis.call(‘HMGET‘, KEYS[1], unpack(ARGV))");//通过脚本HMGET命令获取key的值　　　　　//Get方法中调用此方法，memebers为固定值 data，也就是获取字段data的值 ????????internal static RedisValue[] HashMemberGet(this IDatabase cache, string key, params string[] members) ???????{ ???????????var result = cache.ScriptEvaluate( ???????????????HmGetScript, ???????????????new RedisKey[] { key }, ???????????????GetRedisMembers(members)); ???????????return (RedisValue[])result; ???????} ???????internal static async Task<RedisValue[]> HashMemberGetAsync( ???????????this IDatabase cache, ???????????string key, ???????????params string[] members) ???????{ ???????????var result = await cache.ScriptEvaluateAsync( ???????????????HmGetScript, ???????????????new RedisKey[] { key }, ???????????????GetRedisMembers(members)); ???????????// TODO: Error checking? ???????????return (RedisValue[])result; ???????} ???????private static RedisValue[] GetRedisMembers(params string[] members) ???????{ ???????????var redisMembers = new RedisValue[members.Length]; ???????????for (int i = 0; i < members.Length; i++) ???????????{ ???????????????redisMembers[i] = (RedisValue)members[i]; ???????????} ???????????return redisMembers; ???????} ???}