4.3 可配置的分散式緩存（上）

来源:http://www.cnblogs.com/BenDan2002/archive/2016/10/29/5999038.html
-Advertisement-
Play Games

為了加快系統運行效率，一般情況下系統會採用緩存技術，將常用信息存放到緩存中，避免頻繁的從資料庫、文件中讀寫，造成系統瓶頸，從而提高響應速度。緩存分為客戶端緩存和伺服器端緩存。 目前隨著系統的擴展，伺服器端緩存一般採取兩級緩存技術，本地緩存和分散式緩存。部分常用、公共或者小數據量的信息保存在分散式緩存 ...


為了加快系統運行效率，一般情況下系統會採用緩存技術，將常用信息存放到緩存中，避免頻繁的從資料庫、文件中讀寫，造成系統瓶頸，從而提高響應速度。緩存分為客戶端緩存和伺服器端緩存。

目前隨著系統的擴展，伺服器端緩存一般採取兩級緩存技術，本地緩存和分散式緩存。部分常用、公共或者小數據量的信息保存在分散式緩存中，運行在不同資源上的系統均從分散式緩存中獲取同樣的數據。相反，常用、私有或者數據量大的信息則保存在本地緩存中，避免了大數據量信息頻繁網路傳輸、序列化和反序列化造成的系統瓶頸。

 

大家在使用分散式緩存中需要註意的是，應用在將數據存入分散式緩存或者讀取時，數據需要序列化才能存入，讀取時反序列化，這樣對於大的對象占用的網路/CPU等資源會比較多。

通常情況下，.net core的緩存使用是這樣的：

 1     public void ConfigureServices(IServiceCollection services)
 2     {
 3         services.AddMemoryCache();
 4         // Add framework services.
 5         services.AddMvc();            
 6     }
 7 
 8     public class HomeController : Controller
 9     {
10         private IMemoryCache _memoryCache;
11         public HomeController(IMemoryCache memoryCache)
12         {
13             _memoryCache = memoryCache;
14         }
15 
16         public IActionResult Index()
17         {
18             string cacheKey = "key";
19             string result;
20             if (!_memoryCache.TryGetValue(cacheKey, out result))
21             {
22                 result = DateTime.Now.ToString();
23                 _memoryCache.Set(cacheKey, result);
24             }
25             ViewBag.Cache = result;
26             return View();
27         }
28     }

第一段是在startup.cs中註冊緩存，第二段是具體在某個controller中的使用。

對於分散式緩存來說，以Redis為例則需要寫成這樣：

 1     public void ConfigureServices(IServiceCollection services)
 2     {
 3         services.AddDistributedRedisCache(options =>
 4         {
 5         options.Configuration = "localhost";
 6         options.InstanceName = "SampleInstance";
 7         }); 
 8     }
 9 
10     public class HomeController : Controller
11     {
12         private IDistributedCache _memoryCache;
13         public HomeController(IDistributedCache memoryCache)
14         {
15             _memoryCache = memoryCache;
16         }
17 
18         public IActionResult Index()
19         {
20             string cacheKey = "key";
21             string result;
22             if (!_memoryCache.TryGetValue(cacheKey, out result))
23             {
24                 result = DateTime.Now.ToString();
25                 _memoryCache.Set(cacheKey, result);
26             }
27             ViewBag.Cache = result;
28             return View();
29         }
30     }

然而，這種分散式緩存編程方式在大型可擴展的系統中存在一些問題。一是在不同的環境中可能緩存產品不同，例如阿裡雲是memcached，微軟是appfabirc，我們本地集群的是redis等。不能每次部署修改一遍程式吧？這違反了可替換、可配置的軟體質量原則了。二是IDistributedCache介面方法用起來比較繁瑣，對於過期時間等還得自行編寫DistributedCacheEntryOptions。其實過期時間一般都是滑動時間，應該可以將這個時間直接寫在配置文件中，而不要每個緩存自己寫。

為此，對分散式緩存的封裝首先是建立更好的使用介面，其次是可配置化。介面和抽象類的代碼如下：

  1     public interface ICacheHander
  2     {
  3         /// <summary>
  4         /// 如果不存在緩存項則添加，否則更新
  5         /// </summary>
  6         /// <param name="catalog">緩存分類</param>
  7         /// <param name="key">緩存項標識</param>
  8         /// <param name="value">緩存項</param>
  9         void Put<T>(string catalog, string key, T value);
 10 
 11         /// <summary>
 12         /// 如果不存在緩存項則添加，否則更新
 13         /// </summary>
 14         /// <param name="catalog">緩存分類</param>
 15         /// <param name="key">緩存項標識</param>
 16         /// <param name="value">緩存項</param>
 17         /// <param name="timeSpan">緩存時間，滑動過期</param>
 18         void Put<T>(string catalog, string key, T value, TimeSpan timeSpan);
 19 
 20         /// <summary>
 21         /// 獲取緩存項
 22         /// </summary>
 23         /// <param name="catalog">緩存分類</param>
 24         /// <param name="key">cacheKey</param>
 25         T Get<T>(string catalog, string key);
 26 
 27         /// <summary>
 28         /// 獲取緩存項，如果不存在則使用方法獲取數據並加入緩存
 29         /// </summary>
 30         /// <typeparam name="T"></typeparam>
 31         /// <param name="catalog">緩存分類</param>
 32         /// <param name="key">緩存項標識</param>
 33         /// <param name="func">獲取要緩存的數據的方法</param>
 34         /// <returns>緩存的數據結果</returns>
 35         T GetOrAdd<T>(string catalog, string key, Func<T> func);
 36 
 37         /// <summary>
 38         /// 獲取緩存項，如果不存在則使用方法獲取數據並加入緩存
 39         /// </summary>
 40         /// <typeparam name="T"></typeparam>
 41         /// <param name="catalog">緩存分類</param>
 42         /// <param name="key">緩存項標識</param>
 43         /// <param name="func">獲取要緩存的數據的方法</param>
 44         /// <param name="timeSpan">緩存時間，滑動過期</param>
 45         /// <returns>緩存的數據結果</returns>
 46         T GetOrAdd<T>(string catalog, string key, Func<T> func, TimeSpan timeSpan);
 47 
 48         /// <summary>
 49         /// 移除緩存項
 50         /// </summary>
 51         /// <param name="catalog">緩存分類</param>
 52         /// <param name="key">cacheKey</param>
 53         void Remove(string catalog, string key);
 54 
 55         /// <summary>
 56         /// 刷新緩存項
 57         /// </summary>
 58         /// <param name="catalog">緩存分類</param>
 59         /// <param name="key">cacheKey</param>
 60         void Refresh(string catalog, string key);
 61     }
 62 
 63 
 64     public abstract class BaseCacheHandler : ICacheHander
 65     {
 66         protected abstract IDistributedCache _Cache { get; }
 67         protected CachingConfigInfo _ConfigInfo { get; private set; }
 68 
 69         private TimeSpan _DefaultTimeSpan;
 70 
 71         private ConcurrentDictionary<string, object> _LockObjsDic;
 72 
 73         public BaseCacheHandler(CachingConfigInfo configInfo)
 74         {
 75             this._DefaultTimeSpan = new TimeSpan(0, configInfo.DefaultSlidingTime, 0);
 76             this._LockObjsDic = new ConcurrentDictionary<string, object>();
 77 
 78             this._ConfigInfo = configInfo;
 79         }
 80 
 81         public void Put<T>(string catalog, string key, T value) => Put(catalog, key, value, _DefaultTimeSpan);
 82 
 83         public virtual void Put<T>(string catalog, string key, T value, TimeSpan timeSpan)
 84         {
 85             string cacheKey = GenCacheKey(catalog, key);
 86 
 87             string str = SerializerHelper.ToJson<T>(value);
 88 
 89             _Cache.SetString(cacheKey, str, new DistributedCacheEntryOptions().SetSlidingExpiration(timeSpan));
 90         }
 91 
 92         public T Get<T>(string catalog, string key)
 93         {
 94             MicroStrutLibraryExceptionHelper.TrueThrow(string.IsNullOrWhiteSpace(catalog) || string.IsNullOrWhiteSpace(key), this.GetType().FullName, LogLevel.Error, "緩存分類或者標識不能為空");
 95 
 96             string cacheKey = GenCacheKey(catalog, key);
 97 
 98             string str = _Cache.GetString(cacheKey);
 99 
100             return SerializerHelper.FromJson<T>(str);
101         }
102 
103         public T GetOrAdd<T>(string catalog, string key, Func<T> func) => GetOrAdd(catalog, key, func, _DefaultTimeSpan);
104 
105         public T GetOrAdd<T>(string catalog, string key, Func<T> func, TimeSpan timeSpan)
106         {
107             MicroStrutLibraryExceptionHelper.TrueThrow(string.IsNullOrWhiteSpace(catalog) || string.IsNullOrWhiteSpace(key), this.GetType().FullName, LogLevel.Error, "緩存分類或者標識不能為空");
108 
109             T result = Get<T>(catalog, key);
110 
111             if (result == null)
112             {
113                 string cacheKey = GenCacheKey(catalog, key);
114 
115                 object lockObj = _LockObjsDic.GetOrAdd(cacheKey, n => new object());
116                 lock (lockObj)
117                 {
118                     result = Get<T>(catalog, key);
119 
120                     if (result == null)
121                     {
122                         result = func();
123                         Put(catalog, key, result, timeSpan);
124                     }
125                 }
126             }
127 
128             if (result == null)
129                 return default(T);
130 
131             return result;
132         }
133 
134         /// <summary>
135         /// 刪除緩存
136         /// </summary>
137         /// <param name="catalog"></param>
138         /// <param name="key"></param>
139         public void Remove(string catalog, string key)
140         {
141             string cacheKey = GenCacheKey(catalog, key);
142 
143             _Cache.Remove(cacheKey);
144         }
145 
146         /// <summary>
147         /// 清空緩存
148         /// </summary>
149         public void Refresh(string catalog, string key)
150         {
151             string cacheKey = GenCacheKey(catalog, key);
152 
153             _Cache.Refresh(cacheKey);
154         }
155 
156         /// <summary>
157         /// 生成緩存鍵
158         /// </summary>
159         /// <param name="catalog"></param>
160         /// <param name="key"></param>
161         /// <returns></returns>
162         private string GenCacheKey(string catalog, string key)
163         {
164             return $"{catalog}-{key}";
165         }
166     }

抽象類又對介面進行了進一步的實現。大家可以註意下緩存Get時我們使用了兩次lock，還有GetOrAdd方法，我們用了一個func。

緩存配置信息的代碼，配置基類和配置的介紹請見：多級可換源的配置實現。

 

 1     public sealed class CachingConfigInfo : ConfigInfo
 2     {
 3         /// <summary>
 4         /// 緩存滑動視窗時間（分鐘）
 5         /// </summary>
 6         public int DefaultSlidingTime { get; set; }
 7 
 8         /// <summary>
 9         /// 分散式緩存類型TypeDescription，例如是Redis/Memcached/Default等分散式緩存對應的實現類信息。
10         /// </summary>
11         public string Type { get; set; }
12 
13         /// <summary>
14         /// 緩存的參數，一般是伺服器信息
15         /// </summary>
16         public List<CacheServer> Servers { get; set; }
17 
18         public override string SectionName
19         {
20             get
21             {
22                 return "MicroStrutLibrary:Caching";
23             }
24         }
25 
26         public override void RegisterOptions(IServiceCollection services, IConfigurationRoot root)
27         {
28             services.Configure<CachingConfigInfo>(root.GetSection(SectionName));
29         }
30     }
31 
32     /// <summary>
33     /// 分散式緩存 伺服器配置項
34     /// </summary>
35     public sealed class CacheServer
36     {
37         /// <summary>
38         /// 伺服器地址，可以使伺服器網路名稱也可是IP地址
39         /// </summary>
40         public string HostName { get; set; }
41 
42         /// <summary>
43         /// 伺服器分散式緩存服務提供埠
44         /// </summary>
45         public int Port { get; set; }
46     }

 

其中Type屬性就是具體的實現，例如Redis分散式緩存的實現等。具體請見下節。

接下來需要在startup註冊使用分散式緩存處理

 1         public static IServiceCollection AddCacheHandler(this IServiceCollection services)
 2         {
 3             if (services == null)
 4             {
 5                 throw new ArgumentNullException(nameof(services));
 6             }
 7 
 8             IOptions<CachingConfigInfo> optionsAccessor = services.BuildServiceProvider().GetService<IOptions<CachingConfigInfo>>();
 9 
10             ICacheHander handler = ReflectionHelper.CreateInstance(optionsAccessor.Value.Type, optionsAccessor.Value) as ICacheHander;
11 
12             services.TryAddSingleton<ICacheHander>(handler);
13 
14             return services;
15         }

 

在使用分散式緩存時，只需要在方法或者調用類的構造函數上增加ICacheHandler cacheHandler的屬性即可。例如ParameterService 類的構造函數public ParameterService(ICacheHandler cacheHandler) {…}。

 

面向雲的.net core開發框架目錄


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • centos7 + php7 lamp全套最新版本配置，還有mongodb和redis
    我是個懶人，能yum就yum啦 所有軟體的版本一直會升級，註意自己當時的版本是不是已經更新了。 首先裝centos7 如果你忘了設置swap分區，下麵的文章可以教你怎麼補一個上去： http://www.2cto.com/os/201409/338170.html 裝好centos7後預設是不能上網 ...
  • nice
    我們在使用 "$top" 的時候有一列NI參數，這個參數就是進程的nice值，用來表示進程在系統調度中的優先順序，Linux中的進程nice從 20到+19，越小表明調度的優先順序越高，用戶進程的最小nice值就是0，比這個還要小的都是系統進程,非管理員不允許指定小於0的進程 `$nice n ［新的n ...
  • linux下socket編程
    相關結構 相關函數 主調用 如果函數調用失敗，都返回 1，調用失敗會在全局變數error里有相應的值 不涉及到讀取、發送的時候，調用正常都返回0 socket() 創建套接字 family: 協議或地址族，TCP/IP為PF_INET，（ipv6為PF_INET6），也可以使用AF_INET typ ...
  • Oracle VirtualBox 使用橋接網路完成主機和虛擬機之間的雙向通訊
    最近剛換了新的筆記本電腦，終於使用上intel i7處理器，可以使用硬體虛擬化技術安裝系統。配置如下： 主機 ThinkPad P50s OS Window 10 虛擬機軟體 Oracle VirtualBox （個人感覺速度很快，並且可以創建相容 VMWare 和Hyper-V的虛擬機文件格式） ...
  • 《新手指南之玩轉實驗樓》第1節 實驗報告
    Hello World! ——《新手指南之玩轉實驗樓》第1節 實驗介紹 本節主要介紹電腦相關技術的基本概念,面向完全沒有編程經驗的朋友. 電腦體系 電腦系統 人機交互 編程語言種類 我的操作 1.電腦相關技術基本概念介摘錄 電腦體系： 電腦是一個很龐大的體系，主要領域可以包括：電腦系統 ...
  • Busybox下mdev配置說明
    [TOC] mdev說明 mdev是busybox自帶的一個簡化版的udev，適合嵌入式應用場合。其具有使用簡單的特點。它的作用就是在 系統啟動 和 熱插拔 或 動態載入驅動程式 時，自動產生驅動程式所需要的節點文件。在以busybox為基礎構建嵌入式linux根文件系統時，使用它時最優的選擇。 m ...
  • MCS51系列單片機實用技術部分課件
    ...
  • docker-3 基礎命令
    創建鏡像 創建鏡像的方法有三種： 基於已有的容器創建 基於本地模板導入 基於dockerfile 基於已有的容器創建 主要使用docker commit 命令，命令格式： docker commit [OPTIONS] CONTAINER [REPOSITORY[:tag]]，主要包括： -a ,- ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類