Microsoft Azure Service Bus QueueがFIFOとして機能する

Question

azure用の2つのWebJobを開発しています.1つはトピックを使用してService Bus Queueにメッセージを入れ、もう1つはServiceBusTriggerに同じトピックを使用して購読します。

メッセージはサービスバスキューに正しく送信されますが、ServiceBusTriggerに登録されたWebJobを実行すると、これらのメッセージはFIFOベースで処理されません。

サービスバスキューにメッセージを入れるWebJobためのコードは以下の通りです：

namespace HO.Importer.Azure.WebJob.TGZProcessor 
{ 
    public class Program 
    { 
     static void Main(string[] args) 
     { 
      JobHostConfiguration config = new JobHostConfiguration(); 
      config.UseServiceBus(); 
      JobHost host = new JobHost(config); 
      host.RunAndBlock(); 
     } 

     public static void WriteLog([ServiceBusTrigger("SampleTopic", "ImporterSubscription")] string message, 
      TextWriter logger) 
     {     
      Console.WriteLine(message)); 
     } 
    } 
} 

：サービス・バスのトリガにsubscritedさ

NamespaceManager namespaceManager = NamespaceManager.Create(); 

// Delete if exists 
if (namespaceManager.TopicExists("SampleTopic")) 
{ 
    namespaceManager.DeleteTopic("SampleTopic"); 
} 

TopicDescription td = new TopicDescription("SampleTopic"); 
td.SupportOrdering = true; 
TopicDescription myTopic = namespaceManager.CreateTopic(td); 

SubscriptionDescription myAuditSubscription = namespaceManager.CreateSubscription(myTopic.Path, "ImporterSubscription"); 

TopicClient topicClient = TopicClient.Create("SampleTopic"); 
for(int i = 1; i <= 10; i++) 
{ 
    var message = new BrokeredMessage("message"+i);     
    topicClient.Send(message); 
} 
topicClient.Close(); 

WebJobを次のコードを持っていますキューからメッセージをFIFOとして処理するにはどうすればよいですか？

ありがとうございます！

Answer 1

Azure Service Busは、FIFOのような機能を提供しようとする可能性がありますが、ブローカベースのキューイングシステムではこの種の動作を想定しないほうがよいでしょう。 Ben Morris氏は、非同期メッセージングを使用した注文がほぼ間違いであり、それが理由であるという事実について、良い投稿Don’t assume message ordering in Azure Service Busを持っていました。

Answer 2

SessionIdまたはPartitionKeyを使用すると、メッセージが同じメッセージブローカーによって確実に処理されます。

を参照してください：のSessionIdはhttps://docs.microsoft.com/en-us/azure/service-bus-messaging/service-bus-partitioning

は「：メッセージがBrokeredMessage.SessionIdプロパティが設定されている場合は、Service Busは、パーティションキーとして、このプロパティを使用しています。この方法は、同じセッションに属するすべてのメッセージがによって処理されますこれにより、Service Busはメッセージの順序付けとセッション状態の一貫性を保証することができます。