問題タブ [messagebroker]

私は、大規模なデータベースの特定のデータをリモート Web サイトで利用できるようにするソリューションに取り組んでいます。私が最初に考えたのは、データベースから特定のデータを取得するために、いくつかの SOAP Web サービスを簡単に作成することでした。これは、Zend_Soap_Server のユーザーを使用して、たとえば次のように数行で実行できます。

今、誰かが私にメッセージブローカー/キューも見てみるように言った. 私は apache activeMQ、stomp、zend_queue などのソフトウェアを調べてきましたが、それらが何に使用されるべきか、またこのプロジェクトで役立つかどうかについて明確な見解を得ることはできませんでした。

私の実装には、データベースの応答が速くないときに Web サイトが遅くなったり、Web サイトから多くのリクエストが来るときにデータベースに高負荷がかかるなど、いくつかの欠点がある可能性があることを理解しています。メッセージブローカーはそのような複雑さを防ぐことができますか?

メッセージを生成するサーバーとメッセージを受信する多くのクライアントとの間で、パブリッシャー/サブスクライバー ベースの通信プロトコルをセットアップしたいと考えています。少し調べた後、ActiveMQ を使用することにしました。いくつかのチュートリアルと ActiveMQ サイトを見て、次のようにブローカーをセットアップしました。

メッセージパッシング機能のみが必要で、データベースの永続性などは必要ありません。ただし、アプリケーションを起動すると、構成に関係なく、activemq-data フォルダーが作成されます。これにより、次にブローカーを起動したときに例外が発生します。

これはバグですか、それともブローカーを正しく設定していないのですか (ActiveMQ 5.4.1 を使用)? 追加のデータ ストレージが作成されないように、永続性を無効にするにはどうすればよいですか? また、xml ファイルではなく、Java アプリケーション内からブローカーを構成することを好みます。

乾杯、マックス

組み込みデバイス用のアプリケーションをいくつか開発しています。Windows CE 5.0 および C# 2.0 を使用する XP 組み込みの両方と互換性があるはずです。アプリケーションは、通常はイベントを表す小さなメッセージを交換する必要があります。TCP ソケットと、ディスパッチャーとして機能する別のサーバー (pub/sub パターンを使用) を使用して、最初のプロトタイプを実装しました。それは機能しますが、MSMQ を使用する方がより良い解決策になるかどうか疑問に思っています。いくつかのシナリオではメッセージの永続化が役立ちますが、通常はすべてのイベントがターゲット アプリケーションによってすぐに消費される必要があります。両方のソリューションの長所と短所、および決定に役立つガイドラインを知りたいです。

ありがとうございました

RabbitMQ 経由で pdf や word などのファイルを送信できるようにする必要があります (答えは、RabbitMQ に固有のものではなく、RabbitMQ を使用しているブローカーのより一般的な意味であると思います)。

それらを mimes として送信する方法はありますか、それとも base64 に変換してから送信する必要がありますか。

それとも、ここで接線を進んでいますか:(助けてください。

WMBで実行されているいくつかのレガシーアプリケーションを処理していて、特定のサブフローが属するメインフローを見つける方法を見つけようとしています。できることは明らかなことのようですが、私はそれを見つけることができないようです???? Grrrr

ブローカーアプリケーション開発6.0.2を使用しています

リモート サーバー上の JTEXT アダプターが (自分の PC から) 利用可能であることを確認する必要がありますが、その方法がわかりません。私のコンピューターには MB ソフトウェアがありません。おそらく telnet や同様の手段を介して、利用可能かどうかを判断する方法があるかどうか疑問に思っています。

次に、JTEXT アダプタの統計をリモートで確認する方法がある場合、アダプタに使用されているポートを特定するにはどうすればよいですか?

誰かがこれについて私が正しいか間違っているかを確認してください。「セレクター」操作は MessageConsumer 実装内で行われるようです。(つまり、すべてのメッセージが Message Broker から MessageConsumer にディスパッチされ、それらのメッセージに対して「セレクター」操作が実行されます)。この問題は、関心のない (つまり、セレクターに一致しない) メッセージが大量にある場合に発生します。これらのメッセージは、プリフェッチまたはキャッシュの制限により、最終的に MessageConsumer の内部キューをいっぱいにします。その結果、新しいメッセージ、特にセレクターで関心のあるメッセージを受信できなくなります。

では、MessageBroker 側でセレクター操作を実行するように AMQ を構成する方法はありますか? 「インターセプター」を調べて、独自の BrokerPlugin を作成する必要がありますか? この問題を回避する方法について何かアドバイスはありますか?

どんな答えでも本当に感謝しています。

ありがとう、Soonthorn A.

このサンプルを作成しました: Getting Started With RabbitMQ in .netですが、2 つのプログラムを作成しました。

• ワンパブリッシャー
• 1 人の加入者

BasicPublish例のように公開しBasicAckて聞くために使用しています。1 つのパブリッシャーと複数のサブスクライバーを実行すると、パブリッシャーからのすべての「メッセージの送信」で、1 つのサブスクライバーだけがそれを取得します。パブリッシャーがサブスクライバーにメッセージを送信する順序 (サブスクライバーが開始されたとき) があるように、すべてのサブスクライバーに 1 つのメッセージを送信したいと考えています。そのサンプルの何が問題になっていますか? RabbitMq を介したパブリッシャー/サブスクライバーのメッセージ交換の実用的なサンプルを提供できますか?

メッセージブローカーを書くことに興味があります（楽しみ/学習経験のため）。URL とポートを接続するだけでいくつかのテストを実行できる、メッセージ ブローカー用のテスト フレームワークはありますか? テストに必要なインターフェース (STOMP や AMQP など) をブローカーに使用させたいと考えています。可能性が低いことはわかっていますが、これらはたくさんあり、すべて少数のインターフェイスを使用しているため、可能だと思われます。これを Java で書くつもりはないので、vm://URL を必要とするものは機能しません。

IBM Websphere Message Broker を使用して、ストアド プロシージャ (cobol で記述) をメインフレームで Web サービスとして公開しようとしています。次に、Lotus Notes アプリケーション (8.5.1) を使用して Web サービスと通信し、ストアド プロシージャから返されたデータを取得できるようにする必要があります。いくつかの問題が発生しました:

前置きとして、Message Broker を使用して何かを Web サービスとして公開したことはなく、Lotus Notes 自体の内部で Web サービスを使用したこともありません。ただし、Lotus Notes が機能している請負業者が現場にいます。つまり、Lotus Notes 側で Web サービス コンシューマを正常に作成し、この接続をテストするためだけに .Net で作成した別の Web サービスを使用してデータを取得できます。

これまでにいくつかの問題に遭遇しました。任意の入力をいただければ幸いです。

1) WSDL アクセス - ストアド プロシージャはブローカー側で Web サービスとして公開されていると思われますが、サービス URL に ?wsdl を追加すると、wsdl にアクセスできません。これは、Web サービスが正しく設定されていないということですか?

2) Message Broker で wsdl を生成し、Web サービス コンシューマの import WSDL オプションを使用して Lotus Notes にインポートすることも試みました (URL を指定できないため)。Lotus Notes は WSDL を受け入れ、それと通信するための適切なコードを作成します。ここでの問題は、Broker が要求を受け取ったように見えますが、それを理解していないことです。

これを何週間もトラブルシューティングしてきましたが、うまくいきませんでした。どうぞ、どんなアイデアでも役に立ちます。