EF Code First:二級(jí)緩存
一、前言
今天我們來(lái)談?wù)凟F的緩存問(wèn)題。
緩存對(duì)于一個(gè)系統(tǒng)來(lái)說(shuō)至關(guān)重要,但是是EF到版本6了仍然沒有見到有支持查詢結(jié)果緩存機(jī)制的跡象。EF4開始會(huì)把查詢語(yǔ)句編譯成存儲(chǔ)過(guò)程緩存在Sql Server中,據(jù)說(shuō)EF6中對(duì)此做了改進(jìn),會(huì)把Linq To Entities 的查詢條件直接編譯緩存在EF中。但是這些都是只是對(duì)查詢條件做了緩存,而不是緩存查詢的結(jié)果集(DbSet.Find(object key)那個(gè)雖然走了DbSet.Local數(shù)據(jù)集,但也僅支持通過(guò)主鍵查找單個(gè)實(shí)體的情況,很有局限性),沒有達(dá)到我們想要的效果。
EF不加緩存功能,可能也有另外的考慮吧,這里不去猜測(cè)。雖然EF團(tuán)隊(duì)沒有在EF中加入緩存功能,但已經(jīng)給出的緩存功能的擴(kuò)展,這就是Community Entity Framework Provider Wrappers,這個(gè)擴(kuò)展的工作原理由下圖可以清晰的了解:
該擴(kuò)展提供了跟蹤SQL運(yùn)行日志與SQJ結(jié)果集緩存的功能,這里,我們只用到它的緩存功能來(lái)為EF建立二級(jí)緩存的支持。
二、緩存設(shè)計(jì)
(一) 引用EFProviderWrappers
如下圖,在NuGet中只提供了Entity Framework Provider Wrapper Toolkit(基礎(chǔ)類庫(kù))與Entity Framework Tracing Provider(日志跟蹤)的下載,很遺憾的并沒有提供 Entity Framework Caching Provider(緩存)。
我們只能自己動(dòng)手來(lái)引用了,這里提供幾種思路:
- 到 http://code.msdn.microsoft.com/EFProviderWrappers 下載代碼,自行編譯,然后在項(xiàng)目GMF.Component.Data項(xiàng)目中手動(dòng)引用EFProviderWrapperToolkit.dll與EFCachingProvider.dll文件。
- EFProviderWrapperToolkit由NuGet下載,EFCachingProvider手動(dòng)引用。
我是覺得兩種思路都挺麻煩的,這個(gè)擴(kuò)展的代碼貌似已經(jīng)不更新了(3/18/2011),而且在GMF.Component.Data中額外的引用兩個(gè)程序集也是個(gè)麻煩事,于是我用下面的方法來(lái)引用:
在GMF.Component.Data項(xiàng)目中新建兩個(gè)文件夾,把以上源代碼中的兩個(gè)工程以文件夾的形式包含到項(xiàng)目中。 |
這樣,似乎更干凈利落,如圖:
(二) 緩存代碼分析及整合
1. 關(guān)鍵代碼簡(jiǎn)介
在EFCachingProvider中,我們要用到的核心類有三個(gè):
- ICache:緩存緩存基類,系統(tǒng)中實(shí)現(xiàn)了一個(gè)內(nèi)存緩存類(InMemoryCache),適用于單臺(tái)服務(wù)器的緩存實(shí)現(xiàn),如果要實(shí)現(xiàn)分布式緩存,可以從這個(gè)基類進(jìn)行擴(kuò)展。
- InMemoryCache:內(nèi)存緩存實(shí)現(xiàn)類,內(nèi)部使用了一個(gè)Dictionary<string, CacheEntry>作為緩存容器,以查詢的SQL語(yǔ)句及參數(shù)的連接字符串(或其MD5值)為鍵(EFCachingCommands.cs類中定義)。還包含了緩存命中、緩存項(xiàng)數(shù)量等數(shù)據(jù)的統(tǒng)計(jì)及緩存清理功能。
- CachingPolicy:緩存策略基類,定義了當(dāng)前實(shí)體是否可緩存(CanBeCached)、定義緩存緩存數(shù)(GetCacheableRows)、緩存項(xiàng)滑動(dòng)過(guò)期與絕對(duì)過(guò)期時(shí)間(GetExpirationTimeout)等功能,并默認(rèn)了絕對(duì)過(guò)期時(shí)間為永不過(guò)期(DateTime.MaxValue)。
- NoCachingPolicy:不緩存策略,禁用緩存功能。
- CacheAllPolicy:緩存所有數(shù)據(jù)策略,緩存項(xiàng)最大數(shù)量為int.MaxValue。
- CustomCachingPolicy:自定義緩存策略,使用了CacheableTables與NonCacheableTables兩個(gè)集合來(lái)表示數(shù)據(jù)類型是否可緩存的白名單與黑名單,這兩個(gè)名單將在重寫的CanBeCached方法中作為類型是否可緩存的驗(yàn)證依據(jù)。
- EFCachingConnection:此類定義了類型為ICache,CachingPolicy的兩個(gè)屬性,分別用于接收上面據(jù)說(shuō)的兩個(gè)擴(kuò)展點(diǎn)。
2. 應(yīng)用緩存擴(kuò)展
EF的DbContext上下文類有一個(gè)重載
public DbContext(DbConnection existingConnection, bool contextOwnsConnection) { } |
需要的是DbConnection參數(shù),而EFCachingConnection正好是派生自DbConnection的,我們只需要構(gòu)建一個(gè)EFCachingConnection對(duì)象作為參數(shù)去構(gòu)造DbContext派生類的對(duì)象,即可完成緩存功能的注入(如本篇第一張圖所示)。這里,緩存專用的DbContext派生類只需要派生自原項(xiàng)目中定義的EFDbContext類。
- namespace GMF.Component.Data
- {
- /// <summary>
- /// 啟用緩存的自定義EntityFramework數(shù)據(jù)訪問(wèn)上下文
- /// </summary>
- [Export("EFCaching", typeof (DbContext))]
- public class EFCachingDbContext : EFDbContext
- {
- private static readonly InMemoryCache InMemoryCache = new InMemoryCache();
- public EFCachingDbContext()
- : base(CreateConnectionWrapper("default")) { }
- public EFCachingDbContext(string connectionStringName)
- : base(CreateConnectionWrapper(connectionStringName)) { }
- /// <summary>
- /// 由數(shù)據(jù)庫(kù)連接串名稱創(chuàng)建連接對(duì)象
- /// </summary>
- /// <param name="connectionStringName">數(shù)據(jù)庫(kù)連接串名稱</param>
- /// <returns></returns>
- private static DbConnection CreateConnectionWrapper(string connectionStringName)
- {
- PublicHelper.CheckArgument(connectionStringName, "connectionStringName");
- string providerInvariantName = "System.Data.SqlClient";
- string connectionString = null;
- ConnectionStringSettings connectionStringSetting = ConfigurationManager.ConnectionStrings[connectionStringName];
- if (connectionStringSetting != null)
- {
- providerInvariantName = connectionStringSetting.ProviderName;
- connectionString = connectionStringSetting.ConnectionString;
- }
- if (connectionString == null)
- {
- throw PublicHelper.ThrowComponentException("名稱為“" + connectionStringName + "”數(shù)據(jù)庫(kù)連接串的ConnectionString值為空。");
- }
- string wrappedConnectionString = "wrappedProvider=" + providerInvariantName + ";" + connectionString;
- EFCachingConnection connection = new EFCachingConnection
- {
- ConnectionString = wrappedConnectionString,
- CachingPolicy = CachingPolicy.CacheAll,
- Cache = InMemoryCache
- };
- return connection;
- }
- }
- }
這里緩存策略使用了緩存所有數(shù)據(jù)(CacheAllPolicy)的策略,在實(shí)際項(xiàng)目中,最好自定義緩存策略,而不要使用這個(gè)策略,以免服務(wù)器內(nèi)存被撐爆。
#p#
我們?cè)趹?yīng)用程序配置(Web.Config或App.Config)中,添加一個(gè)名為“EntityFrameworkCachingEnabled”的AppSettings節(jié)點(diǎn),用來(lái)進(jìn)行啟用/禁用緩存的開關(guān)配置。
- <appSettings>
- ...
- <add key="EntityFrameworkCachingEnabled" value="true" />
- ...
- </appSettings>
另外,緩存擴(kuò)展還需要我們?cè)谂渲梦募刑砑尤缦鹿?jié)點(diǎn)的配置:
- <system.data>
- <DbProviderFactories>
- <add name="EF Caching Data Provider" invariant="EFCachingProvider" description="Caching Provider Wrapper" type="EFCachingProvider.EFCachingProviderFactory, GMF.Component.Data" />
- <add name="EF Generic Provider Wrapper" invariant="EFProviderWrapper" description="Generic Provider Wrapper" type="EFProviderWrapperToolkit.EFProviderWrapperFactory, GMF.Component.Data" />
- </DbProviderFactories>
- </system.data>
再來(lái)看看,怎樣使用“EntityFrameworkCachingEnabled”配置來(lái)控制緩存功能的開關(guān)。我們的設(shè)計(jì)中,DbContext對(duì)象的注入點(diǎn)為如下所示的Context屬性:
所以,我們只需要在UnitOfWorkContextBase的派生類中讀取 EntityFrameworkCachingEnabled 進(jìn)行切換即可。
- namespace GMF.Component.Data
- {
- /// <summary>
- /// 數(shù)據(jù)單元操作類
- /// </summary>
- [Export(typeof (IUnitOfWork))]
- public class EFRepositoryContext : UnitOfWorkContextBase
- {
- /// <summary>
- /// 獲取 當(dāng)前使用的數(shù)據(jù)訪問(wèn)上下文對(duì)象
- /// </summary>
- protected override DbContext Context
- {
- get
- {
- bool secondCachingEnabled = ConfigurationManager.AppSettings["EntityFrameworkCachingEnabled"].CastTo(false);
- return secondCachingEnabled ? EFCachingDbContext.Value : EFDbContext.Value;
- }
- }
- [Import("EF", typeof (DbContext))]
- private Lazy<EFDbContext> EFDbContext { get; set; }
- [Import("EFCaching", typeof(DbContext))]
- private Lazy<EFCachingDbContext> EFCachingDbContext { get; set; }
- }
- }
注意,因?yàn)镋FDbContext與EFCachingDbContext兩個(gè)屬性只能同時(shí)用到其中之一,導(dǎo)入需要使用Lazy<>類型來(lái)包裝,這樣沒用到的屬性就不會(huì)實(shí)例化了。
下面,我們來(lái)測(cè)試一下緩存功能是否生效,就用上篇的那個(gè)翻頁(yè)列表吧。判斷標(biāo)準(zhǔn)為SQL Server Profiler是否有SQL語(yǔ)句執(zhí)行。為方便演示,這里在列表的下方顯示當(dāng)前的時(shí)間,以便與SQL Server Profiler中的時(shí)間進(jìn)行匹配。
第1頁(yè)不計(jì)。
點(diǎn)擊第2頁(yè),執(zhí)行了查詢:
點(diǎn)擊第3頁(yè),執(zhí)行了查詢:
再回到第2頁(yè),沒有執(zhí)行查詢:
點(diǎn)擊第4頁(yè),執(zhí)行了查詢:
結(jié)論:重復(fù)第2頁(yè)的時(shí)候,數(shù)據(jù)已經(jīng)緩存了,沒有讀數(shù)據(jù)庫(kù)查詢數(shù)據(jù),說(shuō)明緩存已經(jīng)生效了。
最后要提示的一點(diǎn):
帶緩存的上下文不能擔(dān)當(dāng)生成數(shù)據(jù)庫(kù)的職責(zé),因此在第一次運(yùn)行生成數(shù)據(jù)庫(kù)的時(shí)候,必須關(guān)閉緩存。 |
三、源碼獲取
為了讓大家能第一時(shí)間獲取到本架構(gòu)的最新代碼,也為了方便我對(duì)代碼的管理,本系列的源碼已加入微軟的開源項(xiàng)目網(wǎng)站 http://www.codeplex.com,地址為:
https://gmframework.codeplex.com/
原文鏈接:http://www.cnblogs.com/guomingfeng/p/mvc-ef-caching.html