公司最近搞一个购物网站,我恶补了下相关知识,看了看petshop.这是从网上找到的资料,拿来分享下.

图片不知道怎么弄上去.先将就着看吧 

PetShop
4.0 设计研究——petShop
4.0 的命名空间 以及各个项目模块的说明  

号	项目名称	程序集名称Assembly Name	默认命名空间Default Namespace	描述
1	WEB			表示层
2	Model	PetShop.Model	PetShop.Model	业务实体
3	BLL	PetShop.BLL	PetShop.BLL	业务逻辑层
4	DALFactory	PetShop.DAL	PetShop.DALFactory	数据层的抽象工厂
5	IDAL	PetShop.IDAL	PetShop.IDAL	数据访问层接口定义
6	SQLServerDAL	PetShop.SQLServerDAL	PetShop.SQLServerDAL	SQLServer数据访问层
7	OracleDAL	PetShop.OracleDAL	PetShop.OracleDAL	Oracle数据访问层
8	DBUtility	PetShop.DBUtility	PetShop.DBUtility	数据库访问组件基础类
9	CacheDependencyFactory	PetShop.CacheDependencyFactory	PetShop.CacheDependencyFactory	缓存依赖类的工厂类
10	ICacheDependency	PetShop.ICacheDependency	PetShop.ICacheDependency	缓存依赖类接口
11	TableCacheDependency	PetShop.TableCacheDependency	PetShop.TableCacheDependency	缓存依赖实现类
12	IBLLStrategy	PetShop.IBLLStrategy	PetShop.IBLLStrategy	同步/异步处理策略接口(实现在bll根据配置反射选择)
13	MessagingFactory	PetShop.MessagingFactory	PetShop.MessagingFactory	异时处理消息队列的抽象工厂
14	IMessaging	PetShop.IMessaging	PetShop.IMessaging	异时处理消息队列接口定义
15	MSMQMessaging	PetShop.MsmqMessaging	PetShop.MsmqMessaging	异时处理消息队列的实现
16	Profile	PetShop.Profile	PetShop.Profile	Profile的数据访问层
17	ProfileDALFactory	PetShop.ProfileDALFactory	PetShop.ProfileDALFactory	ProfileDAL的工厂类(反射创建ProfileDAL)
18	IProfileDAL	PetShop.IProfileDAL	PetShop.IProfileDAL	Profile的数据访问层接口定义
19	OracleProfileDAL	PetShop.OracleProfileDAL	PetShop.OracleProfileDAL	Oracle的Profile Providers 做用户状态管理
20	SQLProfileDAL	PetShop.SQLProfileDAL	PetShop.SQLProfileDAL	SQL Server 的Profile Providers 做用户状态管理
21	Membership	PetShop.Membership	PetShop.Membership	Membership认证和授权管理
22	OrderProcessor	PetShop.OrderProcessor	PetShop.OrderProcessor	后台处理进程，处理订单队列

 

《解剖PetShop》系列之一：PetShop的系统架构设计 

 前言：PetShop是一个范例，微软用它来展示.Net企业系统开发的能力。业界有许多.Net与J2EE之争，许多数据是从微软的 PetShop和Sun的PetStore而来。这种争论不可避免带有浓厚的商业色彩，对于我们开发人员而言，没有必要过多关注。然而PetShop随着 版本的不断更新，至现在基于.Net 2.0的PetShop4.0为止，整个设计逐渐变得成熟而优雅，却又很多可以借鉴之处。PetShop是一个小型的项目，系统架构与代码都比较简单，却
也凸现了许多颇有价值的设计与开发理念。本系列试图对PetShop作一个全方位的解剖，依据的代码是PetShop4.0，可以从链接http://msdn.microsoft.com/library/default.asp?url=/library/en-us/dnbda/html/bdasamppet4.asp中获得。

一、PetShop的系统架构设计

在软件体系架构设计中，分层式结构是最常见，也是最重要的一种结构。微软推荐的分层式结构一般分为三层，从下至上分别为：数据访问层、业务逻辑层（又或成为领域层）、表示层，如图所示：

图一：三层的分层式结构

数 据访问层：有时候也称为是持久层，其功能主要是负责数据库的访问。简单的说法就是实现对数据表的Select，Insert，Update，Delete
的操作。如果要加入ORM的元素，那么就会包括对象和数据表之间的mapping，以及对象实体的持久化。在PetShop的数据访问层中，并没有使用 ORM，从而导致了代码量的增加，可以看作是整个设计实现中的一大败笔。

业务逻辑层：是整个系统的核心，它与这个系统的业务（领域）有关。以PetShop为例，业务逻辑层的相关设计，均和网上宠物店特有的逻辑相关，例如查询宠物，下订单，添加宠物到购物车等等。如果涉及到数据库的访问，则调用数据访问层。

表示层：是系统的UI部分，负责使用者与整个系统的交互。在这一层中，理想的状态是不应包括系统的业务逻辑。表示层中的逻辑代码，仅与界面元素有关。在PetShop中，是利用ASP.Net来设计的，因此包含了许多Web控件和相关逻辑。

分层式结构究竟其优势何在？Martin Fowler在《Patterns
of Enterprise Application Architecture》一书中给出了答案：
1、开发人员可以只关注整个结构中的其中某一层；
2、可以很容易的用新的实现来替换原有层次的实现；
3、可以降低层与层之间的依赖；
4、有利于标准化；
5、利于各层逻辑的复用。

概括来说，分层式设计可以达至如下目的：分散关注、松散耦合、逻辑复用、标准定义。

一 个好的分层式结构，可以使得开发人员的分工更加明确。一旦定义好各层次之间的接口，负责不同逻辑设计的开发人员就可以分散关注，齐头并进。例如UI人员只 需考虑用户界面的体验与操作，领域的设计人员可以仅关注业务逻辑的设计，而数据库设计人员也不必为繁琐的用户交互而头疼了。每个开发人员的任务得到了确
认，开发进度就可以迅速的提高。

松散耦合的好处是显而易见的。如果一个系统没有分层，那么各自的逻辑都紧紧纠缠在一起，彼此间相互依赖，谁 都是不可替换的。一旦发生改变，则牵一发而动全身，对项目的影响极为严重。降低层与层间的依赖性，既可以良好地保证未来的可扩展，在复用性上也是优势明
显。每个功能模块一旦定义好统一的接口，就可以被各个模块所调用，而不用为相同的功能进行重复地开发。

进行好的分层式结构设计，标准也是必不可少的。只有在一定程度的标准化基础上，这个系统才是可扩展的，可替换的。而层与层之间的通信也必然保证了接口的标准化。

“金无足赤，人无完人”，分层式结构也不可避免具有一些缺陷：
1、降低了系统的性能。这是不言而喻的。如果不采用分层式结构，很多业务可以直接造访数据库，以此获取相应的数据，如今却必须通过中间层来完成。
2、有时会导致级联的修改。这种修改尤其体现在自上而下的方向。如果在表示层中需要增加一个功能，为保证其设计符合分层式结构，可能需要在相应的业务逻辑层和数据访问层中都增加相应的代码。

前面提到，PetShop的表示层是用ASP.Net设计的，也就是说，它应是一个BS系统。在.Net中，标准的BS分层式结构如下图所示：

图二：.Net中标准的BS分层式结构

随着PetShop版本的更新，其分层式结构也在不断的完善，例如PetShop2.0，就没有采用标准的三层式结构，如图三：

图三：PetShop 2.0的体系架构

从 图中我们可以看到，并没有明显的数据访问层设计。这样的设计虽然提高了数据访问的性能，但也同时导致了业务逻辑层与数据访问的职责混乱。一旦要求支持的数 据库发生变化，或者需要修改数据访问的逻辑，由于没有清晰的分层，会导致项目作大的修改。而随着硬件系统性能的提高，以及充分利用缓存、异步处理等机制，
分层式结构所带来的性能影响几乎可以忽略不计。

PetShop3.0纠正了此前层次不明的问题，将数据访问逻辑作为单独的一层独立出来：

图四：PetShop 3.0的体系架构

PetShop4.0基本上延续了3.0的结构，但在性能上作了一定的改进，引入了缓存和异步处理机制，同时又充分利用了ASP.Net 2.0的新功能MemberShip，因此PetShop4.0的系统架构图如下所示：

图五：PetShop 4.0的体系架构

比 较3.0和4.0的系统架构图，其核心的内容并没有发生变化。在数据访问层（DAL）中，仍然采用DAL Interface抽象出数据访问逻辑，并以DAL Factory作为数据访问层对象的工厂模块。对于DAL Interface而言，分别有支持MS-SQL的SQL Server DAL和支持Oracle的Oracle DAL具体实现。而Model模块则包含了数据实体对象。其详细的模块结构图如下所示：

图六：数据访问层的模块结构图

可 以看到，在数据访问层中，完全采用了“面向接口编程”思想。抽象出来的IDAL模块，脱离了与具体数据库的依赖，从而使得整个数据访问层利于数据库迁移。
DALFactory模块专门管理DAL对象的创建，便于业务逻辑层访问。SQLServerDAL和OracleDAL模块均实现IDAL模块的接口， 其中包含的逻辑就是对数据库的Select，Insert，Update和Delete操作。因为数据库类型的不同，对数据库的操作也有所不同，代码也会
因此有所区别。

此外，抽象出来的IDAL模块，除了解除了向下的依赖之外，对于其上的业务逻辑层，同样仅存在弱依赖关系，如下图所示：

图七：业务逻辑层的模块结构图

图 七中BLL是业务逻辑层的核心模块，它包含了整个系统的核心业务。在业务逻辑层中，不能直接访问数据库，而必须通过数据访问层。注意图中对数据访问业务的
调用，是通过接口模块IDAL来完成的。既然与具体的数据访问逻辑无关，则层与层之间的关系就是松散耦合的。如果此时需要修改数据访问层的具体实现，只要
不涉及到IDAL的接口定义，那么业务逻辑层就不会受到任何影响。毕竟，具体实现的SQLServerDAL和OracalDAL根本就与业务逻辑层没有 半点关系。

因为在PetShop 4.0中引入了异步处理机制。插入订单的策略可以分为同步和异步，两者的插入策略明显不同，但对于调用者而言，插入订单的接口是完全一样的，所以 PetShop 4.0中设计了IBLLStrategy模块。虽然在IBLLStrategy模块中，仅仅是简单的IOrderStategy，但同时也给出了一个范例
和信息，那就是在业务逻辑的处理中，如果存在业务操作的多样化，或者是今后可能的变化，均应利用抽象的原理。或者使用接口，或者使用抽象类，从而脱离对具 体业务的依赖。不过在PetShop中，由于业务逻辑相对简单，这种思想体现得不够明显。也正因为此，PetShop将核心的业务逻辑都放到了一个模块 BLL中，并没有将具体的实现和抽象严格的按照模块分开。所以表示层和业务逻辑层之间的调用关系，其耦合度相对较高：

图八：表示层的模块结构图

在图五中，各个层次中还引入了辅助的模块，如数据访问层的Messaging模块，是为异步插入订单的功能提供，采用了MSMQ（Microsoft Messaging Queue）技术。而表示层的CacheDependency则提供缓存功能。

本文的一些评论：

那就是版主认为这里没有用ORM是一个败笔,我却不这样认为.
1. 首先引用版主的前言”PetShop是一个范例，微软用它来展示.Net企业系统开发的能力。业界有许多.Net与J2EE之争，许多数据是从微软的 PetShop和Sun的PetStore而来。这种争论不可避免带有浓厚的商业色彩”. 的确这是当时微软欲从java手中抢夺市场做的抄作,从先进技术而言,就像人的手掌,五指代表不不同的技术,当你沿着手指往下走的终点是都会到掌心.而且 无论从技术架构到oo观念的运用,java可以说已经做到了极至. 微软唯一能比拟的在当时就是想在他的performance方面做文章.所以,从这个角度来讲,他决不可能用orm的. 我本人套用这个架构曾试图将orm放进去,但是performance差了一大截,尤其是压力测试.
2.我认为在2.0中,如果将来都用 sql2005, 可能已经不再需要用hibernate等orm了,本身sql2005当中的相当大的部分就是参照了hibernate的思想的,所以有必要的话,微软可 能有一天在出一版的petshop就用他的sql2005的特性,也不是不可能,不过可能要等到微软对自己的sql2005的性能和稳定性到达一个信心程 度后,再看吧🙂
所以,以在下愚见,如果自身项目对于performance有很高要求的话,就费点累多写些code吧,而且借助一些代码生成器,这部分工作也不是那么恐怖. 

如果使用IoC+O/R Mapping，不但各层之间的耦合降低到最小，而且持久层的代码也会大大精简。
使用Spring.Net/Castle + NHibernate来重构一次，那么petshop将会真正的优雅起来

1.分层式结构不一定会导致性能问题，相反，在一个结合了WorkUnit的系统中，还可能会提供系统的性能。性能问题主要取决于具体软件在分层架构中所采用的技术实现和机制，与分层架构本身是没有任何关系的

2. 一个实现良好的分层结构并不会导致所谓的级联修改问题。对于一个业务层、表现层、数据访问层使用一一对应式的“蹩脚”实现，确实是会出现级联修改问题。但 是这大多是因为实现者仍然是用分层结构形式来做他的两层系统。分层结构本身的三个层次在设计、逻辑、接口上的粒度是完全不同的，从设计角度上看根本不存在
所谓级联问题，因为他的粗细颗粒不同，一个细粒度的DAC方法又怎么会导致一个粗粒度的BIZ方法的接口修改呢？表现层在实现良好的系统中往往会考虑模板 化的数据显示（诸如XSLT等技术），这些表现技术也能很好的剥离业务逻辑、数据含义与表现层的耦合性，所以也不会出现级联修改问题

并没有使用ORM，从而导致了代码量的增加，可以看作是整个设计实现中的一大败笔。
我不同意作者的这个说法,ormapping不用代码相对来说是增加了,但是不能说是败笔
虽说ormapping能使代码的编写量减少但是同时带来的是性能上的下降,对象与数据表的映射全部交于系统自动处理是很恐怖的一件事.

解剖PetShop》系列之二PetShop数据访问层之数据库访问设计

在系列一中，我从整体上分析了PetShop的架构设计，并提及了分层的概念。从本部分开始，我将依次对各层进行代码级的分析，以求获得更加细致而
深入的理解。在PetShop 4.0中，由于引入了ASP.Net 2.0的一些新特色，所以数据层的内容也更加的广泛和复杂，包括：数据库访问、Messaging、MemberShip、Profile四部分。在系列 二中，我将介绍有关数据库访问的设计。

在PetShop中，系统需要处理的数据库对象分为两类：一是数据实体，对应数据库中相应的数据表。它们没有行为，仅用于表现对象的数据。这些实体类都被放到Model程序集中，例如数据表Order对应的实体类OrderInfo，其类图如下： 

这些对象并不具有持久化的功能，简单地说，它们是作为数据的载体，便于业务逻辑针对相应数据表进行读/写操作。虽然这些类的属性分别映射了数据表的列，而每一个对象实例也恰恰对应于数据表的每一行，但这些实体类却并不具备对应的数据库访问能力。

由于数据访问层和业务逻辑层都将对这些数据实体进行操作，因此程序集Model会被这两层的模块所引用。

第 二类数据库对象则是数据的业务逻辑对象。这里所指的业务逻辑，并非业务逻辑层意义上的领域（domain）业务逻辑（从这个意义上，我更倾向于将业务逻辑
层称为“领域逻辑层”），一般意义上说，这些业务逻辑即为基本的数据库操作，包括Select，Insert，Update和Delete。由于这些业务 逻辑对象，仅具有行为而与数据无关，因此它们均被抽象为一个单独的接口模块IDAL，例如数据表Order对应的接口IOrder： 

将 数据实体与相关的数据库操作分离出来，符合面向对象的精神。首先，它体现了“职责分离”的原则。将数据实体与其行为分开，使得两者之间依赖减弱，当数据行 为发生改变时，并不影响Model模块中的数据实体对象，避免了因一个类职责过多、过大，从而导致该类的引用者发生“灾难性”的影响。其次，它体现了“抽
象”的精神，或者说是“面向接口编程”的最佳体现。抽象的接口模块IDAL，与具体的数据库访问实现完全隔离。这种与实现无关的设计，保证了系统的可扩展
性，同时也保证了数据库的可移植性。在PetShop中，可以支持SQL
Server和Oracle，那么它们具体的实现就分别放在两个不同的模块SQLServerDAL、OracleDAL中。

以Order为例，在SQLServerDAL、OracleDAL两个模块中，有不同的实现，但它们同时又都实现了IOrder接口，如图： 

从 数据库的实现来看，PetShop体现出了没有ORM框架的臃肿与丑陋。由于要对数据表进行Insert和Select操作，以SQL
Server为例，就使用了SqlCommand，SqlParameter，SqlDataReader等对象，以完成这些操作。尤其复杂的是 Parameter的传递，在PetShop中，使用了大量的字符串常量来保存参数的名称。此外，PetShop还专门为SQL Server和Oracle提供了抽象的Helper类，包装了一些常用的操作，如ExecuteNonQuery、ExecuteReader等方法。

在 没有ORM的情况下，使用Helper类是一个比较好的策略，利用它来完成数据库基本操作的封装，可以减少很多和数据库操作有关的代码，这体现了对象复用
的原则。PetShop将这些Helper类统一放到DBUtility模块中，不同数据库的Helper类暴露的方法基本相同，只除了一些特殊的要求，
例如Oracle中处理bool类型的方式就和SQL Server不同，从而专门提供了OraBit和OraBool方法。此外，Helper类中的方法均为static方法，以利于调用。 OracleHelper的类图如下： 

对 于数据访问层来说，最头疼的是SQL语句的处理。在早期的CS结构中，由于未采用三层式架构设计，数据访问层和业务逻辑层是紧密糅合在一起的，因此， SQL语句遍布与系统的每一个角落。这给程序的维护带来极大的困难。此外，由于Oracle使用的是PL-SQL，而SQL Server和Sybase等使用的是T-SQL，两者虽然都遵循了标准SQL的语法，但在很多细节上仍有区别，如果将SQL语句大量的使用到程序中，无 疑为可能的数据库移植也带来了困难。

最好的方法是采用存储过程。这种方法使得程序更加整洁，此外，由于存储过程可以以数据库脚本的形式存 在，也便于移植和修改。但这种方式仍然有缺陷。一是存储过程的测试相对困难。虽然有相应的调试工具，但比起对代码的调试而言，仍然比较复杂且不方便。二是
对系统的更新带来障碍。如果数据库访问是由程序完成，在.Net平台下，我们仅需要在修改程序后，将重新编译的程序集xcopy到部署的服务器上即可。如 果使用了存储过程，出于安全的考虑，必须有专门的DBA重新运行存储过程的脚本，部署的方式受到了限制。

我曾经在一个项目中，利用一个专门 的表来存放SQL语句。如要使用相关的SQL语句，就利用关键字搜索获得对应语句。这种做法近似于存储过程的调用，但却避免了部署上的问题。然而这种方式
却在性能上无法得到保证。它仅适合于SQL语句较少的场景。不过，利用良好的设计，我们可以为各种业务提供不同的表来存放SQL语句。同样的道理，这些 SQL语句也可以存放到XML文件中，更有利于系统的扩展或修改。不过前提是，我们需要为它提供专门的SQL语句管理工具。

SQL语句的使用无法避免，如何更好的应用SQL语句也无定论，但有一个原则值得我们遵守，就是“应该尽量让SQL语句尽存在于数据访问层的具体实现中”。

当 然，如果应用ORM，那么一切就变得不同了。因为ORM框架已经为数据访问提供了基本的Select，Insert，Update和Delete操作了。 例如在NHibernate中，我们可以直接调用ISession对象的Save方法，来Insert（或者说是Create）一个数据实体对象：
public void Insert(OrderInfo order)
{
    ISession s = Sessions.GetSession();
    ITransaction trans = null;
    try
    {
    trans = s.BeginTransaction();
      s.Save( order);
      trans.Commit();
    }
    finally
    {
      s.Close();
    }
}

没有SQL语句，也没有那些烦人的Parameters，甚至不需要专门去考虑事务。此外，这样的设计，也是与数据库无关的，NHibernate可以通过Dialect（方言）的机制支持不同的数据库。唯一要做的是，我们需要为OrderInfo定义hbm文件。

当 然，ORM框架并非是万能的，面对纷繁复杂的业务逻辑，它并不能完全消灭SQL语句，以及替代复杂的数据库访问逻辑，但它却很好的体现了“80/20（或 90/10）法则”（也被称为“帕累托法则”），也就是说：花比较少（10%-20%）的力气就可以解决大部分（80%-90%）的问题，而要解决剩下的 少部分问题则需要多得多的努力。至少，那些在数据访问层中占据了绝大部分的CRUD操作，通过利用ORM框架，我们就仅需要付出极少数时间和精力来解决它
们了。这无疑缩短了整个项目开发的周期。

还是回到对PetShop的讨论上来。现在我们已经有了数据实体，数据对象的抽象接口和实现，可以说有关数据库访问的主体就已经完成了。留待我们的还有两个问题需要解决：
1、数据对象创建的管理
2、利于数据库的移植

在PetShop 中，要创建的数据对象包括Order，Product，Category，Inventory，Item。在前面的设计中，这些对象已经被抽象为对应的接 口，而其实现则根据数据库的不同而有所不同。也就是说，创建的对象有多种类别，而每种类别又有不同的实现，这是典型的抽象工厂模式的应用场景。而上面所述
的两个问题，也都可以通过抽象工厂模式来解决。标准的抽象工厂模式类图如下： 

例如，创建SQL Server的Order对象如下：
PetShopFactory factory = new SQLServerFactory();
IOrder order = factory.CreateOrder();

要 考虑到数据库的可移植性，则factory必须作为一个全局变量，并在主程序运行时被实例化。但这样的设计虽然已经达到了“封装变化”的目的，但在创建
PetShopFactory对象时，仍不可避免的出现了具体的类SQLServerFactory，也即是说，程序在这个层面上产生了与 SQLServerFactory的强依赖。一旦整个系统要求支持Oracle，那么还需要修改这行代码为：
PetShopFactory factory = new OracleFactory();

修 改代码的这种行为显然是不可接受的。解决的办法是“依赖注入”。“依赖注入”的功能通常是用专门的IoC容器提供的，在Java平台下，这样的容器包括 Spring，PicoContainer等。而在.Net平台下，最常见的则是Spring.Net。不过，在PetShop系统中，并不需要专门的容 器来实现“依赖注入”，简单的做法还是利用配置文件和反射功能来实现。也就是说，我们可以在web.config文件中，配置好具体的Factory对象 的完整的类名。然而，当我们利用配置文件和反射功能时，具体工厂的创建就显得有些“画蛇添足”了，我们完全可以在配置文件中，直接指向具体的数据库对象实 现类，例如PetShop.SQLServerDAL.IOrder。那么，抽象工厂模式中的相关工厂就可以简化为一个工厂类了，所以我将这种模式称之为 “具有简单工厂特质的抽象工厂模式”，其类图如下： 

DataAccess类完全取代了前面创建的工厂类体系，它是一个sealed类，其中创建各种数据对象的方法，均为静态方法。之所以能用这个类达到抽象工厂的目的，是因为配置文件和反射的运用，如下的代码片断所示：
public sealed class DataAccess
{
 // Look up the DAL implementation we should be using
    private static readonly string path =
ConfigurationManager.AppSettings[”WebDAL”];
    private static readonly string orderPath =
ConfigurationManager.AppSettings[”OrdersDAL”];

 public static PetShop.IDAL.IOrder CreateOrder()
 {
         string className = orderPath +
“.Order”;
         return
(PetShop.IDAL.IOrder)Assembly.Load(orderPath).CreateInstance(className);
    }
}

在PetShop 中，这种依赖配置文件和反射创建对象的方式极其常见，包括IBLLStategy、CacheDependencyFactory等等。这些实现逻辑散布
于整个PetShop系统中，在我看来，是可以在此基础上进行重构的。也就是说，我们可以为整个系统提供类似于“Service Locator”的实现：
public static class ServiceLocator
{
 private static readonly string dalPath =
ConfigurationManager.AppSettings[”WebDAL”];
    private static readonly string orderPath =
ConfigurationManager.AppSettings[”OrdersDAL”];
 //……
 private static readonly string orderStategyPath =
ConfigurationManager.AppSettings[”OrderStrategyAssembly”];

 public static object LocateDALObject(string
className)
 {
  string fullPath = dalPath + “.” + className;
  return Assembly.Load(dalPath).CreateInstance(fullPath);
 }
public static object LocateDALOrderObject(string className)
 {
  string fullPath = orderPath + “.” + className;
  return Assembly.Load(orderPath).CreateInstance(fullPath);
 }
public static object LocateOrderStrategyObject(string className)
 {
  string fullPath = orderStategyPath + “.” + className;
  return Assembly.Load(orderStategyPath).CreateInstance(fullPath);
 }
 //……
}

那么和所谓“依赖注入”相关的代码都可以利用ServiceLocator来完成。例如类DataAccess就可以简化为：
public sealed class DataAccess
{
 public static PetShop.IDAL.IOrder CreateOrder()
 {
         return
(PetShop.IDAL.IOrder)ServiceLocator. LocateDALOrderObject(”Order”);
    }
}

通过ServiceLocator，将所有与配置文件相关的namespace值统一管理起来，这有利于各种动态创建对象的管理和未来的维护。 

解剖PetShop》系列之三—PetShop数据访问层之消息处理 

在进行系统设计时，除了对安全、事务等问题给与足够的重视外，性能也是一个不可避免的问题所在，尤其是一个B/S结构的软件系统，必须充分地考虑访问量、数据流量、服务器负荷的问题。解决性能的瓶颈，除了对硬件系统进行升级外，软件设计的合理性尤为重要。
    在前面我曾提到，分层式结构设计可能会在一定程度上影响数据访问的性能，然而与它给设计人员带来的好处相比，几乎可以忽略。要提供整个系统的性能，还可以
从数据库的优化着手，例如连接池的使用、建立索引、优化查询策略等等，例如在PetShop中就利用了数据库的Cache，对于数据量较大的订单数据，则 利用分库的方式为其单独建立了Order和Inventory数据库。而在软件设计上，比较有用的方式是利用多线程与异步处理方式。
    在PetShop4.0中，使用了Microsoft Messaging Queue(MSMQ)技术来完成异步处理，利用消息队列临时存放要插入的数据，使得数据访问因为不需要访问数据库从而提供了访问性能，至于队列中的数
据，则等待系统空闲的时候再进行处理，将其最终插入到数据库中。
    PetShop4.0中的消息处理，主要分为如下几部分：消息接口IMessaging、消息工厂MessagingFactory、MSMQ实现MSMQMessaging以及数据后台处理应用程序OrderProcessor。
从模块化分上，PetShop自始自终地履行了“面向接口设计”的原则，将消息处理的接口与实现分开，并通过工厂模式封装消息实现对象的创建，以达到松散耦合的目的。
    由于在PetShop中仅对订单的处理使用了异步处理方式，因此在消息接口IMessaging中，仅定义了一个IOrder接口，其类图如下：

    在对消息接口的实现中，考虑到未来的扩展中会有其他的数据对象会使用MSMQ，因此定义了一个Queue的基类，实现消息Receive和Send的基本操作：
public virtual object Receive()
{
      try
     {
          using (Message message =
queue.Receive(timeout, transactionType))
             return
message;
      }
      catch (MessageQueueException mqex)
     {
          if
(mqex.MessageQueueErrorCode == MessageQueueErrorCode.IOTimeout)
             throw
new TimeoutException();
               
throw;
      }
}
public virtual void Send(object msg)
{
      queue.Send(msg, transactionType);
}
    其中queue对象是System.Messaging.MessageQueue类型，作为存放数据的队列。MSMQ队列是一个可持久的队列，因此不必 担心用户不间断地下订单会导致订单数据的丢失。在PetShopQueue设置了timeout值，OrderProcessor会根据timeout值 定期扫描队列中的订单数据。
    MSMQMessaging模块中，Order对象实现了IMessaging模块中定义的接口IOrder，同时它还继承了基类PetShopQueue，其定义如下：
    public class Order:PetShopQueue, PetShop.IMessaging.IOrder
    方法的实现代码如下：
    public new OrderInfo Receive()
    {
        // This method involves in
distributed transaction and need Automatic Transaction type
        base.transactionType =
MessageQueueTransactionType.Automatic;
        return
(OrderInfo)((Message)base.Receive()).Body;
    }     public OrderInfo Receive(int
timeout)
    {
        base.timeout =
TimeSpan.FromSeconds(Convert.ToDouble(timeout));
        return Receive();
    }

    public void Send(OrderInfo orderMessage)
    {
        // This method does not involve in
distributed transaction and optimizes performance using Single type
        base.transactionType =
MessageQueueTransactionType.Single;
        base.Send(orderMessage);
    }
    所以，最后的类图应该如下： 

    注意在Order类的Receive()方法中，是用new关键字而不是override关键字来重写其父类PetShopQueue的Receive ()虚方法。因此，如果是实例化如下的对象，将会调用PetShopQueue的Receive()方法，而不是子类Order的Receive()方 法：
    PetShopQueue queue = new Order();
    queue.Receive();
    从设计上来看，由于PetShop采用“面向接口设计”的原则，如果我们要创建Order对象，应该采用如下的方式：
    IOrder order = new Order();
    order.Receive();
    考虑到IOrder的实现有可能的变化，PetShop仍然利用了工厂模式，将IOrder对象的创建用专门的工厂模块进行了封装： 

    在类QueueAccess中，通过CreateOrder()方法利用反射技术创建正确的IOrder类型对象：
    public static PetShop.IMessaging.IOrder CreateOrder()
    {
        string className = path + “.Order”;
        return
PetShop.IMessaging.IOrder)Assembly.Load(path).CreateInstance(className);
    }
    path的值通过配置文件获取：
    private static readonly string path =
ConfigurationManager.AppSettings[”OrderMessaging”];
    而配置文件中，OrderMessaging的值设置如下：
    <add key=”OrderMessaging”
value=”PetShop.MSMQMessaging”/>
    之所以利用工厂模式来负责对象的创建，是便于在业务层中对其调用，例如在BLL模块中OrderAsynchronous类：
public class OrderAsynchronous : IOrderStrategy
{       
    private static readonly PetShop.IMessaging.IOrder
asynchOrder = PetShop.MessagingFactory.QueueAccess.CreateOrder();
    public void Insert(PetShop.Model.OrderInfo order)
{
        asynchOrder.Send(order);
    }
}
    一旦IOrder接口的实现发生变化，这种实现方式就可以使得客户仅需要修改配置文件，而不需要修改代码，如此就可以避免程序集的重新编译和部署，使得系
统能够灵活应对需求的改变。例如定义一个实现IOrder接口的SpecialOrder，则可以新增一个模块，如 PetShop.SpecialMSMQMessaging，而类名则仍然为Order，那么此时我们仅需要修改配置文件中OrderMessaging 的值即可：
    <add key=”OrderMessaging”
value=”PetShop.SpecialMSMQMessaging”/>
    OrderProcessor是一个控制台应用程序，不过可以根据需求将其设计为Windows Service。它的目的就是接收消息队列中的订单数据，然后将其插入到Order和Inventory数据库中。它利用了多线程技术，以达到提高系统性能的目的。
    在OrderProcessor应用程序中，主函数Main用于控制线程，而核心的执行任务则由方法ProcessOrders()实现：
    private static void ProcessOrders()
    {
        // the transaction timeout should be
long enough to handle all of orders in the batch
        TimeSpan tsTimeout =
TimeSpan.FromSeconds(Convert.ToDouble(transactionTimeout * batchSize));

        Order order = new Order();
        while (true)
        {
            // queue
timeout variables
            TimeSpan
datetimeStarting = new TimeSpan(DateTime.Now.Ticks);
            double
elapsedTime = 0;

            int
processedItems = 0;

           
ArrayList queueOrders = new ArrayList();

            using
(TransactionScope ts = new TransactionScope(TransactionScopeOption.Required,
tsTimeout))
            {
               
// Receive the orders from the queue
               
for (int j = 0; j < batchSize; j++)
               
{
                   
try
                   
{
                       
//only receive more queued orders if there is enough time
                       
if ((elapsedTime + queueTimeout + transactionTimeout) <
tsTimeout.TotalSeconds)
                       
{
                           
queueOrders.Add(order.ReceiveFromQueue(queueTimeout));
                       
}
                       
else
                       
{
                           
j = batchSize;   // exit loop
                       
}

                       
//update elapsed time
                       
elapsedTime = new TimeSpan(DateTime.Now.Ticks).TotalSeconds –
datetimeStarting.TotalSeconds;
                   
}
                   
catch (TimeoutException)
                   
{
                       
//exit loop because no more messages are waiting
                       
j = batchSize;
                   
}
               
}
               
//process the queued orders
               
for (int k = 0; k < queueOrders.Count; k++)
               
{
                   
order.Insert((OrderInfo)queueOrders[k]);
                   
processedItems++;
                   
totalOrdersProcessed++;
               
}

               
//batch complete or MSMQ receive timed out
               
ts.Complete();
            }

           
Console.WriteLine(“(Thread Id ” +
Thread.CurrentThread.ManagedThreadId + “) batch finished, ” +
processedItems + ” items, in ” + elapsedTime.ToString() + ”
seconds.”);
        }
    }
    首先，它会通过PetShop.BLL.Order类的公共方法ReceiveFromQueue()来获取消息队列中的订单数据，并将其放入到一个
ArrayList对象中，然而再调用PetShop.BLL.Order类的Insert方法将其插入到Order和Inventory数据库中。
    在PetShop.BLL.Order类中，并不是直接执行插入订单的操作，而是调用了IOrderStrategy接口的Insert()方法：
public void Insert(OrderInfo order)
{
    // Call credit card procesor
    ProcessCreditCard(order);

    // Insert the order (a)synchrounously based on
configuration
    orderInsertStrategy.Insert(order);
}
    在这里，运用了一个策略模式，类图如下所示： 

    在PetShop.BLL.Order类中，仍然利用配置文件来动态创建IOrderStategy对象：
private static readonly PetShop.IBLLStrategy.IOrderStrategy orderInsertStrategy
= LoadInsertStrategy();
private static PetShop.IBLLStrategy.IOrderStrategy LoadInsertStrategy()
{
    // Look up which strategy to use from config file
    string path = ConfigurationManager.AppSettings[”OrderStrategyAssembly”];
    string className =
ConfigurationManager.AppSettings[”OrderStrategyClass”];

    // Using the evidence given in the config file load the
appropriate assembly and class
    return
(PetShop.IBLLStrategy.IOrderStrategy)Assembly.Load(path).CreateInstance(className);
}
    由于OrderProcessor是一个单独的应用程序，因此它使用的配置文件与PetShop不同，是存放在应用程序的App.config文件中，在该文件中，对IOrderStategy的配置为：
    <add key=”OrderStrategyAssembly” value=”PetShop.BLL”
/>
    <add key=”OrderStrategyClass”
value=”PetShop.BLL.OrderSynchronous” />   
    因此，以异步方式插入订单的流程如下图所示： 

    Microsoft Messaging Queue(MSMQ)技术除用于异步处理以外，它主要还是一种分布式处理技术。分布式处理中，一个重要的技术要素就是有关消息的处理，而在
System.Messaging命名空间中，已经提供了Message类，可以用于承载消息的传递，前提上消息的发送方与接收方在数据定义上应有统一的
接口规范。
    MSMQ在分布式处理的运用，在我参与的项目中已经有了实现。在为一个汽车制造商开发一个大型系统时，分销商Dealer作为.Net客户端，需要将数据 传递到管理中心，并且该数据将被Oracle的EBS(E-Business System)使用。由于分销商管理系统（DMS）采用的是C/S结构，数据库为SQL
Server，而汽车制造商管理中心的EBS数据库为Oracle。这里就涉及到两个系统之间数据的传递。
    实现架构如下：

     首先Dealer的数据通过MSMQ传递到MSMQ Server，此时可以将数据插入到SQL Server数据库中，同时利用FTP将数据传送到专门的文件服务器上。然后利用IBM的EAI技术（企业应用集成，Enterprise
Application Itegration）定期将文件服务器中的文件，利用接口规范写入到EAI数据库服务器中，并最终写道EBS的Oracle数据库中。
    上述架构是一个典型的分布式处理结构，而技术实现的核心就是MSMQ和EAI。由于我们已经定义了统一的接口规范，在通过消息队列形成文件后，此时的数据 就已经与平台无关了，使得在.Net平台下的分销商管理系统能够与Oracle的EBS集成起来，完成数据的处理。

 
 PetShop之ASP.NET缓存

如果对微型计算机硬件系统有足够的了解，那么我们对于Cache这个名词一定是耳熟能详的。 在CPU以及主板的芯片中，都引入了这种名为高速缓冲存储器（Cache）的技术。因为Cache的存取速度比内存快，因而引入Cache能够有效的解决 CPU与内存之间的速度不匹配问题。硬件系统可以利用Cache存储CPU访问概率高的那些数据，当CPU需要访问这些数据时，可以直接从Cache中读 取，而不必访问存取速度相对较慢的内存，从而提高了CPU的工作效率。软件设计借鉴了硬件设计中引入缓存的机制以改善整个系统的性能，尤其是对于一个数据 库驱动的Web应用程序而言，缓存的利用是不可或缺的，毕竟，数据库查询可能是整个Web站点中调用最频繁但同时又是执行最缓慢的操作之一，我们不能被它
老迈的双腿拖缓我们前进的征程。缓存机制正是解决这一缺陷的加速器。

4.1  ASP.NET缓存概述

作 为.Net框架下开发Web应用程序的主打产品，ASP.NET充分考虑了缓存机制。通过某种方法，将系统需要的数据对象、Web页面存储在内存中，使得 Web站点在需要获取这些数据时，不需要经过繁琐的数据库连接、查询和复杂的逻辑运算，就可以“触手可及”，如“探囊取物”般容易而快速，从而提高整个 Web系统的性能。

ASP.NET提供了两种基本的缓存机制来提供缓存功能。一种是应用程序缓存，它允许开发者将程序生成的数据或报表业务对象放入缓存中。另外一种缓存机制是页输出缓存，利用它，可以直接获取存放在缓存中的页面，而不需要经过繁杂的对该页面的再次处理。

应用程序缓存其实现原理说来平淡无奇，仅仅是通过ASP.NET管理内存中的缓存空间。放入缓存中的应用程序数据对象，以键/值对的方式存储，这便于用户在访问缓存中的数据项时，可以根据key值判断该项是否存在缓存中。

放 入在缓存中的数据对象其生命周期是受到限制的，即使在整个应用程序的生命周期里，也不能保证该数据对象一直有效。ASP.NET可以对应用程序缓存进行管 理，例如当数据项无效、过期或内存不足时移除它们。此外，调用者还可以通过CacheItemRemovedCallback委托，定义回调方法使得数据 项被移除时能够通知用户。

在.Net
Framework中，应用程序缓存通过System.Web.Caching.Cache类实现。它是一个密封类，不能被继承。对于每一个应用程序域，
都要创建一个Cache类的实例，其生命周期与应用程序域的生命周期保持一致。我们可以利用Add或Insert方法，将数据项添加到应用程序缓存中，如 下所示：
Cache[”First”] = “First Item”;
Cache.Insert(”Second”, “Second Item”);

我们还可以为应用程序缓存添加依赖项，使得依赖项发生更改时，该数据项能够从缓存中移除：
string[] dependencies = {”Second”};
Cache.Insert(”Third”, “Third Item”,
new System.Web.Caching.CacheDependency(null, dependencies));

与之对应的是缓存中数据项的移除。前面提到ASP.NET可以自动管理缓存中项的移除，但我们也可以通过代码编写的方式显式的移除相关的数据项：
Cache.Remove(”First”);

相 对于应用程序缓存而言，页输出缓存的应用更为广泛。它可以通过内存将处理后的ASP.NET页面存储起来，当客户端再一次访问该页面时，可以省去页面处理 的过程，从而提高页面访问的性能，以及Web服务器的吞吐量。例如，在一个电子商务网站里，用户需要经常查询商品信息，这个过程会涉及到数据库访问以及搜 索条件的匹配，在数据量较大的情况下，如此的搜索过程是较为耗时的。此时，利用页输出缓存就可以将第一次搜索得到的查询结果页存储在缓存中。当用户第二次
查询时，就可以省去数据查询的过程，减少页面的响应时间。

页输出缓存分为整页缓存和部分页缓存。我们可以通过@OutputCache指令 完成对Web页面的输出缓存。它主要包含两个参数：Duration和VaryByParam。Duration参数用于设置页面或控件进行缓存的时间， 其单位为秒。如下的设置表示缓存在60秒内有效：
< %@ OutputCache Duration=“60“ VaryByParam=“none“ %>

只要没有超过Duration设置的期限值，当用户访问相同的页面或控件时，就可以直接在缓存中获取。
使用VaryByParam参数可以根据设置的参数值建立不同的缓存。例如在一个输出天气预报结果的页面中，如果需要为一个ID为txtCity的TextBox控件建立缓存，其值将显示某城市的气温，那么我们可以进行如下的设置：
< %@ OutputCache Duration=”60”
VaryByParam=”txtCity” %>

如此一来，ASP.NET会对txtCity控件的值进行判断，只有输入的值与缓存值相同，才从缓存中取出相应的值。这就有效地避免了因为值的不同而导致输出错误的数据。

利用缓存的机制对性能的提升非常明显。通过ACT（Application Center Test）的测试，可以发现设置缓存后执行的性能比未设置缓存时的性能足足提高三倍多。

引 入缓存看来是提高性能的“完美”解决方案，然而“金无足赤，人无完人”，缓存机制也有缺点，那就是数据过期的问题。一旦应用程序数据或者页面结果值发生的 改变，那么在缓存有效期范围内，你所获得的结果将是过期的、不准确的数据。我们可以想一想股票系统利用缓存所带来的灾难，当你利用错误过期的数据去分析股
市的风云变幻时，你会发现获得的结果真可以说是“失之毫厘，谬以千里”，看似大好的局面就会像美丽的泡沫一样，用针一戳，转眼就消失得无影无踪。

那 么我们是否应该为了追求高性能，而不顾所谓“数据过期”所带来的隐患呢？显然，在类似于股票系统这种数据更新频繁的特定场景下，数据过期的糟糕表现甚至比
低效的性能更让人难以接受。故而，我们需要在性能与数据正确性间作出权衡。所幸的是，.Net Framework 2.0引入了一种新的缓存机制，它为我们的“鱼与熊掌兼得”带来了技术上的可行性。

.Net 2.0引入的自定义缓存依赖项，特别是基于MS-SQL Server的SqlCacheDependency特性，使得我们可以避免“数据过期”的问题，它能够根据数据库中相应数据的变化，通知缓存，并移除那 些过期的数据。事实上，在PetShop
4.0中，就充分地利用了SqlCacheDependency特性。

4.2 SqlCacheDependency特性

SqlCacheDependency 特性实际上是通过System.Web.Caching.SqlCacheDependency类来体现的。通过该类，可以在所有支持的SQL Server版本（7.0，2000，2005）上监视特定的SQL Server数据库表，并创建依赖于该表以及表中数据行的缓存项。当数据表或表中特定行的数据发生更改时，具有依赖项的数据项就会失效，并自动从 Cache中删除该项，从而保证了缓存中不再保留过期的数据。
由于版本的原因，SQL Server 2005完全支持SqlCacheDependency特性，但对于SQL Server 7.0和SQL Server 2000而言，就没有如此幸运了。毕竟这些产品出现在.Net Framework 2.0之前，因此它并没有实现自动监视数据表数据变化，通知ASP.NET的功能。解决的办法就是利用轮询机制，通过ASP.NET进程内的一个线程以指 定的时间间隔轮询SQL Server数据库，以跟踪数据的变化情况。

要使得7.0或者2000版本的SQL
Server支持SqlCacheDependency特性，需要对数据库服务器执行相关的配置步骤。有两种方法配置SQL Server：使用aspnet_regsql命令行工具，或者使用SqlCacheDependencyAdmin类。

4.2.1  利用aspnet_regsql工具

aspnet_regsql工具位于Windows\Microsoft.NET\Framework\[版本]文件夹中。如果直接双击该工具的执行文件，会弹出一个向导对话框，提示我们完成相应的操作：

图4-1 aspnet_regsql工具

如 图4-1所示中的提示信息，说明该向导主要用于配置SQL Server数据库，如membership，profiles等信息，如果要配置SqlCacheDependency，则需要以命令行的方式执行。以 PetShop
4.0为例，数据库名为MSPetShop4，则命令为：
aspnet_regsql -S localhost -E -d MSPetShop4 -ed

以下是该工具的命令参数说明：
-?  显示该工具的帮助功能；
-S  后接的参数为数据库服务器的名称或者IP地址；
-U  后接的参数为数据库的登陆用户名；
-P  后接的参数为数据库的登陆密码；
-E  当使用windows集成验证时，使用该功能；
-d  后接参数为对哪一个数据库采用SqlCacheDependency功能；
-t  后接参数为对哪一个表采用SqlCacheDependency功能；
-ed  允许对数据库使用SqlCacheDependency功能；
-dd  禁止对数据库采用SqlCacheDependency功能；
-et  允许对数据表采用SqlCacheDependency功能；
-dt  禁止对数据表采用SqlCacheDependency功能；
-lt  列出当前数据库中有哪些表已经采用sqlcachedependency功能。

以上面的命令为例，说明将对名为MSPetShop4的数据库采用SqlCacheDependency功能，且SQL Server采用了windows集成验证方式。我们还可以对相关的数据表执行aspnet_regsql命令，如：
aspnet_regsql -S localhost -E -d MSPetShop4 -t Item -et
aspnet_regsql -S localhost -E -d MSPetShop4 -t Product -et
aspnet_regsql -S localhost -E -d MSPetShop4 -t Category -et

当 执行上述的四条命令后，aspnet_regsql工具会在MSPetShop4数据库中建立一个名为 AspNet_SqlCacheTablesForChangeNotification的新数据库表。该数据表包含三个字段。字段tableName记 录要追踪的数据表的名称，例如在PetShop 4.0中，要记录的数据表就包括Category、Item和Product。notificationCreated字段记录开始追踪的时间。 changeId作为一个类型为int的字段，用于记录数据表数据发生变化的次数。如图4-2所示：

图4-2
AspNet_SqlCacheTablesForChangeNotification数据表

除 此之外，执行该命令还会为MSPetShop4数据库添加一组存储过程，为ASP.NET提供查询追踪的数据表的情况，同时还将为使用了 SqlCacheDependency的表添加触发器，分别对应Insert、Update、Delete等与数据更改相关的操作。例如Product数 据表的触发器：
CREATE TRIGGER dbo.[Product_AspNet_SqlCacheNotification_Trigger] ON [Product]
    FOR INSERT, UPDATE, DELETE AS BEGIN
    SET NOCOUNT ON
    EXEC dbo.AspNet_SqlCacheUpdateChangeIdStoredProcedure
N’Product’
END

其 中，AspNet_SqlCacheUpdateChangeIdStoredProcedure即是工具添加的一组存储过程中的一个。当对 Product数据表执行Insert、Update或Delete等操作时，就会激活触发器，然后执行
AspNet_SqlCacheUpdateChangeIdStoredProcedure存储过程。其执行的过程就是修改 AspNet_SqlCacheTablesForChangeNotification数据表的changeId字段值：
CREATE PROCEDURE dbo.AspNet_SqlCacheUpdateChangeIdStoredProcedure
            
@tableName NVARCHAR(450)
         AS
         BEGIN
             UPDATE
dbo.AspNet_SqlCacheTablesForChangeNotification WITH (ROWLOCK) SET changeId =
changeId + 1
             WHERE
tableName = @tableName
         END  
GO

4.2.2  利用SqlCacheDependencyAdmin类

我们也可以利用编程的方式来来管理数据库对SqlCacheDependency特性的使用。该类包含了五个重要的方法：

表4-1 SqlCacheDependencyAdmin类的主要方法

假设我们定义了如下的数据库连接字符串：
const string connectionStr = “Server=localhost;Database=MSPetShop4″;

那么为数据库MSPetShop4启用SqlCacheDependency对象更改通知的实现为：
protected void Page_Load(object sender, EventArgs e)
{
    if (!IsPostBack)
   {
      
SqlCacheDependencyAdmin.EnableNotifications(connectionStr);
   }
}

为数据表Product启用SqlCacheDependency对象更改通知的实现则为：
SqlCacheDependencyAdmin.EnableTableForNotifications(connectionStr, “Product”);

如果要调用表4-1中所示的相关方法，需要注意的是访问SQL Server数据库的帐户必须具有创建表和存储过程的权限。如果要调用EnableTableForNotifications方法，还需要具有在该表上创建SQL
Server触发器的权限。

虽 然说编程方式赋予了程序员更大的灵活性，但aspnet_regsql工具却提供了更简单的方法实现对SqlCacheDependency的配置与管
理。PetShop 4.0采用的正是aspnet_regsql工具的办法，它编写了一个文件名为InstallDatabases.cmd的批处理文件，其中包含了对
aspnet_regsql工具的执行，并通过安装程序去调用该文件，实现对SQL Server的配置。

4.3 在PetShop 4.0中ASP.NET缓存的实现

PetShop 作为一个B2C的宠物网上商店，需要充分考虑访客的用户体验，如果因为数据量大而导致Web服务器的响应不及时，页面和查询数据迟迟得不到结果，会因此而 破坏客户访问网站的心情，在耗尽耐心的等待后，可能会失去这一部分客户。无疑，这是非常糟糕的结果。因而在对其进行体系架构设计时，整个系统的性能就显得
殊为重要。然而，我们不能因噎废食，因为专注于性能而忽略数据的正确性。在PetShop 3.0版本以及之前的版本，因为ASP.NET缓存的局限性，这一问题并没有得到很好的解决。PetShop 4.0则引入了SqlCacheDependency特性，使得系统对缓存的处理较之以前大为改观。

4.3.1  CacheDependency接口

PetShop 4.0引入了SqlCacheDependency特性，对Category、Product和Item数据表对应的缓存实施了SQL Cache Invalidation技术。当对应的数据表数据发生更改后，该技术能够将相关项从缓存中移除。实现这一技术的核心是 SqlCacheDependency类，它继承了CacheDependency类。然而为了保证整个架构的可扩展性，我们也允许设计者建立自定义的 CacheDependency类，用以扩展缓存依赖。这就有必要为CacheDependency建立抽象接口，并在web.config文件中进行配 置。

在PetShop
4.0的命名空间PetShop.ICacheDependency中，定义了名为IPetShopCacheDependency接口，它仅包含了一个接口方法：
public interface IPetShopCacheDependency
{      
    AggregateCacheDependency GetDependency();
}

AggregateCacheDependency是.Net
Framework 2.0新增的一个类，它负责监视依赖项对象的集合。当这个集合中的任意一个依赖项对象发生改变时，该依赖项对象对应的缓存对象都将被自动移除。
AggregateCacheDependency 类起到了组合CacheDependency对象的作用，它可以将多个CacheDependency对象甚至于不同类型的 CacheDependency对象与缓存项建立关联。由于PetShop需要为Category、Product和Item数据表建立依赖项，因而 IPetShopCacheDependency的接口方法GetDependency()其目的就是返回建立了这些依赖项的
AggregateCacheDependency对象。

4.3.2  CacheDependency实现

CacheDependency的实现正是为Category、Product和Item数据表建立了对应的SqlCacheDependency类型的依赖项，如代码所示：
public abstract class TableDependency : IPetShopCacheDependency
{
    // This is the separator that’s used in web.config
    protected char[] configurationSeparator = new char[] { ‘,’
};

    protected AggregateCacheDependency dependency = new
AggregateCacheDependency();
    protected TableDependency(string configKey)
    {
        string dbName =
ConfigurationManager.AppSettings[”CacheDatabaseName”];
        string tableConfig =
ConfigurationManager.AppSettings[configKey];
        string[] tables =
tableConfig.Split(configurationSeparator);

        foreach (string tableName in
tables)
           
dependency.Add(new SqlCacheDependency(dbName, tableName));
    }
    public AggregateCacheDependency GetDependency()
   {
        return dependency;
    }
}

需要建立依赖项的数据库与数据表都配置在web.config文件中，其设置如下：

根 据各个数据表间的依赖关系，因而不同的数据表需要建立的依赖项也是不相同的，从配置文件中的value值可以看出。然而不管建立依赖项的多寡，其创建的行 为逻辑都是相似的，因而在设计时，抽象了一个共同的类TableDependency，并通过建立带参数的构造函数，完成对依赖项的建立。由于接口方法 GetDependency()的实现中，返回的对象dependency是在受保护的构造函数创建的，因此这里的实现方式也可以看作是Template Method模式的灵活运用。例如TableDependency的子类Product，就是利用父类的构造函数建立了Product、Category 数据表的SqlCacheDependency依赖：
public class Product : TableDependency
{
    public Product() : base(”ProductTableDependency”) { }
}

如 果需要自定义CacheDependency，那么创建依赖项的方式又有不同。然而不管是创建SqlCacheDependency对象，还是自定义的 CacheDependency对象，都是将这些依赖项添加到AggregateCacheDependency类中，因而我们也可以为自定义 CacheDependency建立专门的类，只要实现IPetShopCacheDependency接口即可。

4.3.3  CacheDependency工厂

继 承了抽象类TableDependency的Product、Category和Item类均需要在调用时创建各自的对象。由于它们的父类 TableDependency实现了接口IPetShopCacheDependency，因而它们也间接实现了 IPetShopCacheDependency接口，这为实现工厂模式提供了前提。

在PetShop
4.0中，依然利用了配置文件和反射技术来实现工厂模式。命名空间PetShop.CacheDependencyFactory中，类DependencyAccess即为创建IPetShopCacheDependency对象的工厂类：
public static class DependencyAccess
{       
    public static IPetShopCacheDependency
CreateCategoryDependency()
    {
        return LoadInstance(”Category”);
    }
    public static IPetShopCacheDependency CreateProductDependency()
    {
        return LoadInstance(”Product”);
    }
    public static IPetShopCacheDependency CreateItemDependency()
    {
        return LoadInstance(”Item”);
    }
    private static IPetShopCacheDependency LoadInstance(string
className)
    {
        string path =
ConfigurationManager.AppSettings[”CacheDependencyAssembly”];
        string fullyQualifiedClass = path +
“.” + className;
        return
(IPetShopCacheDependency)Assembly.Load(path).CreateInstance(fullyQualifiedClass);
    }
}
整个工厂模式的实现如图4-3所示：

 图4-3 CacheDependency工厂

虽 然DependencyAccess类创建了实现了IPetShopCacheDependency接口的类Category、Product、
Item，然而我们之所以引入IPetShopCacheDependency接口，其目的就在于获得创建了依赖项的 AggregateCacheDependency类型的对象。我们可以调用对象的接口方法GetDependency()，如下所示：
AggregateCacheDependency dependency =
DependencyAccess.CreateCategoryDependency().GetDependency();

为了方便调用者，似乎我们可以对DependencyAccess类进行改进，将原有的CreateCategoryDependency()方法，修改为创建AggregateCacheDependency类型对象的方法。

然而这样的做法扰乱了作为工厂类的DependencyAccess的本身职责，且创建IPetShopCacheDependency接口对象的行为仍然有可能被调用者调用，所以保留原有的DependencyAccess类仍然是有必要的。

在PetShop
4.0的设计中，是通过引入Facade模式以方便调用者更加简单地获得AggregateCacheDependency类型对象。

4.3.4  引入Facade模式

利用Facade模式可以将一些复杂的逻辑进行包装，以方便调用者对这些复杂逻辑的调用。就好像提供一个统一的门面一般，将内部的子系统封装起来，统一为一个高层次的接口。一个典型的Facade模式示意图如下所示：

图4-4 Facade模式

Facade 模式的目的并非要引入一个新的功能，而是在现有功能的基础上提供一个更高层次的抽象，使得调用者可以直接调用，而不用关心内部的实现方式。以 CacheDependency工厂为例，我们需要为调用者提供获得AggregateCacheDependency对象的简便方法，因而创建了 DependencyFacade类：
public static class DependencyFacade
{
    private static readonly string path =
ConfigurationManager.AppSettings[”CacheDependencyAssembly”];
    public static AggregateCacheDependency
GetCategoryDependency()
    {
        if (!string.IsNullOrEmpty(path))
            return
DependencyAccess.CreateCategoryDependency().GetDependency();
        else
            return null;
    }
    public static AggregateCacheDependency
GetProductDependency()
    {
        if (!string.IsNullOrEmpty(path))
            return
DependencyAccess.CreateProductDependency().GetDependency();
        else
            return null;
        }
    public static AggregateCacheDependency GetItemDependency()
    {
        if (!string.IsNullOrEmpty(path))
            return
DependencyAccess.CreateItemDependency().GetDependency();
        else
            return null;
    }
}

DependencyFacade类封装了获取AggregateCacheDependency类型对象的逻辑，如此一来，调用者可以调用相关方法获得创建相关依赖项的AggregateCacheDependency类型对象：
AggregateCacheDependency dependency = DependencyFacade.GetCategoryDependency();

比起直接调用DependencyAccess类的GetDependency()方法而言，除了方法更简单之外，同时它还对CacheDependencyAssembly配置节进行了判断，如果其值为空，则返回null对象。

在PetShop.Web的App_Code文件夹下，静态类WebUtility的GetCategoryName()和GetProductName()方法调用了DependencyFacade类。例如GetCategoryName()方法：
public static string GetCategoryName(string categoryId)
{
     Category category = new Category();
     if (!enableCaching)
            return category.GetCategory(categoryId).Name;

     string cacheKey =
string.Format(CATEGORY_NAME_KEY, categoryId);

     // 检查缓存中是否存在该数据项;
     string data = (string)HttpRuntime.Cache[cacheKey];
     if (data == null)
     {
           // 通过web.config的配置获取duration值;
           int cacheDuration
= int.Parse(ConfigurationManager.AppSettings[”CategoryCacheDuration”]);
           // 如果缓存中不存在该数据项，则通过业务逻辑层访问数据库获取;
           data =
category.GetCategory(categoryId).Name;
           // 通过Facade类创建AggregateCacheDependency对象;
          
AggregateCacheDependency cd = DependencyFacade.GetCategoryDependency();
           // 将数据项以及AggregateCacheDependency 对象存储到缓存中;
          
HttpRuntime.Cache.Add(cacheKey, data, cd, DateTime.Now.AddHours(cacheDuration),
Cache.NoSlidingExpiration, CacheItemPriority.High, null);
      }
      return data;
}

GetCategoryName ()方法首先会检查缓存中是否已经存在CategoryName数据项，如果已经存在，就通过缓存直接获取数据；否则将通过业务逻辑层调用数据访问层访问
数据库获得CategoryName，在获得了CategoryName后，会将新获取的数据连同DependencyFacade类创建的
AggregateCacheDependency对象添加到缓存中。

WebUtility静态类被表示层的许多页面所调用，例如Product页面：
public partial class Products : System.Web.UI.Page
{
    protected void Page_Load(object sender, EventArgs e)
    {
        Page.Title =
WebUtility.GetCategoryName(Request.QueryString[”categoryId”]);
    }
}

显示页面title的逻辑是放在Page_Load事件方法中，因而每次打开该页面都要执行获取CategoryName的方法。如果没有采用缓存机制，当Category数据较多时，页面的显示就会非常缓慢。

4.3.5  引入Proxy模式

业 务逻辑层BLL中与Product、Category、Item有关的业务方法，其实现逻辑是调用数据访问层（DAL）对象访问数据库，以获取相关数据。
为了改善系统性能，我们就需要为这些实现方法增加缓存机制的逻辑。当我们操作增加了缓存机制的业务对象时，对于调用者而言，应与BLL业务对象的调用保持
一致。也即是说，我们需要引入一个新的对象去控制原来的BLL业务对象，这个新的对象就是Proxy模式中的代理对象。

以PetShop.BLL.Product业务对象为例，PetShop为其建立了代理对象ProductDataProxy，并在GetProductByCategory()等方法中，引入了缓存机制，例如：
public static class ProductDataProxy
{

    private static readonly int productTimeout =
int.Parse(ConfigurationManager.AppSettings[”ProductCacheDuration”]);
    private static readonly bool enableCaching =
bool.Parse(ConfigurationManager.AppSettings[”EnableCaching”]);
       
    public static IList
GetProductsByCategory(string category)
    {
        Product product = new Product();

        if (!enableCaching)
            return
product.GetProductsByCategory(category);

        string key =
“product_by_category_” + category;
        IList data = (IList
)HttpRuntime.Cache[key];

        // Check if the data exists in
the data cache
        if (data == null)
        {
            data =
product.GetProductsByCategory(category);

            //
Create a AggregateCacheDependency object from the factory
           
AggregateCacheDependency cd = DependencyFacade.GetProductDependency();

            //
Store the output in the data cache, and Add the necessary
AggregateCacheDependency object
           
HttpRuntime.Cache.Add(key, data, cd, DateTime.Now.AddHours(productTimeout),
Cache.NoSlidingExpiration, CacheItemPriority.High, null);
        }
        return data;
    }
}

与 业务逻辑层Product对象的GetProductsByCategory()方法相比，增加了缓存机制。当缓存内不存在相关数据项时，则直接调用业务
逻辑层Product的GetProductsByCategory()方法来获取数据，并将其与对应的 AggregateCacheDependency对象一起存储在缓存中。

引入Proxy模式，实现了在缓存级别上对业务对象的封装，增强了对业务对象的控制。由于暴露在对象外的方法是一致的，因而对于调用方而言，调用代理对象与真实对象并没有实质的区别。

从 职责分离与分层设计的角度分析，我更希望这些Proxy对象是被定义在业务逻辑层中，而不像在PetShop的设计那样，被划分到表示层UI中。此外，如 果需要考虑程序的可扩展性与可替换性，我们还可以为真实对象与代理对象建立统一的接口或抽象类。然而，单以PetShop的表示层调用来看，采用静态类与 静态方法的方式，或许更为合理。我们需要谨记，“过度设计”是软件设计的警戒线。

如果需要对UI层采用缓存机制，将应用程序数据存放到缓存中，就可以调用这些代理对象。以ProductsControl用户控件为例，调用方式如下：
productsList.DataSource = ProductDataProxy.GetProductsByCategory(categoryKey);

productsList对象属于自定义的CustomList类型，这是一个派生自System.Web.UI.WebControls.DataList控件的类，它的DataSource属性可以接受IList集合对象。
不过在PetShop 4.0的设计中，对于类似于ProductsControl类型的控件而言，采用的缓存机制是页输出缓存。我们可以从ProductsControl.ascx页面的Source代码中发现端倪：
< %@ OutputCache Duration=”100000″
VaryByParam=”page;categoryId” %>

与ASP.NET
1.x的页输出缓存不同的是，在ASP.NET 2.0中，为ASP.NET用户控件新引入了CachePolicy属性，该属性的类型为ControlCachePolicy类，它以编程方式实现了对 ASP.NET用户控件的输出缓存设置。我们可以通过设置ControlCachePolicy类的Dependency属性，来设置与该用户控件相关的 依赖项，例如在ProductsControl用户控件中，进行如下的设置：
protected void Page_Load(object sender, EventArgs e)
{
    this.CachePolicy.Dependency =
DependencyFacade.GetProductDependency();
}

采 用页输出缓存，并且利用ControlCachePolicy设置输出缓存，能够将业务数据与整个页面放入到缓存中。这种方式比起应用程序缓存而言，在性
能上有很大的提高。同时，它又通过引入的SqlCacheDependency特性有效地避免了“数据过期”的缺点，因而在PetShop
4.0中被广泛采用。相反，之前为Product、Category、Item业务对象建立的代理对象则被“投闲散置”，仅仅作为一种设计方法的展示而 “幸存”与整个系统的源代码中。

 《解剖PetShop》系列之五–业务逻辑层设计

业务逻辑层（Business Logic Layer）无疑是系统架构中体现核心价值的部分。它的关注点主要集中在业务规则的制定、业务流程的实现等与业务需求有关的系统设计，也即是说它是与系统
所应对的领域（Domain）逻辑有关，很多时候，我们也将业务逻辑层称为领域层。例如Martin Fowler在《Patterns of Enterprise
Application Architecture》一书中，将整个架构分为三个主要的层：表示层、领域层和数据源层。作为领域驱动设计的先驱Eric Evans，对业务逻辑层作了更细致地划分，细分为应用层与领域层，通过分层进一步将领域逻辑与领域逻辑的解决方案分离。

五
PetShop之业务逻辑层设计

业 务逻辑层在体系架构中的位置很关键，它处于数据访问层与表示层中间，起到了数据交换中承上启下的作用。由于层是一种弱耦合结构，层与层之间的依赖是向下
的，底层对于上层而言是“无知”的，改变上层的设计对于其调用的底层而言没有任何影响。如果在分层设计时，遵循了面向接口设计的思想，那么这种向下的依赖
也应该是一种弱依赖关系。因而在不改变接口定义的前提下，理想的分层式架构，应该是一个支持可抽取、可替换的“抽屉”式架构。正因为如此，业务逻辑层的设 计对于一个支持可扩展的架构尤为关键，因为它扮演了两个不同的角色。对于数据访问层而言，它是调用者；对于表示层而言，它却是被调用者。依赖与被依赖的关
系都纠结在业务逻辑层上，如何实现依赖关系的解耦，则是除了实现业务逻辑之外留给设计师的任务。

5.1  与领域专家合作

设 计业务逻辑层最大的障碍不在于技术，而在于对领域业务的分析与理解。很难想象一个不熟悉该领域业务规则和流程的架构设计师能够设计出合乎客户需求的系统架
构。几乎可以下定结论的是，业务逻辑层的设计过程必须有领域专家的参与。在我曾经参与开发的项目中，所涉及的领域就涵盖了电力、半导体、汽车等诸多行业， 如果缺乏这些领域的专家，软件架构的设计尤其是业务逻辑层的设计就无从谈起。这个结论唯一的例外是，架构设计师同时又是该领域的专家。然而，正所谓“千军 易得，一将难求”，我们很难寻觅到这样卓越出众的人才。

领域专家在团队中扮演的角色通常称为Business Consultor（业务咨询师），负责提供与领域业务有关的咨询，与架构师一起参与架构与数据库的设计，撰写需求文档和设计用例（或者用户故事User Story）。如果在测试阶段，还应该包括撰写测试用例。理想的状态是，领域专家应该参与到整个项目的开发过程中，而不仅仅是需求阶段。

领 域专家可以是专门聘请的对该领域具有较深造诣的咨询师，也可以是作为需求提供方的客户。在极限编程（Extreme Programming）中，就将客户作为领域专家引入到整个开发团队中。它强调了现场客户原则。现场客户需要参与到计划游戏、开发迭代、编码测试等项目
开发的各个阶段。由于领域专家与设计师以及开发人员组成了一个团队，贯穿开发过程的始终，就可以避免需求理解错误的情况出现。即使项目的开发与实际需求不 符，也可以在项目早期及时修正，从而避免了项目不必要的延期，加强了对项目过程和成本的控制。正如Steve McConnell在构建活动的前期准备中提及的一个原则：发现错误的时间要尽可能接近引入该错误的时间。需求的缺陷在系统中潜伏的时间越长，代价就越昂
贵。如果在项目开发中能够与领域专家充分的合作，就可以最大效果地规避这样一种恶性的链式反应。

传统的软件开发模型同样重视与领域专家的合
作，但这种合作主要集中在需求分析阶段。例如瀑布模型，就非常强调早期计划与需求调研。然而这种未雨绸缪的早期计划方式，对架构师与需求调研人员的技能要 求非常高，它强调需求文档的精确性，一旦分析出现偏差，或者需求发生变更，当项目开发进入设计阶段后，由于缺乏与领域专家沟通与合作的机制，开发人员估量
不到这些错误与误差，因而难以及时作出修正。一旦这些问题像毒瘤一般在系统中蔓延开来，逐渐暴露在开发人员面前时，已经成了一座难以逾越的高山。我们需要 消耗更多的人力物力，才能够修正这些错误，从而导致开发成本成数量级的增加，甚至于导致项目延期。当然还有一个好的选择，就是放弃整个项目。这样的例子不
胜枚举，事实上，项目开发的“滑铁卢”，究其原因，大部分都是因为业务逻辑分析上出现了问题。

迭代式模型较之瀑布模型有很大地改进，因为它
允许变更、优化系统需求，整个迭代过程实际上就是与领域专家的合作过程，通过向客户演示迭代所产生的系统功能，从而及时获取反馈，并逐一解决迭代演示中出 现的问题，保证系统向着合乎客户需求的方向演化。因而，迭代式模型往往能够解决早期计划不足的问题，它允许在发现缺陷的时候，在需求变更的时候重新设计、
重新编码并重新测试。

无论采用何种开发模型，与领域专家的合作都将成为项目成败与否的关键。这基于一个软件开发的普遍真理，那就是世界上没
有不变的需求。一句经典名言是：“没有不变的需求，世上的软件都改动过3次以上，唯一一个只改动过两次的软件的拥有者已经死了，死在去修改需求的路上。” 一语道尽了软件开发的残酷与艰辛！

那么应该如何加强与领域专家的合作呢？James Carey和Brent Carlson根据他们在参与的IBM SanFrancisco项目中获得的经验，提出了Innocent
Questions模式，其意义即“改进领域专家和技术专家的沟通质量”。在一个项目团队中，如果我们没有一位既能担任首席架构师，同时又是领域专家的人 选，那么加强领域专家与技术专家的合作就显得尤为重要了。毕竟，作为一个领域专家而言，可能并不熟悉软件设计方法学，也不具备面向对象开发和架构设计的能
力，同样，大部分技术专家很有可能对该项目所涉及的业务领域仅停留在一知半解的地步。如果领域专家与技术专家不能有效沟通，则整个项目的前途就岌岌可危 了。

Innocent Questions模式提出的解决方案包括：
（1）选用可以与人和谐相处的人员组建开发团队；
（2）清楚地定义角色和职权；
（3）明确定义需要的交互点；
（4）保持团队紧密；
（5）雇佣优秀的人。

事实上，这已经从技术的角度上升到对团队的管理层次了。就好比篮球运动一样，即使你的球队集合了五名世界上最顶尖最有天赋的球员，如果各自为战，要想取得比赛的胜利依旧是非常困难的。团队精神与权责分明才是取得胜利的保障，软件开发同样如此。

与领域专家合作的基础是保证开发团队中永远保留至少一名领域专家。他可以是系统的客户，第三方公司的咨询师，最理想是自己公司雇佣的专家。如果项目中缺乏这样的一个人，那么我的建议是去雇佣他，如果你不想看到项目遭遇“西伯利亚寒流”的话。

确 定领域专家的角色任务与职责。必须要让团队中的每一个人明确领域专家在整个团队中究竟扮演什么样的角色，他的职责是什么。一个合格的领域专家必须对业务领
域有足够深入的理解，他应该是一个能够俯瞰整个系统需求、总揽全局的人物。在项目开发过程中，将由他负责业务规则和流程的制定，负责与客户的沟通，需求的 调研与讨论，并于设计师一起参与系统架构的设计。编档是领域专家必须参与的工作，无论是需求文档还是设计文档，以及用例的编写，领域专家或者提出意见，或
者作为撰写的作者，至少他也应该是评审委员会的重要成员。

规范业务领域的术语和技术术语。领域专家和技术专家必须在保证不产生二义性的语义
环境下进行沟通与交流。如果出现理解上的分歧，我们必须及时解决，通过讨论确立术语标准。很难想象两个语言不通的人能够相互合作愉快，解决的办法是加入一 位翻译人员。在领域专家与技术专家之间搭建一座语义上的桥梁，使其能够相互理解、相互认同。还有一个办法是在团队内部开展培训活动。尤其对于开发人员而
言，或多或少地了解一些业务领域知识，对于项目的开发有很大的帮助。在我参与过的半导体领域的项目开发，团队就专门邀请了半导体行业的专家就生产过程的业 务逻辑进行了全方位的介绍与培训。正所谓“磨刀不误砍柴工”，虽然我们消费了培训的时间，但对于掌握了业务规则与流程的开发人员，却能够提升项目开发进
度，总体上节约了开发成本。

加强与客户的沟通。客户同时也可以作为团队的领域专家，极限编程的现场客户原则是最好的示例。但现实并不都如此
的完美，在无法要求客户成为开发团队中的固定一员时，聘请或者安排一个专门的领域专家，加强与客户的沟通，就显得尤为重要。项目可以通过领域专家获得客户 的及时反馈。而通过领域专家去了解变更了的需求，会在最大程度上减少需求误差的可能。

5.2  业务逻辑层的模式应用

Martin Fowler在《企业应用架构模式》一书中对领域层（即业务逻辑层）的架构模式作了整体概括，他将业务逻辑设计分为三种主要的模式：Transaction Script、Domain Model和Table Module。

Transaction Script模式将业务逻辑看作是一个个过程，是比较典型的面向过程开发模式。应用Transaction Script模式可以不需要数据访问层，而是利用SQL语句直接访问数据库。为了有效地管理SQL语句，可以将与数据库访问有关的行为放到一个专门的 Gateway类中。应用Transaction Script模式不需要太多面向对象知识，简单直接的特性是该模式全部价值之所在。因而，在许多业务逻辑相对简单的项目中，应用Transaction Script模式较多。

Domain Model模式是典型的面向对象设计思想的体现。它充分考虑了业务逻辑的复杂多变，引入了Strategy模式等设计模式思想，并通过建立领域对象以及抽 象接口，实现模式的可扩展性，并利用面向对象思想与身俱来的特性，如继承、封装与多态，用于处理复杂多变的业务逻辑。唯一制约该模式应用的是对象与关系数
据库的映射。我们可以引入ORM工具，或者利用Data Mapper模式来完成关系向对象的映射。

与Domain
Model模式相似的是Table Module模式，它同样具有面向对象设计的思想，唯一不同的是它获得的对象并非是单纯的领域对象，而是DataSet对象。如果为关系数据表与对象建立 一个简单的映射关系，那么Domain
Model模式就是为数据表中的每一条记录建立一个领域对象，而Table Module模式则是将整个数据表看作是一个完整的对象。虽然利用DataSet对象会丢失面向对象的基本特性，但它在为表示层提供数据源支持方面却有着 得天独厚的优势。尤其是在.Net平台下，ADO.NET与Web控件都为Table Module模式提供了生长的肥沃土壤。

5.3  PetShop的业务逻辑层设计

PetShop 在业务逻辑层设计中引入了Domain Model模式，这与数据访问层对于数据对象的支持是分不开的。由于PetShop并没有对宠物网上商店的业务逻辑进行深入，也省略了许多复杂细节的商务 逻辑，因而在Domain Model模式的应用上并不明显。最典型地应该是对Order领域对象的处理方式，通过引入Strategy模式完成对插入订单行为的封装。关于这一点， 我已在第27章有了详尽的描述，这里就不再赘述。

本应是系统架构设计中最核心的业务逻辑层，由于简化了业务流程的缘故，使得PetShop 在这一层的设计有些乏善可陈。虽然在业务逻辑层中，针对B2C业务定义了相关的领域对象，但这些领域对象仅仅是完成了对数据访问层中数据对象的简单封装而
已，其目的仅在于分离层次，以支持对各种数据库的扩展，同时将SQL语句排除在业务逻辑层外，避免了SQL语句的四处蔓延。

最能体现PetShop业务逻辑的除了对订单的管理之外，还包括购物车（Shopping Cart）与Wish List的管理。在PetShop的BLL模块中，定义了Cart类来负责相关的业务逻辑，定义如下：
[Serializable]
public class Cart
{
    private Dictionary cartItems = new Dictionary();
    public decimal Total
    {
        get
        {
            decimal
total = 0;
            foreach
(CartItemInfo item in cartItems.Values)
               
total += item.Price * item.Quantity;
            return
total;
        }
    }
    public void SetQuantity(string itemId, int qty)
    {
        cartItems[itemId].Quantity = qty;
    }
    public int Count
    {
        get { return cartItems.Count; }
    }
    public void Add(string itemId)
    {
        CartItemInfo cartItem;
        if (!cartItems.TryGetValue(itemId,
out cartItem))
        {
            Item item =
new Item();
            ItemInfo
data = item.GetItem(itemId);
            if (data !=
null)
            {
               
CartItemInfo newItem = new CartItemInfo(itemId, data.ProductName, 1,
(decimal)data.Price, data.Name, data.CategoryId, data.ProductId);
               
cartItems.Add(itemId, newItem);
            }
        }
        else
           
cartItem.Quantity++;
    }
    //其他方法略;
}

Cart类通过一个Dictionary对象来负责对购物车内容的存储，同时定义了Add、Remove、Clear等方法，来实现对购物车内容的管理。

在 前面我提到PetShop业务逻辑层中的领域对象仅仅是完成对数据对象的简单封装，但这种分离层次的方法在架构设计中依然扮演了举足轻重的作用。以 Cart类的Add()方法为例，在方法内部引入了PetShop.BLL.Item领域对象，并调用了Item对象的GetItem()方法。如果没有 在业务逻辑层封装Item对象，而是直接调用数据访问层的Item数据对象，为保证层次间的弱依赖关系，就需要调用工厂对象的工厂方法来创建
PetShop.IDAL.IItem接口类型对象。一旦数据访问层的Item对象被多次调用，就会造成重复代码，既不离于程序的修改与扩展，也导致程序
结构生长为臃肿的态势。

此外，领域对象对数据访问层数据对象的封装，也有利于表示层对业务逻辑层的调用。在三层式架构中，表示层应该是对于数据访问层是“无知”的，这样既减少了层与层间的依赖关系，也能有效避免“循环依赖”的后果。

值 得商榷的是Cart类的Total属性。其值的获取是通过遍历购物车集合，然后累加价格与商品数量的乘积。这里显然简化了业务逻辑，而没有充分考虑需求的
扩展。事实上，这种获取购物车总价格的算法，在大多数情况下仅仅是其中的一种策略而已，我们还应该考虑折扣的情况。例如，当总价格超过100元时，可以给 与顾客一定的折扣，这是与网站的促销计划相关的。除了给与折扣的促销计划外，网站也可以考虑赠送礼品的促销策略，因此我们有必要引入Strategy模 式，定义接口IOnSaleStrategy：
public interface IOnSaleStrategy
{
     decimal CalculateTotalPrice(Dictionary cartItems);
}

如此一来，我们可以为Cart类定义一个有参数的构造函数：
private IOnSaleStrategy m_onSale;
public Cart(IOnSaleStrategy onSale)
{
     m_onSale = onSale;
}

那么Total属性就可以修改为：
public decimal Total
{
     get {return m_onSale.CalculateTotalPrice(cartItems);}
}

如此一来，就可以使得Cart类能够有效地支持网站推出的促销计划，也符合开–闭原则。同样的，这种设计方式也是Domain Model模式的体现。修改后的设计如图5-1所示： 

图5-1 引入Strategy模式

作 为一个B2C的电子商务架构，它所涉及的业务领域已为大部分设计师与开发人员所熟悉，因而在本例中，与领域专家的合作显得并不那么重要。然而，如果我们要
开发一个成功的电子商务网站，与领域专家的合作仍然是必不可少的。以订单的管理而言，如果考虑复杂的商业应用，就需要管理订单的跟踪 （Tracking），与网上银行的合作，账户安全性，库存管理，物流管理，以及客户关系管理（CRM）。整个业务过程却涵盖了诸如电子商务、银行、物
流、客户关系学等诸多领域，如果没有领域专家的参与，业务逻辑层的设计也许会“败走麦城”。

5.4  与数据访问层的通信

业 务逻辑层需要与数据访问层通信，利用数据访问层访问数据库，因此业务逻辑层与数据访问层之间就存在依赖关系。在数据访问层引入接口程序集以及数据工厂的设
计前提下，能够做到两者间关系为弱依赖。我们从业务逻辑层的引用程序集中可以看到，BLL模块并没有引用SQLServerDAL和OracleDAL程 序集。在业务逻辑层中，有关数据访问层中数据对象的调用，均利用多态原理定义了抽象的接口类型对象，然后利用工厂对象的工厂方法创建具体的数据对象。如 PetShop.BLL.PetShop领域对象所示：
namespace PetShop.BLL
{
    public class Product
    {
    //根据工厂对象创建IProduct接口类型实例;
        private static readonly IProduct dal
= 
PetShop.DALFactory.DataAccess.CreateProduct();       
        //调用IProduct对象的接口方法GetProductByCategory();
  public IList
GetProductsByCategory(string category)
  {
   // 如果为空则新建List对象;
   if(string.IsNullOrEmpty(category))
    return new List();

   // 通过数据访问层的数据对象访问数据库;
   return dal.GetProductsByCategory(category);
  }
        //其他方法略;
    }
}

在 领域对象Product类中，利用数据访问层的工厂类DALFactory.DataAccess创建PetShop.IDAL.IProduct类型的 实例，如此就可以解除对具体程序集SQLServerDAL或OracleDAL的依赖。只要PetShop.IDAL的接口方法不变，即使修改了 IDAL接口模块的具体实现，都不会影响业务逻辑层的实现。这种松散的弱耦合关系，才能够最大程度地支持架构的可扩展。

领域对象 Product实际上还完成了对数据对象Product的封装，它们暴露在外的接口方法是一致地，正是通过封装，使得表示层可以完全脱离数据库以及数据访
问层，表示层的调用者仅需要关注业务逻辑层的实现逻辑，以及领域对象暴露的接口和调用方式。事实上，只要设计合理，规范了各个层次的接口方法，三层式架构 的设计完全可以分离开由不同的开发人员同时开发，这就可以有效地利用开发资源，缩短项目开发周期。

5.5  面向接口设计

也 许是业务逻辑比较简单地缘故，在业务逻辑层的设计中，并没有秉承在数据访问层中面向接口设计的思想。除了完成对插入订单策略的抽象外，整个业务逻辑层仅以 BLL模块实现，没有为领域对象定义抽象的接口。因而PetShop的表示层与业务逻辑层就存在强依赖关系，如果业务逻辑层中的需求发生变更，就必然会影
响表示层的实现。唯一可堪欣慰的是，由于我们采用分层式架构将用户界面与业务领域逻辑完全分离，一旦用户界面发生更改，例如将B/S架构修改为C/S架 构，那么业务逻辑层的实现模块是可以完全重用的。

然而，最理想的方式仍然是面向接口设计。根据第28章对ASP.NET缓存的分析，我们可 以将表示层App_Code下的Proxy类与Utility类划分到业务逻辑层中，并修改这些静态类为实例类，并将这些类中与业务领域有关的方法抽象为
接口，然后建立如数据访问层一样的抽象工厂。通过“依赖注入”方式，解除与具体领域对象类的依赖，使得表示层仅依赖于业务逻辑层的接口程序集以及工厂模
块。

那么，这样的设计是否有“过度设计”的嫌疑呢？我们需要依据业务逻辑的需求情况而定。此外，如果我们需要引入缓存机制，为领域对象创建
代理类，那么为领域对象建立接口，就显得尤为必要。我们可以建立一个专门的接口模块IBLL，用以定义领域对象的接口。以Product领域对象为例，我 们可以建立IProduct接口：
public interface IProduct
{
   IListGetProductByCategory(string category);
   IListGetProductByCategory(string[] keywords);
   ProductInfo GetProduct(string productId);
}

在BLL模块中可以引入对IBLL程序集的依赖，则领域对象Product的定义如下：
public class Product:IProduct
{
  public IListGetProductByCategory(string category) { //实现略; }
  public IListGetProductByCategory(string[] keywords) { //实现略; }
  public ProductInfo GetProduct(string productId) { //实现略; }
}

然后我们可以为代理对象建立专门的程序集BLLProxy，它不仅引入对IBLL程序集的依赖，同时还将依赖于BLL程序集。此时代理对象ProductDataProxy的定义如下：
using PetShop.IBLL;
using PetShop.BLL;
namespace PetShop.BLLProxy
{
  public class ProductDataProxy:IProduct
  {
     public IListGetProductByCategory(string category)
     {
        Product product = new Product();
        //其他实现略;
     }
     public IListGetProductByCategory(string[] keywords) {
//实现略; }
     public ProductInfo GetProduct(string productId) { //实现略; }
  }
}

如此的设计正是典型的Proxy模式，其类结构如图5-2所示： 

图5-2 Proxy模式

参 照数据访问层的设计方法，我们可以为领域对象及代理对象建立抽象工厂，并在web.config中配置相关的配置节，然后利用反射技术创建具体的对象实 例。如此一来，表示层就可以仅仅依赖PetShop.IBLL程序集以及工厂模块，如此就可以解除表示层与具体领域对象之间的依赖关系。表示层与修改后的 业务逻辑层的关系如图5-3所示：

图5-3 修改后的业务逻辑层与表示层的关系

图5-4则是PetShop 4.0原有设计的层次关系图：
 

图5-4 PetShop 4.0中表示层与业务逻辑层的关系

通 过比较图5-3与图5-4，虽然后者不管是模块的个数，还是模块之间的关系，都相对更加简单，然而Web Component组件与业务逻辑层之间却是强耦合的，这样的设计不利于应对业务扩展与需求变更。通过引入接口模块IBLL与工厂模块 BLLFactory，解除了与具体模块BLL的依赖关系。这种设计对于业务逻辑相对比较复杂的系统而言，更符合面向对象的设计思想，有利于我们建立可抽 取、可替换的“抽屉”式三层架构。

 

 浅析Microsoft .net
PetShop程序中的购物车和订单处理模块（Profile技术，异步MSMQ消息）

 

对于Microsoft .net PetShop程序中的购物车和订单处理模块，文中主要分析两种技术的应用：

1. Profile技术在PetShop程序中用于三处：

   1) 购物车ShoppingCart    －下面的例子围绕购物车流程进行

    2) 收藏WishList

    3)  用户信息AccountInfo

  注册新用户 NewUser.aspx ：使用的是CreateUserWizard 控件，基于MemberShip机制，在数据库MSPetShop4Services的表aspnet_Users中创建用户

  修改用户注册信息 UserProfile.aspx： 基于Profile技术，在数据库MSPetShop4Profile的表Profiles和Account中创建用户信息

2. 异步消息处理技术运用于订单处理

4.1 Web.config配置

Profile 可以利用数据库存储关于用户的个性化信息，有点象session对象，但session对象是有生存期的，在生存期后，session对象自动失效了。而 profile不同，除非显式移除它。要实现profile功能，必须先在web.config中进行定义。

在web.congfig中，将会定义一些属性/值，分别存贮将要保存的变量和值，比如language属性，定义其值是string类型，如此类推。而＜group＞标签，则是将一些相同或类似功能的变量值放在一起。

程序中使用方法：Profile.language
= ddlLanguage.SelectedItem.Value;

 

<profile
automaticSaveEnabled=”false”
defaultProvider=”ShoppingCartProvider”>

             
<providers>

                  
<add name=”ShoppingCartProvider”
connectionStringName=”SQLProfileConnString”
type=”PetShop.Profile.PetShopProfileProvider”
applicationName=”.NET Pet Shop 4.0″/>

                  
<add name=”WishListProvider” connectionStringName=”SQLProfileConnString”
type=”PetShop.Profile.PetShopProfileProvider”
applicationName=”.NET Pet Shop 4.0″/>

                  
<add name=”AccountInfoProvider”
connectionStringName=”SQLProfileConnString”
type=”PetShop.Profile.PetShopProfileProvider” applicationName=”.NET
Pet Shop 4.0″/>

             
</providers>

             
<properties>

                  
<add name=”ShoppingCart” type=”PetShop.BLL.Cart”
allowAnonymous=”true” provider=”ShoppingCartProvider”/>

                  
<add name=”WishList” type=”PetShop.BLL.Cart”
allowAnonymous=”true” provider=”WishListProvider”/>

                  
<add name=”AccountInfo” type=”PetShop.Model.AddressInfo”
allowAnonymous=”false” provider=”AccountInfoProvider”/>

             
</properties>

        
</profile>

4.2 购物车程序流程－Profile技术

1.       点击“加入购物车”：
http://localhost:2327/Web/ShoppingCart.aspx?addItem=EST-34

2.    
ShoppingCart.aspx文件处理：在init方法之前处理

      protected
void Page_PreInit(object sender, EventArgs e) {

       
if (!IsPostBack) {

           
string itemId = Request.QueryString[“addItem”];

           
if (!string.IsNullOrEmpty(itemId)) {

               
Profile.ShoppingCart.Add(itemId); //注意ShoppingCart的类型是PetShop.BLL.Cart

               
//Save 方法将修改后的配置文件属性值写入到数据源，如ShoppingCart属性已经改变

               
Profile.Save();    

         

               
// Redirect to prevent duplictations in the cart if user hits
“Refresh”

               
//防止刷新造成 多次提交

               
Response.Redirect(“~/ShoppingCart.aspx”, true);  //将客户端重定向到新的 URL。指定新的 URL 并指定当前页的执行是否应终止。

           
}

       
}

3.     PetShop.BLL.Cart类

// Dictionary: key/value 

private Dictionary<string,
CartItemInfo> cartItems = new Dictionary<string, CartItemInfo>();

 

/// <summary>

       
/// Add an item to the cart.

       
/// When ItemId to be added has already existed, this method will update the
quantity instead.

       
/// </summary>

       
/// <param name=”itemId”>Item Id of item to add</param>

       
public void Add(string itemId) {

CartItemInfo cartItem;

//获取与指定的键相关联的值TryGetValue(TKey key,out TValue value)

           
if (!cartItems.TryGetValue(itemId, out cartItem)) {

               
Item item = new Item();

               
ItemInfo data = item.GetItem(itemId);

               
if (data != null) {

          
         CartItemInfo newItem =
new CartItemInfo(itemId, data.ProductName, 1, (decimal)data.Price, data.Name,
data.CategoryId, data.ProductId);

                   
cartItems.Add(itemId, newItem);

               
}

           
}

           
else

          
     cartItem.Quantity++;

       
}

 

4.     更新Profile

//Save 方法将修改后的配置文件属性值写入到数据源，如ShoppingCart属性已经改变

               
Profile.Save(); 

如何更新:

    根据配置中的ShoppingCartProvider类型
PetShop.Profile.PetShopProfileProvider。

 

ASP.NET 配置文件提供对用户特定属性的持久性存储和检索。配置文件属性值和信息按照由 ProfileProvider 实现确定的方式存储在数据源中。

每个用户配置文件在数据库的
Profiles 表中进行唯一标识。该表包含配置文件信息，如应用程序名称和上次活动日期。

CREATE TABLE Profiles

(

  UniqueID AutoIncrement NOT NULL PRIMARY KEY,

  Username Text (255) NOT NULL,

  ApplicationName Text (255) NOT NULL,

  IsAnonymous YesNo, 

  LastActivityDate DateTime,

  LastUpdatedDate DateTime,

  CONSTRAINT PKProfiles UNIQUE (Username, ApplicationName)

)

 

5.     PetShop.Profile.
PetShopProfileProvider类， 继承自ProfileProvider

// 创建 PetShop.SQLProfileDAL.PetShopProfileProvider类–数据库操作

        
private static readonly IPetShopProfileProvider dal

=
DataAccess.CreatePetShopProfileProvider();

 

/// <summary>

       
/// 设置指定的属性设置组的值

       
/// </summary>

        
public override void SetPropertyValues(SettingsContext context,
SettingsPropertyValueCollection collection) {

             
string username = (string)context[“UserName”];

             
CheckUserName(username);                      
 

             
bool isAuthenticated = (bool)context[“IsAuthenticated”];

 

             
int uniqueID = dal.GetUniqueID(username, isAuthenticated, false,
ApplicationName);

             
if(uniqueID == 0)

                  
uniqueID = dal.CreateProfileForUser(username, isAuthenticated,
ApplicationName);

 

             
foreach(SettingsPropertyValue pv in collection) {

                  
if(pv.PropertyValue != null) {

                      
switch(pv.Property.Name) {

                           
case PROFILE_SHOPPINGCART:   //ShoppingCart

                                
SetCartItems(uniqueID, (Cart)pv.PropertyValue, true);

                                
break;

                           
case PROFILE_WISHLIST:

                                
SetCartItems(uniqueID, (Cart)pv.PropertyValue, false);

                                
break;

                           
case PROFILE_ACCOUNT:

                                
if(isAuthenticated)

                                    
SetAccountInfo(uniqueID, (AddressInfo)pv.PropertyValue);

                                
break;

                           
default:

                                
throw new ApplicationException(ERR_INVALID_PARAMETER + ” name.”);

                      
}

                  
}

             
}

 

             
UpdateActivityDates(username, false);

        
}

 

// Update cart

        
private static void SetCartItems(int uniqueID, Cart cart, bool isShoppingCart)
{

             
dal.SetCartItems(uniqueID, cart.CartItems, isShoppingCart);

        
}

 

6.      
PetShop.SQLProfileDAL. PetShopProfileProvider类

使用事务：包含两个sql动作，先删除，再插入

/// <summary>

       
/// Update shopping cart for current user

       
/// </summary>

       
/// <param name=”uniqueID”>User id</param>

       
/// <param name=”cartItems”>Collection of shopping cart
items</param>

       
/// <param name=”isShoppingCart”>Shopping cart
flag</param>

        
public void SetCartItems(int uniqueID, ICollection<CartItemInfo>
cartItems, bool isShoppingCart) {

                  
string sqlDelete = “DELETE FROM Cart WHERE UniqueID = @UniqueID AND
IsShoppingCart = @IsShoppingCart;”;

 

             
SqlParameter[] parms1 =
{                
  

                  
new SqlParameter(“@UniqueID”, SqlDbType.Int),

                  
new SqlParameter(“@IsShoppingCart”, SqlDbType.Bit)};

             
parms1[0].Value = uniqueID;

             
parms1[1].Value = isShoppingCart;

 

           
if (cartItems.Count > 0) {

 

               
// update cart using SqlTransaction

               
string sqlInsert = “INSERT INTO Cart (UniqueID, ItemId, Name, Type, Price,
CategoryId, ProductId, IsShoppingCart, Quantity) VALUES (@UniqueID, @ItemId,
@Name, @Type, @Price, @CategoryId, @ProductId, @IsShoppingCart,
@Quantity);”;

 

               
SqlParameter[] parms2 =
{              
  

                  
new SqlParameter(“@UniqueID”, SqlDbType.Int), 

                  
new SqlParameter(“@IsShoppingCart”, SqlDbType.Bit),

                  
new SqlParameter(“@ItemId”, SqlDbType.VarChar, 10),

                  
new SqlParameter(“@Name”, SqlDbType.VarChar, 80),

                  
new SqlParameter(“@Type”, SqlDbType.VarChar, 80),

                  
new SqlParameter(“@Price”, SqlDbType.Decimal, 8),

                  
new SqlParameter(“@CategoryId”, SqlDbType.VarChar, 10),

                  
new SqlParameter(“@ProductId”, SqlDbType.VarChar, 10),

                  
new SqlParameter(“@Quantity”, SqlDbType.Int)};

               
parms2[0].Value = uniqueID;

          
     parms2[1].Value = isShoppingCart;

 

               
SqlConnection conn = new SqlConnection(SqlHelper.ConnectionStringProfile);

               
conn.Open();

               
SqlTransaction trans = conn.BeginTransaction(IsolationLevel.ReadCommitted);

 

  
             try
{

                   
SqlHelper.ExecuteNonQuery(trans, CommandType.Text, sqlDelete, parms1);

 

                   
foreach (CartItemInfo cartItem in cartItems) {

                       
parms2[2].Value = cartItem.ItemId;

                  
     parms2[3].Value = cartItem.Name;

                       
parms2[4].Value = cartItem.Type;

                       
parms2[5].Value = cartItem.Price;

                       
parms2[6].Value = cartItem.CategoryId;

                       
parms2[7].Value = cartItem.ProductId;

                       
parms2[8].Value = cartItem.Quantity;

                       
SqlHelper.ExecuteNonQuery(trans, CommandType.Text, sqlInsert, parms2);

                   
}

                   
trans.Commit();

               
}

 
              catch
(Exception e) {

                   
trans.Rollback();

                   
throw new ApplicationException(e.Message);

               
}

               
finally {

                   
conn.Close();

               
}

           
}

        
   else

               
// delete cart

               
SqlHelper.ExecuteNonQuery(SqlHelper.ConnectionStringProfile, CommandType.Text,
sqlDelete, parms1);

        
}

4.3 订单处理技术

 

订单处理技术：――分布式事务

1）  同步：直接在事务中 将订单 插入到数据库中，同时更新库存

2）  异步：订单－》消息队列(使用MSMQ)－》后台处理 

4.3.1 使用Wizard组件

4.3.2 分布式事务处理技术

开 启MSDTC 服务支持分布式事务. To
start the MSDTC service, open Administrative Tools | Services and start the
Distributed Transaction Coordinator service

4.3.3 MSMQ 消息队列简介

1）引用队列

 

      引用队列有三种方法，通过路径、格式名和标签引用队列，这里我只介绍最简单和最常用的方法：通过路径引用队列。队列路径的形式为 machinename\queuename。指向队列的路径总是唯一的。下表列出用于每种类型的队列的路径信息：

如果是发送到本机上，还可以使用”.”代表本机名称。

 

2）消息的创建

不过要使用MSMQ开发你的消息处理程序，必须在开发系统和使用程序的主机上安装消息队列。消息队列的安装属于Windows组件的安装，和一般的组件安装方法类似。

往系统中添加队列十分的简单，打开[控制面板]中的[计算机管理]，展开[服务和应用程序]，找到并展开[消息队列]（如果找不到，说明你还没有安装消息队列，安装windows组件），右击希望添加的消息队列的类别，选择新建队列即可。

 

消息接收服务位于System.Messaging中，在初始化时引用消息队列的代码很简单，如下所示：

MessageQueue Mq=new
MessageQueue(“.\\private$\\jiang”)；

 

通过Path属性引用消息队列的代码也十分简单：

MessageQueue Mq=new MessageQueue()；

Mq.Path=”.\\private$\\jiang”;

 

使用Create 方法可以在计算机上创建队列：

System.Messaging.MessageQueue.Create(@”.\private$\jiang”);

 

3) 发送和接收消息

过程：消息的创建－》发送－》接收－》阅读－》关闭

简单消息的发送示例如下：

        
Mq.Send(1000); //发送整型数据

        
Mq.Send(“This is a test message!”); //发送字符串

 

接收消息由两种方式：通过Receive方法接收消息同时永久性地从队列中删除消息；通过Peek方法从队列中取出消息而不从队列中移除该消息。如果知道消息的标识符（ID），还可以通过ReceiveById方法和PeekById方法完成相应的操作。

     接收消息的代码很简单：

        
Mq.Receive(); //或Mq.ReceiveById(ID);

        
Mq.Peek();  // 或Mq.PeekById(ID);

 

阅读消息

接 收到的消息只有能够读出来才是有用的消息，因此接收到消息以后还必须能读出消息，而读出消息算是最复杂的一部操作了。消息的序列化可以通过Visual Studio 和 .NET Framework 附带的三个预定义的格式化程序来完成：XMLMessageFormatter 对象（ MessageQueue 组件的默认格式化程序设置）、BinaryMessageFormatter 对象、ActiveXMessageFormatter 对象。由于后两者格式化后的消息通常不能为人阅读，所以我们经常用到的是XMLMessageFormatter对象。

使用XMLMessageFormatter对象格式化消息的代码如下所示：

      
string[] types = { “System.String” };

      
((XmlMessageFormatter)mq.Formatter).TargetTypeNames = types;

       
Message m=mq.Receive(new TimeSpan(0,0,3));

       将接收到的消息传送给消息变量以后，通过消息变量m的Body属性就可以读出消息了：

MessageBox.Show((string)m.Body);

 

关闭消息队列

     消息队列的关闭很简单，和其他对象一样，通过Close函数就可以实现了：

Mq.Close();

 

4.3.4 PetShop程序中订单处理－使用同步消息

默认程序使用同步消息 处理，直接操作数据库插入订单，更新库存类

4.3.5 PetShop程序中订单处理－使用异步消息

1)    Web程序中调用PetShop.BLL.Order类方法：  Insert(OrderInfo order);

 

2)    PetShop.BLL.Order类

//IOrderStrategy接口中只有一个插入订单方法：void
Insert(PetShop.Model.OrderInfo order);

       
//得到PetShop.BLL.
OrderAsynchronous类

       
private static readonly PetShop.IBLLStrategy.IOrderStrategy orderInsertStrategy
= LoadInsertStrategy();

 

    
   //IOrder接口中有两种方法：Send()与Receive() 
－消息队列

       
private static readonly PetShop.IMessaging.IOrder orderQueue

=
PetShop.MessagingFactory.QueueAccess.CreateOrder();

 

public void Insert(OrderInfo order) {

           
// Call credit card procesor，采用随机化方法设置订单认证数字

           
ProcessCreditCard(order);

           
// Insert the order (a)synchrounously based on configuration

           
orderInsertStrategy.Insert(order);    //调用PetShop.BLL.OrderAsynchronous类

       
}

 

3)    PetShop.BLL.
OrderAsynchronous类

 

// CreateOrder()方法得到PetShop.MSMQMessaging .Order类的实例

private static readonly
PetShop.IMessaging.IOrder asynchOrder

 =
PetShop.MessagingFactory.QueueAccess.CreateOrder();

 

public void Insert(PetShop.Model.OrderInfo
order) {

           
asynchOrder.Send(order);    //调用PetShop.MSMQMessaging.Order类

       
}

 

4)    PetShop.MSMQMessaging项目 －关键（发送/接收消息）

 

PetShopQueue基类：创建消息队列，发送和接收消息

Order类：继承自PetShopQueue类

public new OrderInfo Receive()
{            //从队列中接收消息

           
base.transactionType = MessageQueueTransactionType.Automatic;

           
return (OrderInfo)((Message)base.Receive()).Body;

       
}

public void Send(OrderInfo orderMessage)
{  //发送消息到队列

           
base.transactionType = MessageQueueTransactionType.Single;

           
base.Send(orderMessage);

        }

 

5)    PetShop.OrderProcessor项目－后台处理订单，将它们插入到数据库中

Program类：多线程后台订单处理程序，可写成一个控制台程序，作为windows服务开启

处理队列中的批量异步订单，在事务范围内把它们提交到数据库