您的代码有一些问题要解决 –

下面应该会看到你走向成功的道路。 祝好运。

  ManualResetEvent CompletedResetEvent = new ManualResetEvent(false); SubscriptionClient Client; public void ReceiveMessagesFromSubscription(string topicName, string subscriptionFilter, string connectionString) { Task listener = Task.Factory.StartNew(() => { // You only need to set up the below once. Client = SubscriptionClient.CreateFromConnectionString(connectionString, topicName, subscriptionFilter); OnMessageOptions options = new OnMessageOptions(); options.AutoComplete = false; options.AutoRenewTimeout = TimeSpan.FromMinutes(1); options.ExceptionReceived += LogErrors; Client.OnMessage((message) => { try { Trace.WriteLine("Got the message with ID {0}", message.MessageId); message.Complete(); // Remove message from subscription. } catch (Exception ex) { Trace.WriteLine("Exception occurred receiving a message: {0}" + ex.ToString()); message.Abandon(); // Failed. Leave the message for retry or max deliveries is exceeded and it dead letters. } }, options); CompletedResetEvent.WaitOne(); }); } /// 
 /// Added in rudimentary exception handling . /// 
 /// The sender. /// The  instance containing the event data. private void LogErrors(object sender, ExceptionReceivedEventArgs ex) { Trace.WriteLine("Exception occurred in OnMessage: {0}" + ex.ToString()); } /// 
 /// Call this to stop the messages arriving from subscription. /// 
 public void StopMessagesFromSubscription() { Client.Close(); // Close the message pump down gracefully CompletedResetEvent.Set(); // Let the execution of the listener complete and terminate gracefully } 

或者，您可以使用ReceiveBatch以更传统的方式将消息分块：

上述就是C#学习教程：Azure Service Bus – 使用OnMessage（）方法接收消息分享的全部内容，如果对大家有所用处且需要了解更多关于C#学习教程，希望大家多多关注—计算机技术网(www.ctvol.com)!

 var messages = await queueClient.ReceiveBatchAsync(10, TimeSpan.FromSeconds(30), cancellationToken);