は、このWCF MVCシナリオで役立つNServiceBusですか？

Question

私はちょうどnservicebusの調査を開始しましたが、私の特定の状況に対しては、それが適切であるか、おそらく過度のものであることがわかりません。私はちょっと苦労しています。

私はMVCウェブサイトとWCF RESTサービスを持っています。 "質問を投稿する"。これは、エンティティの格納、ルールエンジンによる検査、プッシュメッセージの送信、集約データの更新など、いくつかのアクションをトリガする必要があります。ルールエンジンの結果によって、新しいメッセージが作成されることもあります。これらの要件は将来変更される可能性があります。私は受信エンドポイントがリッスンしている人（誰かXが新しい質問を作成した人）にメッセージを送信する方法でこれを実装したいと思います。

私はdbテーブルにメッセージを格納し、モジュールでテーブルを監視することを考えていました。この思考プロセスはmsmqに移動し、次にnservicebusを使用してpub subに移動しました。しかし、私はこれをどのように実装すべきか分かりません。

現在、次のようなシナリオを考えています。 WCF RESTサービスに質問があります。 WCFサービスは質問を残し、新しい質問メッセージを発行します（nservicebusを何とかしておく必要がありますか？）。メッセージに登録されている私のモジュールは、通知を送信する、または定義されたルールに基づいてアクションをトリガーするなどのアクションを行います。

これは、nservicebusを使用するpubサブが私に利益をもたらすシナリオですか？そして、これは実際にそれを意図して行く方法でしょうか？

Answer 1

WCFサービスは、質問を持続し、新しい質問を出版 メッセージ（それは何とかnservicebusホストする必要があるでしょうか？）

NServiceBusは、IISを含む任意の管理されたプロセスでホストすることができます。これを行うには（WCFサービス内）

• WCFサービスの起動時にIBusのインスタンスを作成します。
• サービスへの質問要求を受け取ったら、NServiceBusメッセージをアセンブルします。
• IBus.Publish（MyMessage）を使用してメッセージをパブリッシュします。

IISでIBusのインスタンスを作成するには、グローバルasmx内の流暢な構成を使用するのが一般的な方法です。典型的な設定は次のようになります

public class Global : System.Web.HttpApplication 
{ 
    public static IBus Bus { get; private set; } 

    void Application_Start(object sender, EventArgs e) 
    { 
     Bus = NServiceBus.Configure.WithWeb() 
      .Log4Net() 
      .DefaultBuilder() 
      .XmlSerializer() 
      .MsmqTransport() 
       .IsTransactional(false) 
       .PurgeOnStartup(false) 
      .UnicastBus() 
       .ImpersonateSender(false) 
      .CreateBus() 
      .Start(); 
    } 

NServiceBusエンドポイント（キュー）は、Webを使用して定義します。設定：

<configSections> 
    <section name="MsmqTransportConfig" 
      type="NServiceBus.Config.MsmqTransportConfig, NServiceBus.Core" /> 
</configSections> 

<MsmqTransportConfig InputQueue="WebFrontEnd" 
        ErrorQueue="error" 
        NumberOfWorkerThreads="1" 
        MaxRetries="5" /> 

私のモジュールは

あなたの下流の加入者は、おそらく最も簡単なホスティングオプションでWindowsサービスとして実行されているNServiceBusジェネリックホスト内の各ホストすることができるメッセージテイクアクションに加入します。サブスクライバはそれぞれ、IHandleMessagesを実装するメッセージハンドラクラスを持ちます。 NServiceBusで

方法パブ/サブ作品：

1. パブリッシャサービスは、入力キューおよびサブスクリプションの店を持っています。
2. 加入者サービスは、起動時に、入力キュー
3. 加入者を持っているが、出版社
4. の入力キューへのサブスクリプション・メッセージを送信するサブスクリプションメッセージは、メッセージの加入者のタイプに興味を持っていると、加入者が含まれていますキューアドレス
5. パブリッシャはサブスクリプションストアにサブスクリプションを記録します。
6. パブリッシャはメッセージを受け取ります。
7. パブリッシャーはサブスクリプションの一覧に対してメッセージの種類を評価します
8. 見つかった各一致に対して、パブリッシャーはメッセージをキューアドレスに送信します。

NServiceBus pub-subサンプルをダウンロードして、これをよりよく理解する必要があります。

Answer 2

あなたはWCFの代わりにNSBを使用し、WCFには使用しないと思います。サービスバスは、多くの新しい概念と設計を導入しています。非同期作業の考え方は従来の要求/応答とは大きく異なります。

開始するには、要求/応答の設計がボトルネックそのものになるまで、サービスバスが必要になるまで導入します。サービスバスは、アプリケーションに「ドロップイン」するだけのものではありません。既存のアプリケーションにサービスバスを導入する際には、最終的にコマンド/イベント/メッセージの処理が、即時の応答&リクエストを使用して設計されたシステムにどのように影響するかを考える必要があります。

Answer 3

あなたのREST APIがGETを処理していて、あなたのPUT/POST/DELETEのいくつかを "非同期"呼び出しにしたいと仮定します。ビルトインのWCF統合エンドポイントを使用することはできますが、SOAPバインディングに縛られています。あなたはRESTでハックすることができますが、本質的に2つのエンドポイントがあります.1つはGET用で、もう1つは他のものです。

NSBをブートストラップNSBをWCFに統合したのは、他の答え（HttpModuleを使用）と同じです。変更操作では、メッセージを別のエンドポイントにBus.Send（）してクライアントに戻すだけです。受信エンドポイントは、必要に応じて単にメッセージを処理します。

ロジックのパイプラインが必要な場合は、それが組み込まれています。メッセージハンドラを一緒に指定することで、定義された順序で処理することができます。私はあなたが望む効果であればPub/Subは必要ないかもしれないと思っています。これにより、エンドポイントの数が減少します。エンドポイントが過負荷になると、ディストリビュータを追加することでスケールアウトすることができますが、それは別の話です。