NServiceBus - 異なるスレッド/プロセスでBus.Send（）が発生したときのメッセージハンドラの順序を制御する方法は？

Question

シナリオ：

NServiceBus経由で監査メッセージを送信するシナリオがあります。ハンドラは既存のデータベーステーブルに行を挿入して更新しますが、変更は不要です。監査データに正しいシステム状態が反映されるように、メッセージの処理順序を制御する必要があります。順不同で処理されたメッセージは、監査データに誤った状態が反映される可能性があります。

監査データの中には特定の順序が想定されているものもありますが、プロセス中に何度も送信される状態更新など、最初のメッセージの後にいつでも受信できるものもあります。私は次のように構成されたエンドポイントを持つサーバー、（特にISpecifyMessageHandlerOrdering機能）を使用してテストしてきた私のテストプロジェクトで

：

public class MyServer : IConfigureThisEndpoint, AsA_Server, ISpecifyMessageHandlerOrdering 
    { 
      public void SpecifyOrder(Order order) 
      { 
       order.Specify(First<PrimaryCommand>.Then<SecondaryCommand>()); 
      } 
    } 

メッセージの明示的な順序が知られていないので、一つのメッセージ、 InitialAuditMessageは最初のメッセージで、PrimaryCommandから継承します。

後で受信できる他のメッセージは、SecondaryCommandから継承します。

public class StartAuditMessage : PrimaryCommand 
public class UpdateAudit1Message : SecondaryCommand 
public class UpdateAudit2Message : SecondaryCommand 
public class ProcessUpdateMessage : SecondaryCommand 

これは、同じスレッドから送信されたメッセージの処理順序を制御する際に機能します。

ただし、メッセージが別のスレッドまたはプロセスから送信された場合、これは機能しません。これは、関連するメッセージをリンクするものがないため意味があります。

メッセージを別のスレッドから送信したときに順不同で処理されないように、何らかのIDのようにメッセージをリンクするにはどうすればよいですか？これはSagasのユースケースですか？

また、ステータス更新メッセージに関しては、同じタイプのメッセージが送信された順に処理されるようにするにはどうすればよいですか？

Answer 1

注文処理の要件がある場合は、処理のある時点ですべてを1つのスレッドに限定する必要があるという結論を避けることはできません。単一スレッドは、処理される順序を保証します。

場合によっては、処理を相関識別子で分割して、1つのスレッドを複数のスレッドに「スケールアウト」することができます。相関IDを使用すると、順序を維持する必要があるメッセージの論理グループを定義できます。これにより、より効率的な順序付けられた処理をそれぞれ実行する同時スレッドを持つことができます。