开始使用队列存储和 Visual Studio 连接服务 (ASP.NET Core)Get started with queue storage and Visual Studio connected services (ASP.NET Core)

提示

试用 Microsoft Azure 存储资源管理器

Microsoft Azure 存储资源管理器是 Microsoft 免费提供的独立应用，适用于在 Windows、macOS 和 Linux 上以可视方式处理 Azure 存储数据。

本文介绍通过使用 Visual Studio 中的“连接服务”功能在 ASP.NET Core 项目中创建或引用 Azure 存储帐户之后，如何开始在 Visual Studio 中使用 Azure 队列存储。执行“连接服务”操作会安装相应的 NuGet 程序包，以访问项目中的 Azure 存储，并将存储帐户的连接字符串添加到项目配置文件中。（有关 Azure 存储的常规信息，请参阅。）

Azure 队列存储是一项可存储大量消息的服务，用户可以通过经验证的呼叫，使用 HTTP 或 HTTPS 从世界任何地方访问这些消息。一条队列消息的大小最多可为 64 千字节 (KB)，一个队列中可以包含数百万条消息，直至达到存储帐户的总容量限值。有关以编程方式操作队列的详细信息，另请参阅通过 .NET 开始使用 Azure 队列存储。

某些 Azure 存储 API 为异步，而本文中的代码假定正在使用异步方法。有关详细信息，请参阅。

要访问 ASP.NET Core 项目中的队列，请将下列事项包含在访问 Azure 队列存储的任何 C# 源文件中。在接下来的部分中，会在代码的前面使用全部这些代码。

  • 添加必要的 语句：
  • 获取表示存储帐户信息的 CloudStorageAccount 对象。使用下面的代码获取存储连接字符串和 Azure 服务配置中的存储帐户信息：
  1. CloudStorageAccount storageAccount = CloudStorageAccount.Parse(
  2.     CloudConfigurationManager.GetSetting("<storage-account-name>_AzureStorageConnectionString"));
  • 获取 CloudQueueClient 对象，以引用存储帐户中的队列对象：
  1. // Create the CloudQueueClient object for the storage account.
  2. CloudQueueClient queueClient = storageAccount.CreateCloudQueueClient();
  • 获取 CloudQueue 对象，以引用特定队列：
  1. // Get a reference to the CloudQueue named "messagequeue"
  2. CloudQueue messageQueue = queueClient.GetQueueReference("messagequeue");

使用代码创建队列Create a queue in code

若要在代码中创建 Azure 队列，请调用 CreateIfNotExistsAsync：

向队列添加消息Add a message to a queue

要在现有队列中插入消息，请创建新的 CloudQueueMessage 对象，并调用 AddMessageAsync 方法。可从字符串（UTF-8 格式）或字节数组创建 CloudQueueMessage 对象。

  1. CloudQueueMessage message = new CloudQueueMessage("Hello, World");
  2. await messageQueue.AddMessageAsync(message);

读取队列中的消息Read a message in a queue

通过调用 PeekMessageAsync，可以扫视队列前面的消息，而不会从队列中删除它：

  1. // Peek the next message in the queue.
  2. CloudQueueMessage peekedMessage = await messageQueue.PeekMessageAsync();
  • 调用 以获取队列中的下一条消息。从 GetMessageAsync 返回的消息对于从此队列读取消息的任何其他代码都是不可见的。默认情况下，此消息将持续 30 秒不可见。
  • 若要完成从队列中删除消息，请调用 DeleteMessageAsync。
    此删除消息的两步过程可确保，如果代码因硬件或软件故障而无法处理消息，则代码的其他实例可以获取相同消息并重试。以下代码会在消息得到处理后立即调用 DeleteMessageAsync：
  1. // Get the next message in the queue.
  2. CloudQueueMessage retrievedMessage = await messageQueue.GetMessageAsync();
  4. // Process the message in less than 30 seconds.
  6. // Then delete the message.
  7. await messageQueue.DeleteMessageAsync(retrievedMessage);

用于取消对消息进行排队的其他选项Additional options for dequeuing messages

可以通过两种方式自定义队列中的消息检索。首先，可以获取一批消息（最多 32 个）。其次，可以设置更长或更短的不可见超时时间，从而允许代码使用更多或更少时间来完全处理每个消息。以下代码示例使用 GetMessages 方法在一个调用中获取 20 条消息。然后，使用 foreach 循环处理每条消息。它还将每条消息的不可见超时时间设置为 5 分钟。请注意，这 5 分钟计时器对于所有消息都是同时开始的，因此在 5 分钟后，尚未删除的任何消息都将再次变为可见。

获取队列长度Get the queue length

可以获取队列中消息的估计数。使用 FetchAttributes 方法可请求队列服务来检索队列属性，包括消息计数。ApproximateMethodCount 属性将返回 FetchAttributes 方法检索到的最后一个值，而不会调用队列服务。

  1. // Fetch the queue attributes.
  2. messageQueue.FetchAttributes();
  4. // Retrieve the cached approximate message count.
  7. // Display the number of messages.
  8. Console.WriteLine("Number of messages in queue: " + cachedMessageCount);

此示例演示如何将异步等待模式与以 Async 结尾的公用队列 API 结合使用。使用异步方法时，异步等待模式将暂停本地执行，直到调用完成。此行为允许当前的线程执行其他工作，这有助于避免性能瓶颈并提高应用程序的整体响应能力。

  1. CloudQueueMessage cloudQueueMessage = new CloudQueueMessage("My message");
  3. // Async enqueue the message.
  4. await messageQueue.AddMessageAsync(cloudQueueMessage);
  5. Console.WriteLine("Message added");
  7. // Async dequeue the message.
  8. CloudQueueMessage retrievedMessage = await messageQueue.GetMessageAsync();
  9. Console.WriteLine("Retrieved message with content '{0}'", retrievedMessage.AsString);
  11. // Async delete the message.
  12. await messageQueue.DeleteMessageAsync(retrievedMessage);
  13. Console.WriteLine("Deleted message");

删除队列Delete a queue

若要删除队列及其内含的所有消息，请对队列对象调用 Delete 方法：

  2. messageQueue.Delete();

后续步骤Next steps

现在，已了解有关 Azure 队列存储的基础知识，可单击下面的链接来了解更复杂的存储任务。

  • 有关可用 API 的完整详细信息，请查看参考中的队列服务参考文档。
  • 在通过 .NET 开始使用 Azure 队列存储中详细了解如何使用队列存储
  • 若要了解如何简化编写用于 Azure 存储的代码，请查阅
  • 查看更多功能指南，以了解在 Azure 中存储数据的其他方式。