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

function StorePage(){d=document;t=d.selection?(d.selection.type!='None'?d.selection.createRange().text:''):(d.getSelection?d.getSelection():'');void(keyit=window.open('http://www.365key.com/storeit.aspx?t='+escape(d.title)+'&u='+escape(d.location.href)+'&c='+escape(t),'keyit','scrollbars=no,width=475,height=575,left=75,top=20,status=no,resizable=yes'));keyit.focus();}


浅析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配置

[align=left]Profile 可以利用数据库存储关于用户的个性化信息，有点象session对象，但session对象是有生存期的，在生存期后，session对象自动失效了。而 profile不同，除非显式移除它。要实现profile功能，必须先在web.config中进行定义。[/align]
[align=left]在web.congfig中，将会定义一些属性/值，分别存贮将要保存的变量和值，比如language属性，定义其值是string类型，如此类推。而＜group＞标签，则是将一些相同或类似功能的变量值放在一起。[/align]
[align=left]程序中使用方法：Profile.language = ddlLanguage.SelectedItem.Value;[/align]
[align=left] [/align]
[align=left]<profile automaticSaveEnabled="false" defaultProvider="ShoppingCartProvider">[/align]
[align=left] <providers>[/align]
[align=left] <add name="ShoppingCartProvider" connectionStringName="SQLProfileConnString" type="PetShop.Profile.PetShopProfileProvider" applicationName=".NET Pet Shop 4.0"/>[/align]
[align=left] <add name="WishListProvider" connectionStringName="SQLProfileConnString" type="PetShop.Profile.PetShopProfileProvider" applicationName=".NET Pet Shop 4.0"/>[/align]
[align=left] <add name="AccountInfoProvider" connectionStringName="SQLProfileConnString" type="PetShop.Profile.PetShopProfileProvider" applicationName=".NET Pet Shop 4.0"/>[/align]
[align=left] </providers>[/align]
[align=left] <properties>[/align]
[align=left] <add name="ShoppingCart" type="PetShop.BLL.Cart" allowAnonymous="true" provider="ShoppingCartProvider"/>[/align]
[align=left] <add name="WishList" type="PetShop.BLL.Cart" allowAnonymous="true" provider="WishListProvider"/>[/align]
[align=left] <add name="AccountInfo" type="PetShop.Model.AddressInfo" allowAnonymous="false" provider="AccountInfoProvider"/>[/align]
[align=left] </properties>[/align]
</profile>

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

1. 点击“加入购物车”： http://localhost:2327/Web/ShoppingCart.aspx?addItem=EST-34 2. ShoppingCart.aspx文件处理：在init方法之前处理
[align=left] protected void Page_PreInit(object sender, EventArgs e) {[/align]
[align=left] if (!IsPostBack) {[/align]
[align=left] string itemId = Request.QueryString["addItem"];[/align]
[align=left] if (!string.IsNullOrEmpty(itemId)) {[/align]
[align=left] Profile.ShoppingCart.Add(itemId); //注意ShoppingCart的类型是PetShop.BLL.Cart[/align]
[align=left] //Save 方法将修改后的配置文件属性值写入到数据源，如ShoppingCart属性已经改变[/align]
[align=left] Profile.Save(); [/align]
[align=left] [/align]
[align=left] // Redirect to prevent duplictations in the cart if user hits "Refresh"[/align]
[align=left] //防止刷新造成 多次提交[/align]
[align=left] Response.Redirect("~/ShoppingCart.aspx", true); //将客户端重定向到新的 URL。指定新的 URL 并指定当前页的执行是否应终止。[/align]
[align=left] }[/align]
}
3. PetShop.BLL.Cart类
[align=left]// Dictionary: key/value [/align]
[align=left]private Dictionary<string, CartItemInfo> cartItems = new Dictionary<string, CartItemInfo>();[/align]
[align=left] [/align]
[align=left]/// <summary>[/align]
[align=left] /// Add an item to the cart.[/align]
[align=left] /// When ItemId to be added has already existed, this method will update the quantity instead.[/align]
[align=left] /// </summary>[/align]
[align=left] /// <param name="itemId">Item Id of item to add</param>[/align]
[align=left] public void Add(string itemId) {[/align]
[align=left]CartItemInfo cartItem;[/align]
[align=left]//获取与指定的键相关联的值TryGetValue(TKey key,out TValue value)[/align]
[align=left] if (!cartItems.TryGetValue(itemId, out cartItem)) {[/align]
[align=left] Item item = new Item();[/align]
[align=left] ItemInfo data = item.GetItem(itemId);[/align]
[align=left] if (data != null) {[/align]
[align=left] CartItemInfo newItem = new CartItemInfo(itemId, data.ProductName, 1, (decimal)data.Price, data.Name, data.CategoryId, data.ProductId);[/align]
[align=left] cartItems.Add(itemId, newItem);[/align]
[align=left] }[/align]
[align=left] }[/align]
[align=left] else[/align]
[align=left] cartItem.Quantity++;[/align]
}

4. 更新Profile
[align=left]//Save 方法将修改后的配置文件属性值写入到数据源，如ShoppingCart属性已经改变[/align]
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
[align=left]// 创建 PetShop.SQLProfileDAL.PetShopProfileProvider类-数据库操作[/align]
private static readonly IPetShopProfileProvider dal
= DataAccess.CreatePetShopProfileProvider();

[align=left]/// <summary>[/align]
[align=left] /// 设置指定的属性设置组的值[/align]
[align=left] /// </summary>[/align]
[align=left] public override void SetPropertyValues(SettingsContext context, SettingsPropertyValueCollection collection) {[/align]
[align=left] string username = (string)context["UserName"];[/align]
[align=left] CheckUserName(username); [/align]
[align=left] bool isAuthenticated = (bool)context["IsAuthenticated"];[/align]
[align=left] [/align]
[align=left] int uniqueID = dal.GetUniqueID(username, isAuthenticated, false, ApplicationName);[/align]
[align=left] if(uniqueID == 0)[/align]
[align=left] uniqueID = dal.CreateProfileForUser(username, isAuthenticated, ApplicationName);[/align]
[align=left] [/align]
[align=left] foreach(SettingsPropertyValue pv in collection) {[/align]
[align=left] if(pv.PropertyValue != null) {[/align]
[align=left] switch(pv.Property.Name) {[/align]
[align=left] case PROFILE_SHOPPINGCART: //ShoppingCart[/align]
[align=left] SetCartItems(uniqueID, (Cart)pv.PropertyValue, true);[/align]
[align=left] break;[/align]
[align=left] case PROFILE_WISHLIST:[/align]
[align=left] SetCartItems(uniqueID, (Cart)pv.PropertyValue, false);[/align]
[align=left] break;[/align]
[align=left] case PROFILE_ACCOUNT:[/align]
[align=left] if(isAuthenticated)[/align]
[align=left] SetAccountInfo(uniqueID, (AddressInfo)pv.PropertyValue);[/align]
[align=left] break;[/align]
[align=left] default:[/align]
[align=left] throw new ApplicationException(ERR_INVALID_PARAMETER + " name.");[/align]
[align=left] }[/align]
[align=left] }[/align]
[align=left] }[/align]
[align=left] [/align]
[align=left] UpdateActivityDates(username, false);[/align]
}

[align=left]// Update cart[/align]
[align=left] private static void SetCartItems(int uniqueID, Cart cart, bool isShoppingCart) {[/align]
[align=left] dal.SetCartItems(uniqueID, cart.CartItems, isShoppingCart);[/align]
}

6. PetShop.SQLProfileDAL. PetShopProfileProvider类
使用事务：包含两个sql动作，先删除，再插入
[align=left]/// <summary>[/align]
[align=left] /// Update shopping cart for current user[/align]
[align=left] /// </summary>[/align]
[align=left] /// <param name="uniqueID">User id</param>[/align]
[align=left] /// <param name="cartItems">Collection of shopping cart items</param>[/align]
[align=left] /// <param name="isShoppingCart">Shopping cart flag</param>[/align]
[align=left] public void SetCartItems(int uniqueID, ICollection<CartItemInfo> cartItems, bool isShoppingCart) {[/align]
[align=left] string sqlDelete = "DELETE FROM Cart WHERE UniqueID = @UniqueID AND IsShoppingCart = @IsShoppingCart;";[/align]
[align=left] [/align]
[align=left] SqlParameter[] parms1 = { [/align]
[align=left] new SqlParameter("@UniqueID", SqlDbType.Int),[/align]
[align=left] new SqlParameter("@IsShoppingCart", SqlDbType.Bit)};[/align]
[align=left] parms1[0].Value = uniqueID;[/align]
[align=left] parms1[1].Value = isShoppingCart;[/align]
[align=left] [/align]
[align=left] if (cartItems.Count > 0) {[/align]
[align=left] [/align]
[align=left] // update cart using SqlTransaction[/align]
[align=left] string sqlInsert = "INSERT INTO Cart (UniqueID, ItemId, Name, Type, Price, CategoryId, ProductId, IsShoppingCart, Quantity) VALUES (@UniqueID, @ItemId, @Name, @Type, @Price, @CategoryId, @ProductId, @IsShoppingCart, @Quantity);";[/align]
[align=left] [/align]
[align=left] SqlParameter[] parms2 = { [/align]
[align=left] new SqlParameter("@UniqueID", SqlDbType.Int), [/align]
[align=left] new SqlParameter("@IsShoppingCart", SqlDbType.Bit),[/align]
[align=left] new SqlParameter("@ItemId", SqlDbType.VarChar, 10),[/align]
[align=left] new SqlParameter("@Name", SqlDbType.VarChar, 80),[/align]
[align=left] new SqlParameter("@Type", SqlDbType.VarChar, 80),[/align]
[align=left] new SqlParameter("@Price", SqlDbType.Decimal, 8),[/align]
[align=left] new SqlParameter("@CategoryId", SqlDbType.VarChar, 10),[/align]
[align=left] new SqlParameter("@ProductId", SqlDbType.VarChar, 10),[/align]
[align=left] new SqlParameter("@Quantity", SqlDbType.Int)};[/align]
[align=left] parms2[0].Value = uniqueID;[/align]
[align=left] parms2[1].Value = isShoppingCart;[/align]
[align=left] [/align]
[align=left] SqlConnection conn = new SqlConnection(SqlHelper.ConnectionStringProfile);[/align]
[align=left] conn.Open();[/align]
[align=left] SqlTransaction trans = conn.BeginTransaction(IsolationLevel.ReadCommitted);[/align]
[align=left] [/align]
[align=left] try {[/align]
[align=left] SqlHelper.ExecuteNonQuery(trans, CommandType.Text, sqlDelete, parms1);[/align]
[align=left] [/align]
[align=left] foreach (CartItemInfo cartItem in cartItems) {[/align]
[align=left] parms2[2].Value = cartItem.ItemId;[/align]
[align=left] parms2[3].Value = cartItem.Name;[/align]
[align=left] parms2[4].Value = cartItem.Type;[/align]
[align=left] parms2[5].Value = cartItem.Price;[/align]
[align=left] parms2[6].Value = cartItem.CategoryId;[/align]
[align=left] parms2[7].Value = cartItem.ProductId;[/align]
[align=left] parms2[8].Value = cartItem.Quantity;[/align]
[align=left] SqlHelper.ExecuteNonQuery(trans, CommandType.Text, sqlInsert, parms2);[/align]
[align=left] }[/align]
[align=left] trans.Commit();[/align]
[align=left] }[/align]
[align=left] catch (Exception e) {[/align]
[align=left] trans.Rollback();[/align]
[align=left] throw new ApplicationException(e.Message);[/align]
[align=left] }[/align]
[align=left] finally {[/align]
[align=left] conn.Close();[/align]
[align=left] }[/align]
[align=left] }[/align]
[align=left] else [/align]
[align=left] // delete cart[/align]
[align=left] SqlHelper.ExecuteNonQuery(SqlHelper.ConnectionStringProfile, CommandType.Text, sqlDelete, parms1);[/align]
}

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类
[align=left]//IOrderStrategy接口中只有一个插入订单方法：void Insert(PetShop.Model.OrderInfo order);[/align]
[align=left] //得到PetShop.BLL. OrderAsynchronous类[/align]
[align=left] private static readonly PetShop.IBLLStrategy.IOrderStrategy orderInsertStrategy = LoadInsertStrategy();[/align]
[align=left] [/align]
[align=left] //IOrder接口中有两种方法：Send()与Receive() －消息队列[/align]
private static readonly PetShop.IMessaging.IOrder orderQueue
= PetShop.MessagingFactory.QueueAccess.CreateOrder();

[align=left]public void Insert(OrderInfo order) {[/align]
[align=left] // Call credit card procesor，采用随机化方法设置订单认证数字[/align]
[align=left] ProcessCreditCard(order);[/align]
[align=left] // Insert the order (a)synchrounously based on configuration[/align]
[align=left] orderInsertStrategy.Insert(order); //调用PetShop.BLL.OrderAsynchronous类[/align]
}

3) PetShop.BLL. OrderAsynchronous类

// CreateOrder()方法得到PetShop.MSMQMessaging .Order类的实例
private static readonly PetShop.IMessaging.IOrder asynchOrder
= PetShop.MessagingFactory.QueueAccess.CreateOrder();
[align=left] [/align]
[align=left]public void Insert(PetShop.Model.OrderInfo order) {[/align]
[align=left] asynchOrder.Send(order); //调用PetShop.MSMQMessaging.Order类[/align]
}

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

PetShopQueue基类：创建消息队列，发送和接收消息
Order类：继承自PetShopQueue类
[align=left]public new OrderInfo Receive() { //从队列中接收消息[/align]
[align=left] base.transactionType = MessageQueueTransactionType.Automatic;[/align]
[align=left] return (OrderInfo)((Message)base.Receive()).Body;[/align]
}
[align=left]public void Send(OrderInfo orderMessage) { //发送消息到队列[/align]
[align=left] base.transactionType = MessageQueueTransactionType.Single;[/align]
[align=left] base.Send(orderMessage);[/align]
}

5) PetShop.OrderProcessor项目－后台处理订单，将它们插入到数据库中
Program类：多线程后台订单处理程序，可写成一个控制台程序，作为windows服务开启
处理队列中的批量异步订单，在事务范围内把它们提交到数据库