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

来自:http://dev.csdn.net/article/85/85106.shtm

对于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;

</providers>

</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服务开启

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