未收到Azure服务总线消息

Question

我正在从web角色向worker角色发送消息。早些时候，这些消息被正确和立即接收，但现在没有收到任何消息，即使所有消息的内容都是相同的。就像我现在发送一条消息，它没有收到，但之后立即如果我发送另一条消息，然后收到最新消息。之前没有收到的那个，几秒钟后突然收到，或者因为生存时间已过，有时会收到死信。

我无法弄清楚问题是什么，有什么想法？或者这种行为与服务总线正常？

这是怎么了作业人员的角色接收消息

编辑：

public override void Run() 
    { 
     while (!IsStopped) 
     { 
      try 
      { 
       if (BroadcastReceived) 
       { 
        BroadcastReceived = false; 
        // Receive the message from Web Role to upload the broadcast to queue 
        BroadcastClient.BeginReceive(OnWebRoleMessageReceived, null); 
       } 

       if (SignalRMessageReceived) 
       { 
        SignalRMessageReceived = false; 
        // Receive the message from SignalR BroadcastHub 
        SignalRClient.BeginReceive(OnSignalRMessageReceived, null); 
       } 

       if (SignalRFirstTimeMessageReceived) 
       { 
        SignalRFirstTimeMessageReceived = false; 
        // Receive the message from SignalR BroadcastHub 
        SignalRFirstTimeClient.BeginReceive(OnSignalRFirstTimeMessageReceived, null); 
       }   
     } 
    } 


public void OnWebRoleMessageReceived(IAsyncResult iar) 
    { 
     BrokeredMessage receivedBroadcastMessage = null; 
     receivedBroadcastMessage = BroadcastClient.EndReceive(iar); 

     if (receivedBroadcastMessage != null) 
     { 
      // Process the message 
      receivedBroadcastMessage.Complete(); 
     } 
BroadcastReceived = true; 
    } 

UPDATE：

BroadcastClient = CloudStorageHelper.GetServiceBusQueueClient(Queuenames.ApiToWorkerRole); 

public static QueueClient GetServiceBusQueueClient(string queuename) 
    { 
     string connectionString = CloudConfigurationManager.GetSetting("Microsoft.ServiceBus.ConnectionString"); 

     var namespaceManager = NamespaceManager.CreateFromConnectionString(connectionString); 

     if (!namespaceManager.QueueExists(queuename)) 
     { 
      namespaceManager.CreateQueue(queuename); 
     } 

     QueueClient Client = QueueClient.CreateFromConnectionString(connectionString, queuename); 



     return Client; 
    } 

Web角色：

var queueClient = CloudStorageHelper.GetServiceBusQueueClient(Queuenames.ApiToWorkerRole); 

      //for testing purposes 
      record.Username = "owner"; 
      record.Channel = "World"; 
      record.Title = "Sample"; 
      record.Duration = 10; 

      BrokeredMessage message = new BrokeredMessage(record); 

      queueClient.Send(message); 

Answer 1

的问题是在我们工作人员的作用，因为我们出现连续检查服务总线队列，以查看是否收到了信息。当我们启动本地和云工作者角色时，这两个角色都尝试从同一个服务总线队列接收新消息。因此，有时云接受它，有时是本地的。

对云和本地项目使用不同的服务总线队列名称解决了问题。

Answer 2

在辅助角色以上，哟你只在Run中执行代码一次。所以基本上，这表明每次运行worker角色时都会处理单个消息？典型的代码在一个循环来处理消息如下所示：

public override void Run() 
    { 
     while (!IsStopped) 
     { 
      try 
      { 
       // Receive the message 
       BrokeredMessage receivedMessage = null; 
       receivedMessage = Client.Receive(); 

       if (receivedMessage != null) 
       { 
        // Process the message 
        receivedMessage.Complete(); // Unless you do this the message goes back in the Queue 
       } 
      } 
      catch (MessagingException e) 
      { 
       if (!e.IsTransient) 
       { 
        Trace.WriteLine(e.Message); 
        throw; 
       } 

       Thread.Sleep(10000); // optional if you want to add a delay 
      } 
     } 
    }