4.从队列接收消息
-
创建一个新的控制台应用程序并添加对 Service Bus NuGet 包的引用,类似于上面的发送应用程序。
-
将以下
using
语句添加到 Program.cs 文件的顶部。using Microsoft.ServiceBus.Messaging;
-
将以下代码添加到
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(); } } }
-
运行该程序,并检查门户。请注意,队列长度值现在应为 0。
恭喜! 你现在已经创建了一个队列,发送了一条消息并收到了一条消息。