基于云存儲實現(xiàn)用Windows Azure Storage增強應(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)用程序中，我們希望使用隊列存儲執(zhí)行的另一個關(guān)鍵方案是提交購物車。Hollywood Hackers 有一個第三方履行系統(tǒng)（Hollywood Hackers 無法在其空間有限的倉庫中保留所有小工具），所以引擎需要對購物車進行一些處理。一旦引擎完成其處理，它會向用戶通知隊列提交一個消息，告知用戶已經(jīng)對購物車進行了處理（或者出現(xiàn)了問題）。如果處理購物車時用戶處于在線狀態(tài)，該用戶將收到系統(tǒng)彈出的一個 toast 消息。如果用戶不在線，則會在其下次登錄到該站點時收到該彈出消息，如圖 8 所示。

圖 8 示例用戶通知

　　查看原圖（大圖）

　　我們首先需要的是一些包裝類，使我們可以與購物車隊列交互。這些包裝非常簡單，如果要查看它們的源代碼，可以在 CodePlex 站點上查看。

　　與標(biāo)準(zhǔn) CRUD（創(chuàng)建、讀取、更新、刪除）存儲庫不同的是，隊列中的讀取操作不是單純的讀取操作。請記住，只要獲取隊列中的消息，必須在有限的時間內(nèi)處理該消息，操作失敗或刪除消息都會顯示處理完成。這種模式不能順利地轉(zhuǎn)換到存儲庫模式，所以我們已經(jīng)不再借助包裝類執(zhí)行此操作。

　　現(xiàn)在，我們已經(jīng)擁有了要與購物車隊列交互的代碼，我們可以將一些代碼放在購物車控制器中，以便將購物車內(nèi)容提交到隊列中（請參見圖 9）。

　　圖 9 向隊列提交購物車

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();　
　　}

在實際情況下，您可能會從進程外狀態(tài)（例如會話存儲、緩存或窗體發(fā)布）獲得購物車。為了簡化本文代碼，我們僅僅構(gòu)建了購物車的內(nèi)容。

　　最后，購物車內(nèi)容已處于隊列中，我們可以修改工作者角色，以便它可以定期檢查隊列中掛起的購物車。它每次會從隊列中選擇一個購物車，用整整一分鐘對該購物車進行處理，然后向用戶通知隊列提交一個消息，告知用戶已經(jīng)對該購物車進行了處理（請參見圖 10）。

　　圖 10 檢查隊列中掛起的購物車

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)過對用戶通知表中的隊列消息的存取操作，位于主頁面中的 jQuery Gritter 代碼然后會在下一個 15 秒的輪詢周期中檢測是否存在新消息，然后向用戶顯示購物車 toast 通知。

　　總結(jié)和后續(xù)操作

　　本文的目的是使開發(fā)人員可以拋開其有形的數(shù)據(jù)中心這條“安全毛毯”，認識到他們可以使用 Windows Azure 執(zhí)行很多操作，而不僅僅是創(chuàng)建簡單的“Hello World”網(wǎng)站。借助 Windows Azure Queues 和 Windows Azure 表存儲的強大功能，以及利用這些強大功能在應(yīng)用程序和其工作者角色之間進行異步消息傳送，您可以真正使用 Windows Azure 增強應(yīng)用程序的引擎了。

　　為使文章簡明易懂，我們將很多代碼都保留為原樣，沒有進行重構(gòu)。作為熟悉新 Windows Azure Muscle 的練習(xí)，請嘗試重構(gòu)本文中的一些代碼，以加深對隊列的熟練使用，甚至創(chuàng)建一個獨立的程序集，其中包含為任何 ASP.NET MVC 網(wǎng)站進行異步消息傳送和通知所需的所有代碼。

　　主要是親自動手實踐，創(chuàng)建一些站點并看看您都可以執(zhí)行哪些操作。本文中的代碼位于 Hollywood Hackers 的 CodePlex 站點中。