問題タブ [broker]

ここにuniPaaS開発者がいる可能性があるのは遠慮がちですが、次のようになります。

今日初めて、uniPaaS1.5にあるシステムを複製しました。

uniPaaSブローカーで、アプリケーションが応答するフラグ/ApplicationPublicNameを 追加しました。APPNAME

ただし、AppName()アプリケーションが生成する出力は、アプリケーションの元の名前であり、私が。として指定したものではありません ApplicationPublicName。

私たちのシステムはに大きく依存していAppName()ます。AppName()と同じ値を返す方法はあります/ApplicationPublicNameか？

みなさん、Python で Etrade の株を取引するためのインターフェイスのプログラミングをどのように開始すればよいか考えていました。自動取引ボットを作成しようとしていますが、Etrade での自動取引用に公開されている API はありません。前もって感謝します。^^

ブローカ レベルである程度のインテリジェンスを備えた膨大な量のメッセージ トラフィックを管理できるパブリッシュ/サブスクライブ分散メッセージング フレームワークを構築しようとしています。これを説明するトポロジがあるかどうかはわかりませんが、これは私が目指しているモデルです。

例のモデル A

A) 実行中のメッセージ ブローカーが 2 つあります (デモを簡単にするために、可能であればすべて localhost で実行するのが理想的です)。

• ブローカー A
• ブローカー B

B) 各ブローカーには 2 つのリスナーと 1 つのパブリッシャーがあります。

例図

[サブスクライバー A1、サブスクライバー A2、パブリッシャー A1] <--> BrokerA <--> BrokerB <--> [パブリッシャー B1、サブスクライバー B1、サブスクライバー B2]

• メッセージ X がブローカー A にパブリッシュされ、Broker-B のリスナーに (メッセージ セレクターまたはブローカー ルーティング ルールの基準を介して) そのサブスクライバーが存在しない場合、そのメッセージ X はブローカー B にパブリッシュされません。

• それ以外の場合、ブローカー A はブローカー B にメッセージを発行します。そこでは、ブローカー B のリスナー/サブスクライバー/サービスの 1 つがサブスクリプション基準に基づいてそのメッセージを期待しています。

クラスタリングは正しいアプローチですか?

最初に、これをサポートするには「ブローカー クラスタリング」の概念が必要であると結論付けました。ただし、私が理解しているように、クラスタリングの一般的な使用には次のいずれかが伴います。

• すべてのブローカーにわたるメッセージの冗長性 ... または
• 競合する消費者パターン

...そして、これらはどちらも、モデル例 A の要件を満たしていません。

正しいアプローチとは？

私の質問は、私が説明したモデルをサポートする JMS 実装を知っている人はいますか?

検索のために、stackoverflow のすべての投稿タイトル (JMS とクラスター) をスキャンしました。これらの 2 つの有益な投稿を見つけましたが、一見矛盾しているように見えます。

1. 例のモデル A は暗黙的にサポートされている、またはサポートされるべきであると言います: ブローカーの ActiveMQ ネットワークを備えた JMS コンシューマー "これは、ブローカーを選択し、それに接続し、ブローカー ネットワークにそれらの間でそれを整理させることを意味します。理論的には."

2. サンプル モデル A はサポートされていません: クラスター化されたアプリケーション サーバーの JMS トピック サブスクライバーはどのようにメッセージを受信しますか? 「異なるアプリ サーバーで実行されている PropertiesSubscriber のすべてのインスタンスは、そのメッセージを受け取ります。」

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

私の投稿を読んでいただき、誠にありがとうございます。

遺伝子

こんにちはスタックオーバーフラワーです。

ActiveMQ でブローカーを起動しようとしているときに、非常に厄介なエラーが発生しました。何らかの理由で、管理コンテキストが既に登録されているものを起動しようとしているようです。スタック トレースの先頭には次のように表示されます。

何が起こっているのか誰にも分かりますか？

xBeanで解析された外部XMLファイルを介してActiveMQブローカーを構成する際に問題が発生しました。この時点で、ヘルプ、ヒント、ポインタ、ヒント、さらには応援を歓迎します。これが私の問題です：

外部の.xmlファイルを使用してブローカーを構成しようとしています。Springバンドルのコンテキストに次のコードがあります。

これは、それ以上の問題なしに構成ファイルとリンクするはずです。activemq.xmlファイルは次のようになります。

ご覧のとおり、これはかなり標準的なものです。バンドルを開始すると、次の例外が発生します。

関係するnamaspacesのいくつかの構成を試しました。"amq:"宣言（<broker>および）の有無にかかわらずブローカータグを使用し<amq:broker>、activemq.xsd宣言の特定のバージョン番号を指定します。それでも、.xsdファイルが見つからないようです。activemq .xsdファイルのバージョン番号を指定すると、代わりに次のようになります。

ここにあるxbean-springバージョン3.7を使用しています。バンドルファイルから.xsdファイルを抽出し、com.springsource.org.apache.activemq-5.3.0.jarバンドルの1つにあるパッケージにエクスポートしようとしましたが、パーサーがそれを見つけられないようです。この問題について、GeronimoJiraにもバグを投稿しました。

誰かがこの問題に光を当てることができますか？

よろしくお願いします、
エドゥアルド。

デザインパターンに関する本（旧版）「パターン指向のソフトウェアアーキテクチャ」を読んでいます。Client-Dispatcher-Server に関する章では、SunRPC は Client-Dispatcher-Server アーキテクチャとして引用されており、ポートマッパーは Client-Server ネゴシエーションで Dispatcher として機能します。SunRPC がどのように機能するかは多かれ少なかれ知っていますが、SunRPC を実際に使用したことはありません。

3 つの質問があります。

• Client-Dispatcher-Server メカニズムとしての SunRPC のソフトウェア制限 (インターフェイスと機能の観点から) は何ですか?
• 同じ Client-Dispatcher-Server アーキテクチャ (言語に関係なく) を達成するために、今日同様に優れたシステムは何ですか?
• Broker アーキテクチャと Client-Dispatcher-Server アーキテクチャの本質的な違いは何ですか?

質問が多く、複雑であることは承知しています。独立した質問に分割することも考えましたが、この提出のポイントは、典型的なケースとして特定の例 (SunRPC) を使用して、一般的なアーキテクチャの原則と制限についてです。これらの考慮事項により、猶予期間中の回答に対する満足度に関係なく、機会があればすぐに 100 担当者のバウンティを設定することを事前に発表します。

ActiveMQ に関して: 小さな (約 10KB) ファイルをコンシューマーに送信するプロデューサーが 1 つあるシナリオがあります。ファイルは小さいですが、コンシューマーがそれらを分析して結果をプロデューサーに返すのに約 10 秒かかります。私は多くのことを調査しましたが、次の質問に対する答えはまだ見つかりません。

1. ブローカーがファイルを (完全に) キューに保管するようにするにはどうすればよいですか?
2. ObjectMessage (ファイルが小さいため) または blob メッセージを使用する必要がありますか?
3. コンシューマーの処理が遅いため、prefetchLimit を下げるか、ラウンドロビン ディスパッチ ポリシーを使用する必要がありますか? どちらの方がよいですか？
4. 最後に、ActiveMQ FAQ で、「コンシューマーがメッセージを受信し、閉じる前にそれを確認しない場合、メッセージは別のコンシューマーに再配信されます。」を読みました。ここでの私の質問は、ActiveMQ は 1 つのコンシューマーのみがメッセージを処理することを保証するか (したがって、プロデューサーへの回答は 1 つだけになるか) ですか? コンシューマーがメッセージを確認するのはいつですか (デフォルトの自動確認設定) - メッセージを受信して​​セッションに保存するとき、または onMessage ハンドラーが終了するとき? また、消費者の処理が非常に遅いため、「タイムアウト制限」を変更して、ブローカーが別の消費者に作業を渡す前にどれだけ待機する必要があるかを知る必要があります (これは私の以前の質問に関連しています)。

Zeromqドキュメントの「ARequest-ReplyBroker」を参照しています：http：//zguide.zeromq.org/chapter：all

私はアプリの一般的な要点を理解しています。それは仲介者のように機能し、クライアントからサーバーにメッセージをルーティングし、また元に戻します。

私が得ていないのは、サーバーからの正しい応答が、最初に要求を行った正しいクライアントに送信されることを確認する方法です。これを確認するコード例には何も表示されません。

この例では、1つのメッセージ（hello）と1つの応答（world）のみを送信するため、メッセージが混同されても問題ありませんが、testclientとサーバーは意図的に単純に保たれていると思います。

どんな考えでも大歓迎です...

特定のトピックのプロデューサーのメッセージをリッスンして代わりに処理するように変更された ActiveMQ ブローカーを作成したいと考えています (たとえば、デフォルトの永続ストアを使用せずに HDFS API を使用します)。どこから始めればよいか、何かアイデアはありますか?

前もって感謝します、ペトルッチ

私は、着信メッセージを継続的に処理する .NET サービスの計画段階にいます。これには、さまざまな変換、データベースの挿入と更新などが含まれます。全体として、サービスは巨大で複雑ですが、実行する個々のタスクは小さく、シンプルで明確に定義されています。

このため、将来の簡単な拡張を可能にするために、サービスをいくつかの小さなサービスに分割して、基本的に処理の一部を実行してからチェーン内の次のサービスに渡したいと考えています。

これを実現するには、あるサービスから別のサービスにメッセージを渡す何らかの中間メッセージング システムが必要です。チェーン内のリンクがクラッシュしたり、一時的にオフラインになったりした場合に、宛先がオンラインに戻ったときにメッセージがキューに入れられて処理されるように、これを実現したいと考えています。

私は常にこの種のメッセージ キューイングを使用してきましたが、最近、同様のことを行うと思われる SQL Service Broker を認識しました。SQLSB はこのシナリオの実行可能な代替手段ですか? もしそうなら、標準のメッセージ キューの代わりに SQLSB を使用することでパフォーマンス上の利点が見られますか?

ありがとう