- Storage Account。 和之前介绍的Azure Table和AzureBlob一样。你须要一个StorageAccount，仅仅须要创建1次AzureStorageAccount就好了，它们3个是共享的。

创建好之后。就能够使用下面属性来訪问Azure的Storage了：

private static CloudStorageAccount StorageAccount{get{var creds = new StorageCredentials(AccountName, Key);var account = new CloudStorageAccount(creds, useHttps: true);return account;}}

- 创建Azure Q

public static void CreateIfNotExist(){// Create the queue clientCloudQueueClient queueClient = StorageAccount.CreateCloudQueueClient();CloudQueue queue = queueClient.GetQueueReference(OrdersQueue);// Create the queue if it doesn't already existqueue.CreateIfNotExists();}

须要注意的就是Q的名字。所有小写。

- 入队

   /// <summary>/// add msg to Q /// </summary>/// <param name="msg"></param>public static void AddMsg(string msg){CloudQueueClient queueClient = StorageAccount.CreateCloudQueueClient();// Retrieve a reference to a queue.CloudQueue queue = queueClient.GetQueueReference(OrdersQueue);// Create a message and add it to the queue.CloudQueueMessage message = new CloudQueueMessage(msg);queue.AddMessage(message);}

代码逻辑非常easy，就是向Queue中加入消息。只是要注意，这里仅仅是为了演示没有考虑多线程环境以及并发情形，详细场景中为了不堵塞线程，你通过须要使用Asyn版本号的方法，即：

queue.AddMessageAsync(message);

- 拿取指定数量的消息

   /// <summary>/// peek a number of messages from Q/// </summary>/// <param name="count"></param>/// <returns></returns>public static IList<string> Peek(int count){// Create the queue clientCloudQueueClient queueClient = StorageAccount.CreateCloudQueueClient();// Retrieve a reference to a queueCloudQueue queue = queueClient.GetQueueReference(OrdersQueue);// Peek at the next messageIEnumerable<CloudQueueMessage> peekedMessages = queue.PeekMessages(count);return peekedMessages.Select(m => m.AsString).ToList();}

- 出队

    /// <summary>/// dequeue a msg/// </summary>/// <returns></returns>public static string DequeueMsg(){var queueClient = StorageAccount.CreateCloudQueueClient();// Retrieve a reference to a queuevar queue = queueClient.GetQueueReference(OrdersQueue);var retrievedMessage = queue.GetMessage();//Process the message in less than 30 seconds, and then delete the messagequeue.DeleteMessage(retrievedMessage);return retrievedMessage.AsString;}

完整的測试代码：

    [TestMethod]public void AzureQ_Test(){// - create QAzureQueueManager.CreateIfNotExist();// - Add 5 messages to Qfor (int i = 0; i < 5; i++){AzureQueueManager.AddMsg(string.Format("hello_{0}",i));    }// peek all messages , Assert the order is correctvar msgs = AzureQueueManager.Peek(5);Assert.IsTrue(msgs.Count == 5);Assert.IsTrue(msgs[0] == "hello_0");Assert.IsTrue(msgs[1] == "hello_1");Assert.IsTrue(msgs[2] == "hello_2");Assert.IsTrue(msgs[3] == "hello_3");Assert.IsTrue(msgs[4] == "hello_4");// - dequeue msgvar msg = AzureQueueManager.DequeueMsg();Assert.IsTrue(msg == "hello_0");// - peek all messages , assert the first msg has been dequeuedmsgs = AzureQueueManager.Peek(5);Assert.IsTrue(msgs.Count == 4);Assert.IsTrue(msgs[0] == "hello_1");Assert.IsTrue(msgs[1] == "hello_2");Assert.IsTrue(msgs[2] == "hello_3");Assert.IsTrue(msgs[3] == "hello_4");}

測试逻辑在凝视中已经所有说明

最后，使用Azure Storage Explorer查看结果：