問題タブ [masstransit]

私は非常に奇妙な問題と戦っています... Windows 7 Ultimate上の.NET 4.0を使用して、WCFサービス間のサービスバス通信(MassTransit + MSMQ経由)を実装しました。サービスが起動すると、すべてが正常に機能し、お互いにメッセージを受信しますが、特定の時点で、コンピューターの管理 -> サービスとアプリケーション -> メッセージ キュー -> でプライベート キューを手動で削除するまで、サービスは受信しません。 > プライベート キュー。

各サービスごとに、MassTransit を構成するブートストラップがあります。

次に、サービスのメイン クラスが MassTransit を拡張します。以下に例を示します。

説明したように、特定の時点で Accept メソッドは呼び出されなくなります。唯一の方法は、プライベート キューを手動で削除し、サービスを再起動することです。その後、次のトラブルまで、システムは再び正常に動作します :-(.

どんな提案でも大歓迎です。

どうもありがとう！アレッサンドロ

MassTransitServiceBusを使用してメッセージの処理を「一時停止」するための良い方法を考え出そうとしています。基本的に、Windowsサービスを実行したままにする必要がありますが、メッセージの処理を一時的に停止します。

これを行うには、サブスクリプショントークンを使用する方法と、サービスバスを破棄する方法の2つしか考えられません。

これを行うための好ましい方法はありますか、それとも私は間違った道を進んでいますか？

IronPython で次の C#/.Net インターフェイスを実装したくありません。

これは私がこれまでに試したpythonコードです：

これから、次の例外が発生します。

TypeError: TestConsumer: 開いている一般的なインスタンス化 MassTransit.Consumes`1+All[TMessage] から継承できません。閉じたインスタンス化のみがサポートされています。

このインターフェイスを実装するための有効な C# クラス定義は次のようになります。

では、IronPython でこの種のものを実装することはできないのでしょうか? それとも私は間違っていますか？

前もって感謝します！

MassTransit プロジェクトからいくつかのサンプル コードを実行しようとしています。

Visual Studio を使用するとF5、次の例外が発生します。

Management Console で MessageQueues を確認したところ、実際にキューが存在しないことがわかりました。ただし、TestApp1.exe を実行すると、すべて正常に動作し、キューが作成されます。Visual Studio に戻ると、同じエラーが引き続き発生します (ただし、キューが使用できるようになりました)。

キューのセキュリティを設定してみました (Everyone フル アクセス) が、変更されません。

私は何を間違っていますか？これを Visual Studio 内から実行できないのはなぜですか?

編集

RabbitMQコードをインストールして更新しました：

そしてそれは動作します。
疑問が残ります: msmq の何が問題なのですか? 私はそれを使い続けたいと思います。

MassTransit と MSMQ を使用して、複数のサブスクライバー (すべてのサブスクライバーがパブリッシュされたメッセージを受信する) を持つパブリッシャー/サブスクライバー アーキテクチャを正しくセットアップするにはどうすればよいですか。

MSMQ マルチキャスト機能は少し不安定であり、PGM (独自のいくつかの制限があります) に依存しているため、使用したくないことに注意してください。

this、this、およびthisを読みましたが、セットアップ方法がわかりません

1. サブスクリプションサービス、
2. 出版社、
3. そして数人の加入者。

特に、sbc.UseSubscriptionService("uri");多くの例で使用されている は廃止されました (私は MassTransit 2.7 を使用しています)。古いコメントには と書かれてThe extension method on UseMsmq should be used instaedいますが、そのような方法は見つかりません。
サブスクリプション サービスをどのようにセットアップすればよいでしょうか。

MassTransit Github ページのDistributorサンプルは、私が望むものに最も近いものですが、消費サブスクライバーをセットアップします。

複数のサブスクライバーが可能なパブリッシャー/サブスクライバー アーキテクチャをセットアップする方法の例を教えてください。

御時間ありがとうございます。

MSMQ で MassTransit を使用すると、1 回限りの配信(たとえば、イベント ストアがイベントを 2 回発行する場合) と順次配信(たとえば、2 つのノードがイベントを同時に書き込み/発行する場合) を自動的にサポートできます。ノード A がイベントを格納する可能性があります。 #2、次にノード B がイベント #2 を読み取り、ノード B がイベント #3 を保存、ノード B がイベント #3 を発行、ノード A がイベント #2 を発行 - 典型的な競合状態)?

また、MassTransit がそれをすぐにサポートしていない場合 (私は現在これを想定しています)、MassTransit/MSMQ でこれら 2 つの要件を実装するための最適な/一般的なアプローチは何ですか?

誰かが私を助けてくれるかもしれないと思って、この問題に遭遇しました。

そこで、RabbitMQ サーバーにクラスター ノードを 1 つ追加しました。ここで、クライアントのサーバーに接続したいと考えています。エンドポイントの配列を渡すことができる RabbitMQ.Client のように、MassTransit が最初に利用可能なサーバーに接続し、最初に利用可能なサーバーに接続するようにします。

ありがとう、ペイマン

すべてのプロセスが同じサーバー上で実行されている限り、問題なく動作する MassTransit ベースのデモを開発しました。

ただし、受信者が別のマシンで自分自身を購読したいので、しばらくハングし、その後、次の例外を受け取ります。

「System.InvalidOperationException: サブスクリプション サービスが応答するのを待っているタイムアウト。」

確認済み: MSMQ (インバウンドおよびアウトバウンド)、ネットワークなどのファイアウォール ルール。

何がうまくいかなかったのでしょうか？

• 他のマシンのサブスクリプション キューはプライベートですか? これは問題ですか？
• 特別な方法でアドレス形式を変更する必要がありますか? msmq://computerName/queueName リモート接続に問題がありますか?

以前は誰もこの問題を抱えていなかったので、小さなことを忘れているようです...