.net core使用CSRedisCore鏈接哨兵集羣，並用做redis使用分佈式緩存。

CSRedisCore是國內大佬出品的一個Redis-Cli-SDK。

Github地址:https://github.com/2881099/csredis

使用此插件做爲分佈式緩存也十分簡單。

1、asp.net core 3.0中使用分佈式緩存。

　　注意：IDistributedCache是asp.net core中提供的緩存接口。提供了一些基本的方法。

　　使用Caching.CSRedis能夠方便的實現IDistributedCache接口。

　　

// 經過Caching.CSRedis實現IDistributedCache
　　　　　　services.AddSingleton<IDistributedCache>(new CSRedisCache(new CSRedisClient("127.0.0.1:6379")));

 　　此時就能夠在構造函數中注入IDistributedCache接口使用了。

　　

public WeatherForecastController(ILogger<WeatherForecastController> logger, IDistributedCache distributedCache) { _logger = logger; _distributedCache = distributedCache; }

 [HttpGet] public IEnumerable<WeatherForecast> GetDistributeCacheData(string key) { var cache = _distributedCache.Get(key); if (cache == null) { // 這裏應該上鎖,不然同時會有多個請求,單機測試無所謂。 // 模擬獲取數據
                Thread.Sleep(1000); var result = GetDataByDatabase(key); //放到緩存。
 _distributedCache.Set(key, JsonSerializer.SerializeToUtf8Bytes(result)); return result; } else { return JsonSerializer.Deserialize<WeatherForecast[]>(cache); } }

使用起來十分簡單。

2、使用Session。

　　　　asp.net core 3.0中，使用Session是須要IDistributedCache支持的，即便在單機中使用，也要使用基於內存的分佈式緩存。

　　　　

　　
　　 // 若是不實現IDistributedCache將會異常。
　　 services.AddSession();

　　　　public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
　　　　{

　　　　　　app.UseSession();

　　　　}

　　雖然我在上面注入了IDistributedCache接口的實現，已經可使用Session了，可是我不能區分數據Redis和SessionRedis容器,Session和其餘全部的緩存都將放在一個Redist容器中。

　　要解決這個問題，則須要注入新的接口。

　　仍是基於CSRedisCore修改。

　　如下基於Caching.CSRedis的源碼修改。

　　

// 繼承分佈式緩存接口。
 public interface IDistributedSessionCache : IDistributedCache

使用自定義類繼承默認實現。

/// <summary>
    /// 自定義RedisSession緩存。 /// </summary>
    public class DistributedRedisSessionStore : DistributedSessionStore { /// <summary>
        /// 構造函數。 /// </summary>
        /// <param name="cache">自定義RedisSession緩存,此處使用繼承默認接口的自定義接口。</param>
        /// <param name="loggerFactory">日誌工廠。</param>
        public DistributedRedisSessionStore(IDistributedSessionCache cache, ILoggerFactory loggerFactory) : base(cache, loggerFactory) { } }

 擴展依賴注入方法

public static IServiceCollection AddRedisSession(this IServiceCollection services) { services.TryAddTransient<ISessionStore, DistributedRedisSessionStore>(); services.AddDataProtection(); return services; }

依賴注入方法

// 鏈接Redis的容器，此時6380端口。
　　　　　　  services.AddSingleton<IDistributedSessionCache>(new CSRedisSessionCache(new CSRedisClient("127.0.0.1:6380"))); services.AddRedisSession();

一個簡單的測試方法

 [HttpGet] public IActionResult GetSessionData(string key) { var msg = HttpContext.Connection.LocalPort.ToString(); DateTime dateTime = default; if (HttpContext.Session.TryGetValue(key, out var value)) dateTime = JsonSerializer.Deserialize<DateTime>(value); else { dateTime = DateTime.Now; HttpContext.Session.Set(key, JsonSerializer.SerializeToUtf8Bytes(dateTime)); } _logger.LogInformation($"本次鏈接端口{msg},經過Session得到時間值{dateTime}"); return new JsonResult(dateTime); }

 

此時，我在docker中止了6379(普通數據緩存容器)，Session依然沒有問題。

 

 普通數據容器已經掛了

 

 

 分別啓用端口5002和5003，進行分佈式session是否有效。

 

 

 　　能夠看到是有效的。

 

區分Session容器和普通數據緩存的代碼。

　　github: https://github.com/yeqifeng2288/Microsoft.Extensions.Caching.CSRedis.Session