共用方式為

開始使用 Azure 佇列儲存體和 Visual Studio 已連接服務 (雲端服務專案)

  • 發行項

提示

Microsoft Azure 儲存體總管

Microsoft Azure 儲存體總管 是一個免費的獨立應用程式，可讓您在 Windows、MacOS 和 Linux 上以視覺化方式處理 Azure 儲存體資料。

概觀

重要

雲端服務 (傳統) 目前已針對新客戶淘汰，且從 2024 年 8 月 31 日起將針對所有客戶淘汰。 新部署應使用以 Azure Resource Manager 為基礎的新部署模型 Azure 雲端服務 (延伸支援)。

本文說明如何在您使用 Visual Studio [ 新增已聯機服務 ] 對話方塊建立或參考雲端服務專案中的 Azure 儲存體帳戶之後，開始使用 Visual Studio 中的 Azure 佇列儲存體。

我們將會示範如何在程式碼中建立佇列。 我們也將顯示如何執行基本的佇列作業，例如新增、修改、讀取和讀取佇列訊息。 這些範例是以 C# 程式碼撰寫，並使用適用于 .NET 的 Microsoft Azure 儲存體 用戶端程式庫。

[ 新增連接的服務 ] 作業會安裝適當的 NuGet 封裝，以存取專案中的 Azure 儲存體，並將儲存體帳戶的連接字串新增至您的專案組態檔。

Azure 佇列儲存體是一項儲存大量訊息的服務，全球任何地方都可利用 HTTP 或 HTTPS 並透過驗證的呼叫來存取這些訊息。 單一佇列訊息的大小上限為 64 KB，而一個佇列可以包含數百萬個訊息，以儲存體帳戶的總容量為限。

在程式碼中存取佇列

若要在 Visual Studio 雲端服務專案中存取佇列，您需要將下列項目加入至任何 C# 原始程式檔，以存取 Azure 佇列儲存體。

  1. 請確定 C# 檔案頂端的命名空間宣告包含這些 using 陳述式。

    using Microsoft.Framework.Configuration;
using Microsoft.WindowsAzure.Storage;
using Microsoft.WindowsAzure.Storage.Queue;

  2. 取得 CloudStorageAccount 物件，其代表您的儲存體帳戶資訊。 使用下列程式碼，從 Azure 服務組態取得您的儲存體連接字串和儲存體帳戶資訊。

    CloudStorageAccount storageAccount = CloudStorageAccount.Parse(
CloudConfigurationManager.GetSetting("<storage-account-name>_AzureStorageConnectionString"));

  3. 取得 CloudQueueClient 物件以參考儲存體帳戶中的佇列物件。

    // Create the queue client.
CloudQueueClient queueClient = storageAccount.CreateCloudQueueClient();

  4. 取得 CloudQueue 物件以參考特定的佇列。

    // Get a reference to a queue named "messageQueue"
CloudQueue messageQueue = queueClient.GetQueueReference("messageQueue");

注意： 在下列範例中的程式碼前面使用上述所有程式碼。

在程式碼中建立佇列

若要在程式碼中建立佇列，請加入 CreateIfNotExists呼叫。

// Create the CloudQueue if it does not exist
messageQueue.CreateIfNotExists();

將訊息新增至佇列

若要將訊息插入現有佇列，請建立新的 CloudQueueMessage 物件，然後呼叫 AddMessage 方法。

您可以從字串 (採用 UTF-8 格式) 或位元組陣列建立 CloudQueueMessage 物件。

以下是插入訊息 'Hello, World' 的範例。

// Create a message and add it to the queue.
CloudQueueMessage message = new CloudQueueMessage("Hello, World");
messageQueue.AddMessage(message);

讀取佇列中的訊息

您可以呼叫 PeekMessage 方法來查看佇列前端的訊息，而不需從佇列中移除訊息。

// Peek at the next message
CloudQueueMessage peekedMessage = messageQueue.PeekMessage();

讀取並移除佇列中的訊息

您的程式碼可以使用兩個步驟將訊息從佇列中移除 (清除佇列)。

  1. 呼叫 GetMessage 以取得佇列中的下一個訊息。 從 GetMessage傳回的訊息，對從這個佇列讀取訊息的任何其他程式碼都看不見。 依預設，此訊息會隱藏 30 秒。
  2. 若要完成從佇列中移除訊息，請呼叫 DeleteMessage。

這個刪除訊息的兩步驟流程可確保當程式碼因硬體或軟體故障而無法處理訊息時，程式碼的其他執行個體可取得相同訊息並再試一次。 下列程式碼會在處理完訊息之後立即呼叫 DeleteMessage 。

// Get the next message in the queue.
CloudQueueMessage retrievedMessage = messageQueue.GetMessage();

// Process the message in less than 30 seconds

// Then delete the message.
await messageQueue.DeleteMessage(retrievedMessage);

使用其他選項來處理和移除佇列訊息

自訂從佇列中擷取訊息的方法有兩種。

  • 您可以取得一批訊息 (最多 32 個)。
  • 您可以設定較長或較短的可見度逾時，讓您的程式碼有較長或較短的時間可以完全處理每個訊息。 下列程式碼範例將使用 GetMessages 方法，在一次呼叫中取得 20 個訊息。 接著它會使用 foreach 迴圈處理每個訊息。 它也會將可見度逾時設定為每個訊息五分鐘。 請注意，所有訊息的 5 分鐘都會同時啟動，因此在呼叫 GetMessages之後超過 5 分鐘之後，任何尚未刪除的訊息都會再次顯示。

以下是範例：

foreach (CloudQueueMessage message in messageQueue.GetMessages(20, TimeSpan.FromMinutes(5)))
{
    // Process all messages in less than 5 minutes, deleting each message after processing.

    // Then delete the message after processing
    messageQueue.DeleteMessage(message);

}

取得佇列長度

您可以取得佇列中的估計訊息數目。 FetchAttributes 方法會要求佇列服務擷取佇列屬性，其中包含訊息計數。 ApproximateMethodCount 屬性會傳回 FetchAttributes 方法所擷取的最後一個值，而無需呼叫佇列服務。

// Fetch the queue attributes.
messageQueue.FetchAttributes();

// Retrieve the cached approximate message count.
int? cachedMessageCount = messageQueue.ApproximateMessageCount;

// Display number of messages.
Console.WriteLine("Number of messages in queue: " + cachedMessageCount);

搭配使用 Async-Await 模式和通用 Azure 佇列 API

這個範例示範如何搭配使用 Async-Await 模式和通用 Azure 佇列 API。 此範例會呼叫每個指定方法的非同步版本，這可由每個方法的 Async 後置修正來查看。 使用非同步方法時，async-await 模式會暫停本機執行，直到呼叫完成為止。 這種行為可讓目前的執行緒執行其他工作，有助於避免發生效能瓶頸並提升應用程式的整體回應。 如需在 .NET 中使用Async-Await模式的詳細資訊，請參閱 Async 和 Await (C# 和 Visual Basic) 

// Create a message to put in the queue
CloudQueueMessage cloudQueueMessage = new CloudQueueMessage("My message");

// Add the message asynchronously
await messageQueue.AddMessageAsync(cloudQueueMessage);
Console.WriteLine("Message added");

// Async dequeue the message
CloudQueueMessage retrievedMessage = await messageQueue.GetMessageAsync();
Console.WriteLine("Retrieved message with content '{0}'", retrievedMessage.AsString);

// Delete the message asynchronously
await messageQueue.DeleteMessageAsync(retrievedMessage);
Console.WriteLine("Deleted message");

刪除佇列

若要刪除佇列及其內含的所有訊息，請在佇列物件上呼叫 Delete 方法。

// Delete the queue.
messageQueue.Delete();

後續步驟

既然已了解 Azure 佇列儲存體的基本概念，請遵循下列連結以了解更複雜的儲存體工作。