在ASP.NET 2.0中操作数据之五十七:在分层架构中缓存数据
导言:
正如前面章节所言,缓存objectdatasource的数据只需要简单的设置一些属性。然而,它是在表现层对数据缓存,这就与asp.net page页面缓存策略(caching policies)紧密的耦合(tightly couples)起来。我们对体系机构分层的原因之一便是打破这种耦合。拿业务逻辑层为例,将业务逻辑从asp.net页面脱离出来;而数据访问层将数据访问的细节asp.net页面脱离出来。从某种意义来说,将业务逻辑和数据访问细节脱离出来是首先,这样的话使系统更易读、易维护、易修改,便于按模块分工—比如,表现层的开发者对数据库的细节不甚了解也不妨碍其开发工作。当然,将缓存策略从表现层脱离出来也有类似的好处。
本文我们将对层次机构进行扩充,新添一个缓存层(caching layer,简称cl)以实施缓存策略。该缓存层包括一个productscl类,该类用类似 getproducts(), getproductsbycategoryid(categoryid)等方法来访问产品信息。调用这些方法时先从内存检索数据,如果内存为空则调用业务逻辑层bll里的productsbll类的相应方法,再从数据访问层dal返回获取的数据。该productscl类的方法从业务逻辑层bll获取数据后先对数据缓存后再返回。
如图1所示,缓存层cl位于表现层和业务逻辑层。
图1:在我们的体系结构中缓存层(cl)是单独的一层
第一步:创建缓存层的类
在本文,我们创建的缓存层仅仅包含一个productscl类,它只有几个方法。
完整的缓存层还应该包含categoriescl, employeescl, 和supplierscl类。有了业务逻辑层bll和数据访问层dal,缓存层完全可以当成一个单独的类库工程(class library project),不过我们将它作为app_code文件夹里的一个类来处理。
为了更好的将缓存层类和dal类、bll类区分开,我们在app_code文件夹里创建一个新的子文件夹。在资源管理器里右击app_code文件夹,选择“新文件夹”,命名为cl,在里面添加新类productscl.cs
图2:添加名为cl的文件夹和名为productscl.cs的类
跟bll里的productsbll类一样,productscl类应该包含相同的数据访问和修改方法。不过在本文,我们只创建getproducts()方法(在第3步)和getproductsbycategoryid(categoryid)方法(在第4步)。你可以在空闲的时候对productscl类进行完善,并创建相应的categoriescl, employeescl和 supplierscl类
第二步:对data cache进行读和写
objectdatasource的缓存属性使用asp.net data cache来存储从bll获取的数据。要访问data cache,可以从asp.net页面的code-behind classes类或体系结构层(architecture)的类来访问。要通过asp.net页面的code-behind classes类对data cache进行读写,可使用如下模式:
// read from the cache(读) object value = cache["key"];
// add a new item to the cache(写) cache["key"] = value; cache.insert(key, value); cache.insert(key, value, cachedependency); cache.insert(key, value, cachedependency, datetime, timespan);
cache class类的insert方法可以有很多的重载。cache["key"] = value 和 cache.insert(key, value)是相同的,都是向cache添加一个条目(item),不过没有指定expiry(可以理解为缓存持续时间)。更具代表性的是,在我们向cache添加条目的时候指定一个expiry,它要么是dependency(从属体),要么是time-based expiry,又或者两者兼而有之,比如上面的最后2个表达式。
如果所需的数据存储在内存的话,首先调用缓存层的方法返回数据。如果不在内存的话就调用bll里相应的方法。数据先缓存再返回。就像下面的流程表解析的一样:
图3:如果数据存在于内存的话就调用缓存层的方法。
上图的流程可用如下的模式:
type instance = cache["key"] as type; if (instance == null) { instance = bllmethodtogetinstance(); cache.insert(key, instance, ...); } return instance;
其中,type是缓存在内存中的数据的类型——具体到本文,也就是northwind.productsdatatable;此外,key用于唯一地标识缓存的每一个条目。如果指定了key值的那个条目不在内存中,那么instance就为null,然后用bll类的某恰当的方法来检索数据,将获得的数据缓存到内存。将instance返回后,它将包含一个对数据的引用(reference to the data),数据要么来自内存,要么是bll类的返回数据。
当访问内存时,请务必使用上述模式。下面的这个模式,咋一看好像和上面的模式一模一样,但是有一个细微的区别,它存在一个race condition(可以理解为不易察觉的隐式缺陷)。race condition很难调试,因为它只是偶尔发生,而且再次发生的可能性也小。如下:
if (cache["key"] == null) { cache.insert(key, bllmethodtogetinstance(), ...); } return cache["key"];
再一个就是,上述模式不是在局部变量里存储缓存条目的引用,而是在条件语句里直接访问数据,在return语句里直接返回数据。设想这种情况,开始运行代码时cache["key"]是non-null的,但在运行return语句前,系统将其从内存里清除掉,那么代码就会返回一个null值,而不是我们期望的某种类型的对象。
注意:如果仅仅是对data cache进行读或写访问,你没有必要进行同步访问(synchronize thread access);当然,如果你需要对内存里的数据进行多重操作(multiple operations),你还是应该实施锁定(lock),或其它的机制。
如果要从data cache里清除某个条目,可以用remove方法,比如:
cache.remove(key);
第三步:从productscl类返回产品信息
在本文,我们要在productscl类里用2个方法来返回产品信息: getproducts()和 getproductsbycategoryid(categoryid). 和业务逻辑层里的productsbl类相似,缓存层里的getproducts()方法返回一个northwind.productsdatatable对象,来获取所有产品的信息;而getproductsbycategoryid(categoryid)方法返回的是某个特定类别的所有产品。
如下的代码是productscl类里的部分方法:
[system.componentmodel.dataobject] public class productscl { private productsbll _productsapi = null; protected productsbll api { get { if (_productsapi == null) _productsapi = new productsbll(); return _productsapi; } } [system.componentmodel.dataobjectmethodattribute(dataobjectmethodtype.select, true)] public northwind.productsdatatable getproducts() { const string rawkey = "products"; // see if the item is in the cache northwind.productsdatatable products = _ getcacheitem(rawkey) as northwind.productsdatatable; if (products == null) { // item not found in cache - retrieve it and insert it into the cache products = api.getproducts(); addcacheitem(rawkey, products); } return products; } [system.componentmodel.dataobjectmethodattribute(dataobjectmethodtype.select, false)] public northwind.productsdatatable getproductsbycategoryid(int categoryid) { if (categoryid < 0) return getproducts(); else { string rawkey = string.concat("productsbycategory-", categoryid); // see if the item is in the cache northwind.productsdatatable products = _ getcacheitem(rawkey) as northwind.productsdatatable; if (products == null) { // item not found in cache - retrieve it and insert it into the cache products = api.getproductsbycategoryid(categoryid); addcacheitem(rawkey, products); } return products; } } }
首先,注意运用到类(class)和方法(methods)上的属性 dataobject和 dataobjectmethodattribute ;这些属性服务于objectdatasource的设置向导,指出那些类和方法应该出现在向导的设置步骤里。因为objectdatasource控件要在表现层访问这些类和方法,所以我添加了这些属性,方便向导设置。关于这些属性及其作用,请参阅本教程第2章《》。
在getproducts() 和 getproductsbycategoryid(categoryid)方法里,getcacheitem(key)返回的数据赋值给一个局部变量。getcacheitem(key)方法根据指定的key值在内存查找对应的缓存条目;如果没找到,则用productsbll类里相应的方法来检索数据,并用addcacheitem(key, value)方法将获取的数据缓存到内存。
getcacheitem(key) 和 addcacheitem(key, value)方法分别对data cache进行读、写操作。getcacheitem(key)相对简单,它根据传入的key值,从cache类返回数据,如下:
private object getcacheitem(string rawkey) { return httpruntime.cache[getcachekey(rawkey)]; } private readonly string[] mastercachekeyarray = {"productscache"}; private string getcachekey(string cachekey) { return string.concat(mastercachekeyarray[0], "-", cachekey); }
getcacheitem(key)并没有直接使用我们提供的key值,而是调用getcachekey(key)方法,因为该方法根据“productscache-”返回key;在上述代码中,mastercachekeyarray用于存储字符串“productscache”。当然,addcacheitem(key, value)方法也会用到mastercachekeyarray,我们稍后会看到。
在asp.net页面后台代码类(code-behind class),我们可以使用page类的cache属性来访问data cache ,就像我们在第2步里的表达式:cache["key"] = value一样;而在体系结构的类(注:具体到本文,就是缓存层类(productscl),我们可以通过2种方式来访问:httpruntime.cache 或 httpcontext.current.cache ;在peter johnson的博客里有一篇文章《httpruntime.cache vs. httpcontext.current.cache》(),探讨了httpruntim与相对于httpcontext.current的优点;在此,我们的productscl类将使用httpruntime.
注意:如果你是使用的类库工程(class library projects),一定要记得引用system.web才能使用httpruntime 和 httpcontext类。
如果没有在内存找到数据,productscl类将从业务逻辑层bll获取数据,并使用addcacheitem(key, value)对数据进行缓存,可以用下面的代码向内存添加缓存数据,其缓存时间为60秒:
const double cacheduration = 60.0; private void addcacheitem(string rawkey, object value) { httpruntime.cache.insert(getcachekey(rawkey), value, null, datetime.now.addseconds(cacheduration), caching.cache.noslidingexpiration); }
其中,datetime.now.addseconds(cacheduration)指定了缓存时间—60秒;而 system.web.caching.cache.noslidingexpiration指明了不存在可变缓存时间(no sliding expiration).虽然insert()方法可以包含绝对时间和可变时间(absolute and sliding expiry)2种定义缓存时间的输入参数,但是你只能指定其中一个,如果你同时指定绝对时间和可变时间2个参数的话,insert()方法会抛出一argumentexception 异常。
注意:直接执行addcacheitem(key, value)方法会有一些弊端,我们将在第4步解释并修正。
第4步:当数据被修改时使缓存失效
除了数据检索方法外,缓存层还应该包含插入、更新、删除数据的方法。缓存层的数据修改方法并不是修改缓存的数据,而是调用业务逻辑层的相应方法,然后使缓存数据失效。就像前面章节探讨的那样,当激活objectdatasource的缓存属性时,便可调用它的insert, update或delete方法。
下面的updateproduct方法,说明了如何在缓存层cl执行数据修改方法:
[system.componentmodel.dataobjectmethodattribute(dataobjectmethodtype.update, false)] public bool updateproduct(string productname, decimal? unitprice, int productid) { bool result = api.updateproduct(productname, unitprice, productid); // todo: invalidate the cache return result; }
在业务逻辑层的方法返回数据以前,我们需要将缓存的数据失效。不过,这并非易事,无论productscl class's getproducts()还是getproductsbycategoryid(categoryid)都会向内存添加条目,并且getproductsbycategoryid(categoryid)方法会为每种类别添加几个条目(因为每种类别有几种甚至更多的产品)。
要使缓存数据失效,我们需要将productscl类添加的所有条目删除。为此,在addcacheitem(key, value)方法里,当添加条目时为其指定一个缓存从属体(cache dependency)。一般来说,缓存从属体可以是内存里的另一个条目;文件系统里的一个文件;又或者是microsoft sqlserver database数据库里的数据。当从属体发生改变,或者从内存里移除时,其对应的缓存条目会自动的从内存删除。在本教程,当productscl类向内存添加条目时,我们创建一个额外的条目作为其从属体。由此,要删除缓存条目,仅仅移除这些从属体即可。
我们来更改addcacheitem(key, value)方法,当用该方法向内存添加缓存数据时,使每个条目与一个从属体(cache dependency)对应起来。
private void addcacheitem(string rawkey, object value) { system.web.caching.cache datacache = httpruntime.cache; // make sure mastercachekeyarray[0] is in the cache - if not, add it if (datacache[mastercachekeyarray[0]] == null) datacache[mastercachekeyarray[0]] = datetime.now; // add a cachedependency system.web.caching.cachedependency dependency = new cachedependency(null, mastercachekeyarray); datacache.insert(getcachekey(rawkey), value, dependency, datetime.now.addseconds(cacheduration), system.web.caching.cache.noslidingexpiration); }
mastercachekeyarray是一个字符串数组,用来存储“productscache”. 首先检查mastercachekeyarray,如果其为null,用当前date和time对其赋值。然后,创建一个从属体。cachedependency类的构造器(constructor)可以有很多重载(overloads),本文使用的重载接受2个字符串数组作为输入参数。第一个参数指定文件作为从属体,但本文我们不大算用文件来做从属体,所以我们将第一个输入参数设为null;第二个参数指定cache keys作为从属体,本文我们指定为mastercachekeyarray。然后将该cachedependency传递给insert方法。
对addcacheitem(key, value)方法做了上述修改后,要使缓存失效,很简单,将从属体移除即可:
[system.componentmodel.dataobjectmethodattribute(dataobjectmethodtype.update, false)] public bool updateproduct(string productname, decimal? unitprice, int productid) { bool result = api.updateproduct(productname, unitprice, productid); // invalidate the cache invalidatecache(); return result; } public void invalidatecache() { // remove the cache dependency httpruntime.cache.remove(mastercachekeyarray[0]); }
第五步:在表现层调用缓存层
保存对productscl类的修改,打开caching文件夹里的fromthearchitecture.aspx页面,并添加一个gridview控件。从gridview控件的智能标签里创建一个新的objectdatasource,在向导的第一步,从下拉列表里选择productscl,如下图:
图4:类productscl包含在下拉列表里
选定productscl类后,点next。我们可以看到在select标签里有2个选项:getproducts() 和 getproductsbycategoryid(categoryid)方法;而在update标签里只有唯一的一个updateproduct()方法。在select标签里选择getproducts()方法;而在update标签里选择那个唯一的updateproduct()方法,最后点finish。
图5:productscl类的方法包含在下拉列表里。
完成向导后,visual studio会将objectdatasource的oldvaluesparameterformatstring属性设置为original_{0},并向gridview添加相应的列。将oldvaluesparameterformatstring该为默认值{0}, 并启用gridview控件的分页、排序、编辑功能。由于缓存层cl的uploadproducts()方法只对产品的name 和 price进行编辑,由此需要对gridview做相应的修改以限制其只能编辑这2列。
在前面的教程,我们指定gridview控件包含 productname, categoryname,和unitprice3列。放心大胆的将其复制过来,这样,gridview 和 objectdatasource的声明代码看起来应该像下面的这样:
<asp:gridview id="products" runat="server" autogeneratecolumns="false" datakeynames="productid" datasourceid="productsdatasource" allowpaging="true" allowsorting="true"> <columns> <asp:commandfield showeditbutton="true" /> <asp:templatefield headertext="product" sortexpression="productname"> <edititemtemplate> <asp:textbox id="productname" runat="server" text='<%# bind("productname") %>' /> <asp:requiredfieldvalidator id="requiredfieldvalidator1" controltovalidate="productname" display="dynamic" errormessage="you must provide a name for the product." setfocusonerror="true" runat="server">*</asp:requiredfieldvalidator> </edititemtemplate> <itemtemplate> <asp:label id="label2" runat="server" text='<%# bind("productname") %>'></asp:label> </itemtemplate> </asp:templatefield> <asp:boundfield datafield="categoryname" headertext="category" readonly="true" sortexpression="categoryname" /> <asp:templatefield headertext="price" sortexpression="unitprice"> <edititemtemplate> $<asp:textbox id="unitprice" runat="server" columns="8" text='<%# bind("unitprice", "{0:n2}") %>'></asp:textbox> <asp:comparevalidator id="comparevalidator1" runat="server" controltovalidate="unitprice" display="dynamic" errormessage="you must enter a valid currency value with no currency symbols. also, the value must be greater than or equal to zero." operator="greaterthanequal" setfocusonerror="true" type="currency" valuetocompare="0">*</asp:comparevalidator> </edititemtemplate> <itemstyle horizontalalign="right" /> <itemtemplate> <asp:label id="label1" runat="server" text='<%# bind("unitprice", "{0:c}") %>' /> </itemtemplate> </asp:templatefield> </columns> </asp:gridview> <asp:objectdatasource id="productsdatasource" runat="server" oldvaluesparameterformatstring="{0}" selectmethod="getproducts" typename="productscl" updatemethod="updateproduct"> <updateparameters> <asp:parameter name="productname" type="string" /> <asp:parameter name="unitprice" type="decimal" /> <asp:parameter name="productid" type="int32" /> </updateparameters> </asp:objectdatasource>
这样,我们该页面就使用了缓存层。为实地演示缓存,在productscl类的getproducts() 和 updateproduct()方法里设置断点(breakpoints),在浏览器里访问该页面,当排序或分页时就会执行这些代码,从内存获取数据。然后更新一条记录,注意由于缓存失效,将从业务逻辑层bll获取数据并绑定到gridview。
注意:从本文download链接下载的缓存层并不完善。它只包含了一个productscl类,它只包含几个方法。此外,只有一个asp.net页面(~/caching/fromthearchitecture.aspx)使用了缓存层cl,而其它的页面都是直接调用业务逻辑层bll。如果打算在你的应用程序里使用缓存层cl,那么页面层的所有调用都应该先访问缓存层cl。
总结:
虽然可以在asp.net 2.0的表现层对sqldatasource 和 objectdatasource控件实施缓存,但更理想的做法是在体系单独分层来达到缓存的目的。在本文,我们在表现层和业务逻辑层之间创建了一个缓存层,该缓存层包含的类和方法与现有的业务逻辑层所包含的类和方法类似。当然,也是在表现层调用。
本示例及前面教程处理的是“触发装载”(reactive loading)—也就是说当发现请求的数据没在内存后将数据装载进内存。其实数据也可以“预装载”(proactively loaded)进内存—也就是说在数据实际请求之前将其预先装载进内存。在下一篇文章我们将看到预装载的情形——在应用程序启动的时候如何将静态值(static values)装载进内存。
祝编程快乐!
作者简介
本系列教程作者 scott mitchell,著有六本asp/asp.net方面的书,是4guysfromrolla.com的创始人,自1998年以来一直应用 微软web技术。大家可以点击查看全部教程《[翻译]scott mitchell 的asp.net 2.0数据教程》,希望对大家的学习asp.net有所帮助。
推荐阅读
-
在ASP.NET 2.0中操作数据之五十八:在程序启动阶段缓存数据
-
在ASP.NET 2.0中操作数据之六十六:在TableAdapters中使用现有的存储过程
-
在ASP.NET 2.0中操作数据之五十七:在分层架构中缓存数据
-
在ASP.NET 2.0中操作数据之六十五:在TableAdapters中创建新的存储过程
-
在ASP.NET 2.0中操作数据之六十九:处理Computed Columns列
-
在ASP.NET 2.0中操作数据之六十七:在TableAdapters中使用JOINs
-
在ASP.NET 2.0中操作数据之六十八:为DataTable添加额外的列
-
在ASP.NET 2.0中操作数据之七十二:调试存储过程
-
在ASP.NET 2.0中操作数据之七十四:用Managed Code创建存储过程和用户自定义函数(下部分)
-
在ASP.NET 2.0中操作数据之七十一:保护连接字符串及其它设置信息