基于云存儲實(shí)現(xiàn)用Windows Azure Storage增強(qiáng)應(yīng)用程序的引擎
圖 7 以 toast 形式消息顯示的通知
$(document).ready(function() {
setInterval(function() {
$.ajax({
contentType: application/json; charset=utf-8,
dataType: json,
url: /SystemMessage/GetMessages,
success: function(data) {
for (msg in data) {
$.gritter.add({
title: data[msg].title,
text: data[msg].text,
sticky: false
});
}
}
})
}, 15000)
});
提交和處理購物車
在我們的示例應(yīng)用程序中,我們希望使用隊(duì)列存儲執(zhí)行的另一個關(guān)鍵方案是提交購物車。Hollywood Hackers 有一個第三方履行系統(tǒng)(Hollywood Hackers 無法在其空間有限的倉庫中保留所有小工具),所以引擎需要對購物車進(jìn)行一些處理。一旦引擎完成其處理,它會向用戶通知隊(duì)列提交一個消息,告知用戶已經(jīng)對購物車進(jìn)行了處理(或者出現(xiàn)了問題)。如果處理購物車時用戶處于在線狀態(tài),該用戶將收到系統(tǒng)彈出的一個 toast 消息。如果用戶不在線,則會在其下次登錄到該站點(diǎn)時收到該彈出消息,如圖 8 所示。
圖 8 示例用戶通知
查看原圖(大圖)
我們首先需要的是一些包裝類,使我們可以與購物車隊(duì)列交互。這些包裝非常簡單,如果要查看它們的源代碼,可以在 CodePlex 站點(diǎn)上查看。
與標(biāo)準(zhǔn) CRUD(創(chuàng)建、讀取、更新、刪除)存儲庫不同的是,隊(duì)列中的讀取操作不是單純的讀取操作。請記住,只要獲取隊(duì)列中的消息,必須在有限的時間內(nèi)處理該消息,操作失敗或刪除消息都會顯示處理完成。這種模式不能順利地轉(zhuǎn)換到存儲庫模式,所以我們已經(jīng)不再借助包裝類執(zhí)行此操作。
現(xiàn)在,我們已經(jīng)擁有了要與購物車隊(duì)列交互的代碼,我們可以將一些代碼放在購物車控制器中,以便將購物車內(nèi)容提交到隊(duì)列中(請參見圖 9)。
圖 9 向隊(duì)列提交購物車
public ActionResult Submit()
{
ShoppingCartMessage cart = new ShoppingCartMessage();
cart.UserName = User.Identity.Name;
cart.Discounts = 12.50f;
cart.CartID = Guid.NewGuid().ToString();
ListShoppingCartItem> items = new ListShoppingCartItem>();
items.Add(new ShoppingCartItem()
{ Quantity = 12, SKU = 10000101010,
UnitPrice = 15.75f });
items.Add(new ShoppingCartItem()
{ Quantity = 27, SKU = 12390123j213,
UnitPrice = 99.92f });
cart.CartItems = items.ToArray();
cartQueue.AddMessage(cart);
return View();
}
在實(shí)際情況下,您可能會從進(jìn)程外狀態(tài)(例如會話存儲、緩存或窗體發(fā)布)獲得購物車。為了簡化本文代碼,我們僅僅構(gòu)建了購物車的內(nèi)容。
最后,購物車內(nèi)容已處于隊(duì)列中,我們可以修改工作者角色,以便它可以定期檢查隊(duì)列中掛起的購物車。它每次會從隊(duì)列中選擇一個購物車,用整整一分鐘對該購物車進(jìn)行處理,然后向用戶通知隊(duì)列提交一個消息,告知用戶已經(jīng)對該購物車進(jìn)行了處理(請參見圖 10)。
圖 10 檢查隊(duì)列中掛起的購物車
private void ProcessShoppingCarts()
{
CloudQueueMessage cqm = cartQueue.GetMessage();
while (cqm != null)
{
ShoppingCartMessage cart =
QueueMessageBase.FromMessageShoppingCartMessage>(cqm);
toastRepository.AddNotification(new UserTextNotification()
{
MessageText = String.Format
(Your shopping cart containing {0} items has been processed.,
cart.CartItems.Length),
MessageDate = DateTime.Now,
TargetUserName = cart.UserName
});
cartQueue.DeleteMessage(cqm);
cqm = cartQueue.GetMessage();
}
}
經(jīng)過對用戶通知表中的隊(duì)列消息的存取操作,位于主頁面中的 jQuery Gritter 代碼然后會在下一個 15 秒的輪詢周期中檢測是否存在新消息,然后向用戶顯示購物車 toast 通知。
總結(jié)和后續(xù)操作
本文的目的是使開發(fā)人員可以拋開其有形的數(shù)據(jù)中心這條“安全毛毯”,認(rèn)識到他們可以使用 Windows Azure 執(zhí)行很多操作,而不僅僅是創(chuàng)建簡單的“Hello World”網(wǎng)站。借助 Windows Azure Queues 和 Windows Azure 表存儲的強(qiáng)大功能,以及利用這些強(qiáng)大功能在應(yīng)用程序和其工作者角色之間進(jìn)行異步消息傳送,您可以真正使用 Windows Azure 增強(qiáng)應(yīng)用程序的引擎了。
為使文章簡明易懂,我們將很多代碼都保留為原樣,沒有進(jìn)行重構(gòu)。作為熟悉新 Windows Azure Muscle 的練習(xí),請嘗試重構(gòu)本文中的一些代碼,以加深對隊(duì)列的熟練使用,甚至創(chuàng)建一個獨(dú)立的程序集,其中包含為任何 ASP.NET MVC 網(wǎng)站進(jìn)行異步消息傳送和通知所需的所有代碼。
主要是親自動手實(shí)踐,創(chuàng)建一些站點(diǎn)并看看您都可以執(zhí)行哪些操作。本文中的代碼位于 Hollywood Hackers 的 CodePlex 站點(diǎn)中。
評論