問題タブ [messagebroker]

AMQ 5.5 を使用しています。デッド レターを ActiveMQ.DLQ 宛先に送信するオプションを無効にし、それ以外の場合に送信されるメッセージを (自動的に) 完全に破棄したいと考えています。これを行うために、ブローカーを次のように構成しました。

ただし、メッセージが DLQ に保存されていることがわかります。何が原因なのか教えてください。構成で何か修正する必要がありますか?

ありがとう

ハリ

ZMQ を使用してパブ/サブ アーキテクチャを設計しています。私は最大限の信頼性とスケーラビリティを必要としており、与えられた可能性の地獄に迷い込んでいます。

現時点では、ブローカーによってリンクされたパブリッシャーとサブスクライバーのセットを取得しています。ブローカーは、パブリッシャーのフロントエンドとサブスクライバーのバックエンドを公開するシンプルなフォワーダー デバイスです。

ブローカーがクラッシュまたは切断した場合に対処し、全体的なスケーラビリティを改善する必要があります。

そこで、複数のブローカーを追加することを考えました。パブリッシャーはブローカーをラウンドロビンしてメッセージを送信し、サブスクライバーはこれらすべてのブローカーをサブスクライブするだけです。

次に、可能なブローカーのリストを取得する方法が必要だったので、必要に応じてブローカーのリストを提供するネーム サービスを作成しました。パブリッシャーとサブスクライバーは、このサービスに接続するブローカーを尋ねます。

また、メインのネーム サービスが機能しなくなった場合に備えて、一種の「怠惰な海賊」 (つまり、次々に試行/再試行) の信頼できるネーム サービスも作成しました。

コードベースのサイズと複雑さが止まらないため、設計が間違っていると思い始めています。ZMQ が提供する可能性のジャングルで迷っています。

たぶん、ルーター/ディーラーベースの何かがここで使用できるでしょうか?

どんなアドバイスでも大歓迎です！

信頼性が高く、柔軟で、スケーラブルな方法でメッセージ交換を提供するフレームワークまたはプラットフォームはありますか? 次のシナリオがあります。

システムとメッセージを交換する外部デバイスがあります。これらのデバイスは実際には同一ではなく、複数のセットに固有のプロトコルがあります。私が探しているのは、中間層のプラットフォームまたはフレームワーク(メッセージ ブローカーまたは ESB)が、システム全体を変更することなくさまざまなプロトコルをサポートする非常に柔軟な統合ソリューションとして機能することです。一方で、システム アーキテクチャ全体で信頼性とスケーラビリティを確保する必要があります。

デバイスがメッセージを交換するシステムは、.Net で記述されています。それでも、そのメッセージ交換プラットフォームを使用して、Java または PHP システムと対話する可能性も知りたいです。

ActiveMQ、Camel、ServiceMix、Microsoft Biztalk などの Apache ファミリについて読みました。しかし、私はそれらのいずれも使用したことがなく、そのような技術について深い知識も持っていないため、上記のケースに何が当てはまるかを判断できませんでした.

私の会社は、Solaris から Linux への移行を検討していますが、WebSphere MQ と Message Broker が RHEL でどの程度うまく機能するかについて、いくつかの疑念が提起されています。IBM からのサポートについても懸念があります。この環境でこれらのツールを使用した経験のある人はいますか?

ありがとう。

Message Broker で MQMD.Expiry と MQM.Report (= MQRO_EXPIRATION_WITH_FULL_DATA) を設定すると、期限切れになったメッセージはどこに送られますか?

それらを MQInput ノードでキャッチする必要がありますか?

もしそうなら、どうすればこれらのエラーと他のエラーを区別できますか?

5 つの異なる形式のメッセージを受信します。すべてのメッセージは、最初の 20 文字が同じ形式になります。文字 10 から 20 を使用してメッセージ タイプを見つけなければなりません。次に、適切なメッセージ セットを適用します。計算ノードがテキストを理解するのではなく、0 から 20 までを解析するメッセージ形式と、残りを解析する 5 つの他のメッセージ形式を作成したいですか?

学習/実践の目的でクライアント/サーバーカードゲームを作成し、最初にクライアントとサーバーの両方にJavaを使用する予定です。将来的には、このプロジェクトを学習に使用し続けることを検討しているため、CやC++などの他の言語で追加のクライアントを作成する必要があります。

私が確信していない主な詳細は、メッセージブローカーでMOMを使用する必要があるかどうか、またはMOMを使用せずに逃げることができるかどうかです。

私の当初の考えは、メッセージの送受信の失敗に対処し、メッセージの再送信を促し、試行回数が最大に達した場合にゲームを終了させることでした。

ただし、ゲームクライアントとゲームサーバーだけでなく、クライアント、ロビーサーバー、ゲームサーバーを用意することも考えていました。このように、正しいメッセージを正しいサーバーにルーティングするためにメッセージブローカーが必要になりますが、メッセージブローカーが必要かどうかはわかりません。これは、本当に必要な機能があるかどうかわからないためです。メッセージの永続性。

私はメッセージブローカーを使ってMOMを選ぶことに傾倒していますが、不必要にそうしているのであれば、もう軽量なソリューションを歓迎します。そうは言っても、もし私が使用するのに適したクロスランゲージMOMは何でしょうか？私は以前にSOについて提案されたものをかなり多く見ましたが、自分のニーズに最適なものが何であるかわかりません。

QPID AMQP

ネットワーク トラフィックの再評価について質問があります。Machine A に Publisher があるとします。Qpid ブローカーはマシン B で実行されています。マシン C とマシン D の 2 人のサブスクライバーがいます (どちらも同じトピックにサブスクライブしています)。ここで、トポロジを想像してください。
A-->B-->X-->C | D (パブリッシャー A は B に接続され、サブスクライバー C および D は中間ノード X を介してブローカーに接続されます) C および D のトピックに一致する A によってパブリッシュされたメッセージは、両方によって受信されます。エッジ b->x はメッセージを 2 回 (b->x->c で 1 回、b->x->c で 2 回目) 伝送します。または、AMQP/qpid フレームワークは、メッセージを B から X に 1 回送信してから、個々のサブスクライバーにコピーを送信するのに十分なほどインテリジェントですか (したがって、b->x のネットワーク トラフィックが少なくなります)。私が考えたのは、X は何も知らないので、サブスクライバーごとにプライベート サブスクリプション キューがある場合 (または、共有キューがあり、メッセージを消費する代わりに閲覧/コピーしている場合でも)、メッセージは b->x を 2 回通過することです。

この質問は QPID に固有のものではありません。他のブローカー ベース (RabbitMQ) およびブローカーレス メッセージング フレームワーク (Zero MQ、LBM/UMS) のソリューションを知りたいです。Zero Mq がよりスマートなソリューションを提供しようとしている記事http://www.250bpm.com/pubsub#toc4を読みましたが、複数のコピーを送信するかどうかを中間ホップがどのように知るか (私はネットワーキングではありません)専門家なので、何かわかりにくいものがあるかもしれませんので、どんな助けも本当に感謝しています)

私は qpid を使用しており、今はブローカーの少ないメッセージング システムに移行しようとしていますが、Pub Sub パターンのネットワーク トラフィックについて本当に混乱しています。次のドキュメントを読みました: http://www.250bpm.com/pubsub#toc4 サブスクリプションの転送が実際にどのように行われるのか本当に混乱していますか?

ゼロ mq は、基盤となるネットワーク トポロジに依存しない必要があると考えていましたが、そうではないようです。すべてのノードは、何を転送し、何を転送しないかをどのように認識していますか (たとえば、何百万ものサブスクライバーとパブリッシャーが存在する可能性のある eth ネットワークでは、メッセージ ツリーは実現可能ではないように思えます。ゼロ mq が存在する場合、彼らはそれらに接続されたサブスクライバーにどのようにパケットを転送しますか?彼らにとってそれは単なる通常のパケットであり、同じパケットであってもデータ パケットの複数のコピーを転送するだけでしょうか?私はネットワークの専門家ではないので、そうかもしれませんメッセージ ツリーと、それがどのように作成されるかについて明らかな何かが欠けているのでしょうか? この配布ツリーがどのように作成されるか、どのノードが xpub および xsub ソケットで作成されるかについて、いくつかの例を挙げていただけますか?

デバイス (リンクで使用される用語) はブローカーのようなものです。記事全体では、デバイスが実際にブローカのようなもの、それは pub sub の場合、メッセージング ツリー内のすべてのノードがデバイスであるという定義を満たさなければならないことを意味するのでしょうか。

また、ツリー ダイアグラム (P、D、C で構成されるリンクから) では、最初は C と C が 2 つのサブスクライバーであり、P が唯一のパブリッシャー (D はランダム ホップ) であると想定していましたが、今では D がゼロ分子量。C は D にサブスクライブし、D は P にサブスクライブしますか? または両方の C が P にサブスクライブするだけです (より一般的には、各ノードは でのみその親にサブスクライブします)。初心者の質問で申し訳ありませんが、ここで明らかなことを見逃しているようです。誰かがより多くの洞察を与えることができれば幸いです。