Azure Storage 是微軟 Azure 雲提供的雲端存儲解決方案，目前支援的存儲類型有 Blob、Queue、File 和 Table。筆者在《Azure File Storage 基本用法》中介紹了 File Storage 的基本用法，本文将介紹 Queue Storage 的主要使用方法。
Azure Storage 是微軟 Azure 雲提供的雲端存儲解決方案，目前支援的存儲類型有 Blob、Queue、File 和 Table。
筆者在《Azure File Storage 基本用法》中介紹了 File Storage 的基本用法，本文将介紹 Queue Storage 的主要使用方法。
Queue Storage 是什麼？
Azure Queue Storage 是一個存儲大量消息的存儲服務，這些消息可以在任何地方通過 HTTP/HTTPS 通路。每條消息最大 64K，消息的資料量幾乎不受限制 (除非超出了您的 Storage Account 的總容量) 。
下面是 Queue Storage 典型的應用場景：
- 建立未處理任務的隊列，以便異步的處理這些任務。
- 把消息從 web role 傳遞給 worker role 進行處理。
Azure Queue Storage 的結構
下圖描述了 Queue Storage 的基本組織結構：
- Azure Storage Account:
Storage Account 是用來管理 Azure Storage 的一個命名空間，主要用來控制存儲資料的通路權限和計費。對 Blob、Queue、File 和 Table 這些 Azure 提供的存儲服務的通路控制，都是通過 Storage Account 來進行的，是以要想使用 Queue Storage，需要先建立你的 Storage Account。
- Queue:
每個 Queue 都是一組消息的集合，每一條消息都必須屬于一個 Queue，Queue 名稱中的字元必須是小寫。
- Message：
每條 Message 的最大長度為 64KB，Message 在 Queue 中停留的最長時間為 7 天。
- URL format:
Queue 的 URL 位址格式為：
http://<storage account>.queue.core.windows.net/<queuename>
下面是個更真實的例子：
http://nickstorage.queue.core.windows.net/app1tasks
如果您還不熟悉 Azure Storage Account 的使用，以及如何通過 WindowsAzure.Storage 庫通路 Azure Storage，請參考前文《Azure Table storage 基本用法》中的介紹。
為了友善檢視 C# 代碼執行的結果，本文使用了 MS 釋出的一個 Azure Storage 用戶端工具：Microsoft Azure Storage Explorer，文中簡稱為 Storage Explorer。下面是 Queue Storage 的一個截圖：
接下來我們通過 C# 代碼來介紹如何操作 Queue Storage。
建立 Queue
我們先來建立一個名為“app2tasks”的 Queue:
//CloudStorageAccount 類表示一個 Azure Storage Account，我們需要先建立它的執行個體，才能通路屬于它的資源。
//注意連接配接字元串中的xxx和yyy，分别對應Access keys中的Storage account name 和 key。
CloudStorageAccount storageAccount = CloudStorageAccount.Parse("DefaultEndpointsProtocol=https;AccountName=xxx;AccountKey=yyy");
//CloudQueueClient 類是 Windows Azure Queue Service 用戶端的邏輯表示，我們需要使用它來配置和執行對 Queue Storage 的操作。
CloudQueueClient queueClient = storageAccount.CreateCloudQueueClient();
//CloudQueue 表示一個 Queue 對象, 絕大多數的操作都是通過這個對象完成的。
CloudQueue queue = queueClient.GetQueueReference("app2tasks");
//如果不存在就建立名稱為 "app2tasks" 的 Queue。
queue.CreateIfNotExists(); 執行上面的代碼，然後在 Storage Explorer 中檢視結果：
把消息插入 Queue
現實的應用場景中肯定有一個或多個程式産生 Message 并插入到 Queue 中，接下來我們看看用 C# 如何實作：
string current = DateTime.Now.ToString();
//把消息插入到隊列中。
CloudQueueMessage message = new CloudQueueMessage("Hello, World. -- " + current);
queue.AddMessage(message); 調用幾次上面的代碼看看結果如何：
我通過三次調用向 Queue 中加入了三條消息，請注意插入它們的時間，分别是 11:33:45，11:33:57，和 11.34:16。在接下來的描述中我分别稱它們為第一條消息、第二條消息和第三條消息。
檢視 Queue 中的消息
既然是隊列，肯定有隊頭和隊尾，消息從隊頭出隊，從隊尾入隊。那麼能不能檢視一下隊頭(也就是下一條要處理的消息，此處隻是檢視并不是要處理)的消息呢？當然可以：
//總是取到隊頭的消息，沒有消息出隊。
//消息在隊列中的位置、可見狀态也沒有發生變化。
CloudQueueMessage peekedMessage = queue.PeekMessage(); PeekMessage 方法總是取到處于隊頭位置的那條消息，并且不改變隊列的狀态！
檢視 Queue 的長度
經常的檢視 Queue 的長度是個不錯的注意，因為你需要避免一些由于 Queue 過長帶來的問題：
//擷取 Queue 的屬性。
queue.FetchAttributes();
int cachedMessageCount = queue.ApproximateMessageCount; 更新 Queue 中的消息
如果一條消息已經被添加到 Queue 中了，但是又需要更新其内容該怎麼辦？我們可以找到這條消息然後更新它的内容：
CloudQueueMessage message = queue.GetMessage();
// 執行 getmessage(), 隊頭的消息會變得不可見。
message.SetMessageContent("Updated contents.");
queue.UpdateMessage(message,
TimeSpan.FromSeconds(60.0),
MessageUpdateFields.Content | MessageUpdateFields.Visibility);
// 更新完消息内容的60s 之後，該消息會重新可見，但是是在隊尾。 執行上面的代碼後，我們發現在 Storage Explorer 中”第一條消息”不見了。過了 60 秒之後它又重新出現在 Storage Explorer 中，但是它的内容已經變化，位置也成了隊尾：
此時我們也隻能通過 ID 認出它是之前的”第一條消息”，之前 “第二條消息”，”第三條消息”的位置也發生了相應的變化。
處理 Queue 中的消息
如何處理 Queue 中的消息呢？我們的程式大體應該遵循下面的邏輯：
- 使用 GetMessage 方法取出隊頭的消息，此時該消息會在 Queue 中30秒不可見(這個時常使用者是可以設定的，預設是 30 秒)；
- 處理消息；
- 正常處理完成後，調用 Delete 方法删除消息；
- 如果沒有正常處理消息 (沒有調用 Delete 方法)，此消息會在30秒後重新出現在隊尾。
類似于下面的代碼邏輯：
// 執行 getmessage(), 隊頭的消息會變得不可見。
CloudQueueMessage message = queue.GetMessage();
try
{
//處理消息
// 如果在30s内你沒有删除這條消息，它會重新出現在隊尾。
// 是以正确處理一條消息的過程是，處理完成後，删除這條消息
queue.DeleteMessage(message);
}
catch //(消息處理異常)
{ } 删除 Queue 中的消息
除了正常處理完消息後把消息從隊列中删除，我們也可以找到一條消息，直接删除它，本質上和處理完再删除是一樣的。