.Net Core緩存組件(Redis)源碼解析
上一篇文章已經介紹了MemoryCache，MemoryCache存儲的數據類型是Object，也說了Redis支持五中數據類型的存儲，但是微軟的Redis緩存組件只實現了Hash類型的存儲。在分析源碼之前，先學幾個關於Redis操作的命令。
一、Redis命令
Redis所有的命令在http://doc.redisfans.com/上有詳細介紹。下面介紹幾個常用的關於Hash類型的命令。
HSET：用於添加緩存
用法：HSET key field value 。
返回值：如果 field 是哈希表中的一個新建域，並且值設置成功，返回 1 。
如果哈希表中域 field
HMSET：用於同時添加多個
用法：HMSET key [field value field1 value1 ...]
返回值：如果命令執行成功，返回 OK 。
當 key 不是哈希表(hash)類型時，返回一個錯誤。 例如：HMSET user1 Name Microheart Age 18
HGET：獲取字段值
用法：HGET key field
返回值：給定域的值。
當給定域不存在或是給定 key 不存在時，返回 nil
例如：HGET user Name (註意 Redis區分大小寫)
HMGET：獲取多個字段的值
用法：HMGET key [field1,field2]
返回值：一個包含多個給定域的關聯值的表，表值的排列順序和給定域參數的請求順序一樣。
例如：HMGET user Name Age
EXPIRE：設置緩存的過期時間
用法：EXPIRE key seconds
返回值：設置成功返回 1 。
當 key 不存在或者不能為 key 設置生存時間時(比如在低於 2.1.3 版本的 Redis 中你嘗試更新 key
TTL：表示剩余生存時間。57表示還有57秒這個緩存過期。過期後，Redis會自動刪除。在 Redis 2.4 版本中，過期時間的延遲在 1 秒鐘之內 —— 也即是，就算 key 已經過期，但它還是可能在過期之後一秒鐘之內被訪問到，而在新的 Redis 2.6 版本中，延遲被降低到 1 毫秒之內。
二、在.Net Core中使用Redis組件
首先在Startup類中添加Redis緩存功能。配置的Option中設置的InstanceName的值會作為key的一部分。比如設置的InstanceName為test，代碼中設置一個緩存key為user，存儲到Redis中的實際key為testuser。
public void ConfigureServices(IServiceCollection services) { services.AddMvc(); services.AddDistributedRedisCache(option => { option.Configuration = "121.41.55.55:6379";//連接字符串 option.InstanceName = "test"; }); }
然後在需要使用的地方註入IDistributedCache。如下面所示：
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" }; } }
三、源碼解析
源碼在https://github.com/aspnet/Caching，Redis的源碼相對簡單，主要是因為很多都直接使用的StackExchange.Redis的API。
RedisCacheOptions類：主要是Redis配置相關。
Configuration：設置Redis配置，如連接字符串、超時時間等，最終被裝換為StackExchange.Redis中的ConfigurationOptions
InstanceName：實例名稱。會和代碼中設置的key拼接成為Redis中的key。
RedisCacheServiceCollectionExtensions類：跟服務註入相關。
就一個方法AddDistributedRedisCache，依賴註入IDistributedCache的實例。
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; }
RedisCache類：最主要的類，緩存操作相關的類。
其中插入、獲取數據的方法比較重要。
3.1 Set方法，插入數據。
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");
如果absexp和sldexp都沒有設置值，默認為-1，表示永不過期，緩存時間就是從設置的絕對過期時間和滑動過期時間中取，當時間到了，Redis自動刪除過期緩存，這一點和MemoryCache不一樣，MemoryCahe是在對緩存操作的時候，會掃描整個緩存刪除，存在很大的延時，而Redis采用下面三種策略清理過期的key:
- 被動刪除：當讀/寫一個已經過期的key時，會觸發惰性刪除策略，直接刪除掉這個過期key
- 主動刪除：由於惰性刪除策略無法保證冷數據被及時刪掉，所以Redis會定期主動淘汰一批已過期的key
- 當前已用內存超過maxmemory限定時，觸發主動清理策略
這就保證了過期緩存的及時清理。關於Redis清理過期key的策略可以看這篇文章。
當插入一條Hash類型數據時，打開RedisManager會看到下面這樣，absexp：絕對過期時間，sldexp：滑動過期時間，data：就是我們代碼中設置的value。
3.2 Get方法中，實現的主要獲取功能調用了下面代碼。
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; } }
Remove方法就直接調用了StackExchange的API，這裏就不做解釋。
相比MemoryCache的代碼，Redis代碼相對簡單，主要是微軟的開發人員"偷工減料"吧(我自己感覺)，很多重要的方法，比如連接直接、添加、設置過期時間、都調用了StackExchange的API，沒有實現自己的鏈接池等等。更像是對StackExchangeAPI中的Hash類型的再次封裝。
.Net Core緩存組件(Redis)源碼解析