4.从队列接收消息

  1. 创建一个新的控制台应用程序并添加对 Service Bus NuGet 包的引用,类似于上面的发送应用程序。

  2. 将以下 using 语句添加到 Program.cs 文件的顶部。

    using Microsoft.ServiceBus.Messaging;
    
  3. 将以下代码添加到 Main 方法,将 connectionString 变量设置为创建命名空间时获取的连接字符串,并将 queueName 设置为创建队列时使用的队列名称。

    var connectionString = "";
    var queueName = "samplequeue";
    
    var client = QueueClient.CreateFromConnectionString(connectionString, queueName);
    
    client.OnMessage(message =>
    {
      Console.WriteLine(String.Format("Message body: {0}", message.GetBody<String>()));
      Console.WriteLine(String.Format("Message id: {0}", message.MessageId));
    });
    
    Console.ReadLine();
    

    这是你的 Program.cs 文件应该是这样的:

    using System;
    using Microsoft.ServiceBus.Messaging;
    
    namespace GettingStartedWithQueues
    {
      class Program
      {
        static void Main(string[] args)
        {
          var connectionString = "";
          var queueName = "samplequeue";
    
          var client = QueueClient.CreateFromConnectionString(connectionString, queueName);
    
          client.OnMessage(message =>
          {
            Console.WriteLine(String.Format("Message body: {0}", message.GetBody<String>()));
            Console.WriteLine(String.Format("Message id: {0}", message.MessageId));
          });
    
          Console.ReadLine();
        }
      }
    }
    
  4. 运行该程序,并检查门户。请注意,队列长度值现在应为 0。

    队列长度

恭喜! 你现在已经创建了一个队列,发送了一条消息并收到了一条消息。