問題タブ [messagebroker]

必要なのは、実際にはキューとして機能し、これを行わないRabbitMQです。クライアントがメッセージを明示的にデキューするまで、メッセージはキューの先頭に留まる必要があります。

非常に単純なシナリオのように見えますが、何らかの理由で、それをサポートするブローカーが見つかりません。ブローカーはWindowsOSで実行する必要があります。

（C）PythonとJava / JMSアプリケーションの両方をサポートするメッセージブローカーを介した通信に適したソリューションは何ですか？私の特定の要件は次のとおりです。

• オープンソースソリューション
• Linuxベースのシステムで利用可能
• 送信者と受信者の間のランデブーは必要ありません（つまり、メッセージブローカーを使用します）
• 1つのイベントキューでサポートされる複数のプロデューサーとコンシューマー（各メッセージを受信するのは1つのコンシューマーのみ）
• 2フェーズコミットによる作業単位のサポート（XAサポートがあると便利です）
• 永続メッセージのサポート（つまり、ブローカーの再起動後も存続します）
• JavaクライアントのJMSをサポート
• 「フリンジ」のコンポーネントはありません。つまり、コミュニティのサポートや関心がないためにメンテナンスから外れるリスクがあります。
• 「JMSを話す」ことができるPythonクライアントがある場合、それは素晴らしいことですが、独自のPythonJMSレイヤーを作成するタスクを含む回答は受け入れられます。

私はこれに対する解決策を見つけるのに驚くほど苦労しました。ApacheのActiveMQは、そのままではPythonをサポートしていません。ZeroMQにはランデブーが必要です。RabbitMQはJMSをサポートしていないようです。私が見つけた最良の候補は、ActiveMQとpyactivemqライブラリの組み合わせです。しかし、pyactivemqの最初と最後のリリースは2008年だったので、それは私の「フリンジなし」の要件を満たしていないように見えます。

理想的な答えは、Java / JMSとPythonアプリケーション間の通信に個人的に使用した、十分にサポートされ、十分に文書化された1つ以上のオープンソースパッケージの名前であり、取得するために多くの統合作業を必要としません。開始しました。上記のすべての要件を満たすための追加のグルーコードの「簡単な」（最大数日間の作業）実装を含む回答が受け入れられます。優れたオープンソース候補がない場合の商用ソリューションも受け入れられます。

また、Jythonも出ています。（私ができれば...）同じPythonアプリケーションは、CPythonでのみ利用可能なモジュールを使用する必要があります。

IBM WebSphere Message Broker (おそらく V6) を使用して、いくつかの CSV ファイルを使用し、いくつかの検証を実行してから、Java アプリケーションで使用するためにいくつかの Java オブジェクトを設定したいと考えています。これの多くは、FileInputNode を使用して csv ファイルを使用し、JavaCompute ノードを Java 関連のものに使用することで実現できると考えています。しかし、私が知りたいのは、どうすれば2つを接続できるのでしょうか? 私が考えている方法の 1 つは、csv ファイルを使用してから、Java ノードによって使用されるメッセージを作成することです。

アドバイスをいただければ幸いです。私は Message Broker についてあまり詳しくないので、無知であることをお許しください。ちなみに、WebSphere Message Broker を使用するという決定は私 (会社の標準) ではないため、これを達成する他の (より簡単な) 方法があるかもしれませんが、私は MQ Broker を使用することに固執しています。

アドバイスをいただければ幸いです。

前もって感謝します。

バズ

I'm in the process to plan for a messaging framework and I thought of using an AMQP product (RabbitMQ, OpenMQ, Apache Qpid... etc.) but while searching I found it hard to decide. the conditions of the network are as follows:

1. Topology: Fully-connected (or completely-connected)
2. Number of Servers: 4
3. Type of messaging: Topic Messaging - publish/subscribe

While reading about the AMQP products it was not so clear how they deal with infinite looping messages in a federation.

• Qpid: clearly states that an ad-hoc connection will cause the problem.
• RabbitMQ: wasn't so clear how to use federation.
• openAMQ: I feel that would solve my issue but still not sure and here comes my question!

openAMQ states a fully connected topology example here (as shown in the last figure in the link): http://www.openamq.org/tutorial:broker-federation

in another document of openAMQ the following statement appears:

http://www.openamq.org/doc:user-3-advanced#toc61

"Federated publish-subscribe creates extra hops when the publisher and subscriber are both on a child server. In this case, messages are sent first to the parent, root server and from there back out to all child servers that need them. This is how we avoid delivering the same message more than once. However it creates extra latency. We would normally put important publishers on the root parent server."

the first example causes message duplication but the second document talks about this as a limitation in a tree topology(as I did understand)!

now.. does openAMQ support a fully-connected network without causing looping messages or not? not could you recommend me a product that doesn't?

多対 1 の関係を持つ 2 つのテーブルがあります。(オラクル)

子テーブルと親テーブルに挿入されたレコードは同時に挿入されます。

私が疑問に思っているのは、これを行う最も効率的な方法は何ですか。

現在、この挿入ステップ全体で呼び出し側アプリケーションによって呼び出されるストアド プロシージャが 1 つあります。ストアド プロシージャには現在、次のシグネチャがあります。

このプロシージャは、入力から C をループし、各値を配列に格納します。次に、その配列を入力からの A および B と共に使用して、表 PARENT に挿入します。

次に、入力から A を使用し、入力から D と E をループして、区切り文字列の各項目に対してテーブル CHILD に挿入します。

これは、1 日あたり最大 300 万回呼び出されます。可能な限り効率的である必要があります。

1 つだけではなく複数の SP 呼び出しを行うと、どの程度効率が失われますか?

制限された文字列を処理するためのすべてのループは、大変な作業のように思えます。

呼び出し元のアプリケーションは、CHILD へのエントリごとに個別の SP 呼び出しを行うことができると考えていました。ただし、どのようにして CHILD への挿入が PARENT への挿入の前に行われないようにするにはどうすればよいですか? (多くの場合、挿入する子レコードはありません。ある場合、通常は 10 未満ですが、50 にもなる可能性があります)

また、dilimted 文字列 C で情報を取得する別の方法も開きます。

分割された文字列から情報を取得するために while ループよりも効率的なものはありますか?

私は SP を書きませんでした。小さな変更を加えて、可能であればより効率的にするように依頼されました。

何か案は？

ノート：

テーブルを単純化しました。実際には、拡張された文字列 C には 5 ではなく 10 の項目があり、テーブル PARENT に挿入される C のような拡張された文字列がさらに 2 つあります。テーブルには、示されている以外にもいくつかのフィールドがあります

記録は 30 日後に削除されます。

Oracleでパッケージを定義すると、ヘッダーとボディのようなものがあります。

両方の場所ですべてのパラメータを定義する必要があります。呼び出し側プログラム（IBMメッセージ・ブローカー）のパラメーターの1つをオプションにしたい。ヘッダーと本文の両方の定義にデフォルト値を追加する必要がありますか？

さらに、messagebrokerがデフォルトでパラメータの値を指定せずにprocを呼び出すことができることを誰かが確認できますか？

ありがとう！

更新：デフォルトを本文ではなくヘッダーに追加できるか、両方に追加できることに気付きました。体だけに入れることはできません。

両方に追加することとヘッダーだけに追加することの違いは何ですか？

アップデート：

これは、本体ではなく仕様でデフォルトのみを指定する場合に実行できます。または、両方の場所でデフォルトを指定することもできます。違いは何ですか？

会社の統合アーキテクチャのロードマップを定義しようとしており、アプローチに関するガイダンスを探しています。

当社のアプリケーションのほとんど (90 ～ 95%) は、Microsoft SQL Server 2008 を使用した .NET に基づいています。Salesforce にはセールス クラウドがあり、今後数年間でさらに多くのアプリケーションを (Force.com プラットフォームに) Salesforce に移行する予定です。オンプレミス アプリケーションを Salesforce と統合し、場合によってはオンプレミス アプリケーション内に統合するために、IBM Cast Iron を購入しました。既存のアプリケーションと既存の統合 (アドホック - SQL ジョブ、Windows サービスなど) を分析した後、アプリケーションと対話するために使用する方法が複数あることに気付いたので、ESB が必要であると感じました ( FTP、Web サービス、CSV/Excel、SQL)。Cast Iron はあらゆるタイプのフォーマットを取り、Web サービス、FTP などと話すことができますが、私は'

ESB を導入することで、少なくとも次のメリットが得られると思います。

• スケーラビリティ
• 信頼性
• ハイパフォーマンス

添付の図は、このシナリオを簡略化したものです。このアーキテクチャは、ESB で SOA を提供することにより、将来的に拡張することもできます。

今、私の懸念/質問は次のとおりです。

• Cast Iron はオーケストレーション ツールであるため、オーケストレーションにはどれを使用すればよいですか? Cast Iron ですか、それとも ESB ですか。
• Cast Iron は JMS/IBM MQ としか通信できず、Microsoft Message Queue と通信できません。では、Mule (Active MQ を使用) や Service Mix などの Java ベースの ESB を使用する必要がありますか?
• 信頼性が高く、最も広く使用されている .NET ベースの ESB (Microsoft Biztalk と NServiceBus 以外) のオプションは何ですか?
• 一括データ移動のベスト プラクティスは何ですか? 通常、これは SSIS を介して実行できます。私たちの場合、大量のデータを定期的にクラウドに移動する必要があるかもしれません。
• .NET アプリケーションから JMS ベースのメッセージ ストアにメッセージを発行する最良の方法は何ですか?

私はここで多くの質問をしたことを知っていますが、直接的な答えがあるかもしれないし、ないかもしれません. 先輩方のご意見をお聞かせいただければ幸いです。

メッセージ ブローカーによって作成された bar ファイルからプロパティ値を読み取ろうとしています。

Java経由でこれを行いたい。APIはここにあります：http://publib.boulder.ibm.com/infocenter/wmbhelp/v7r0m0/index.jsp?topic=%2Fcom.ibm.etools.mft.doc%2Fbe43410_.htm

ただし、配置記述子を使用して、値ではなくプロパティの名前を取得する方法しかわかりません。プロパティの値をオーバーライドする方法はわかりますが、値を取得する方法はわかりません。別の言葉では、プロパティから読み取るのではなく、プロパティに書き込む方法しかわかりません。両方やりたい！私を貪欲と呼んでください;）

コマンド ライン ベースのユーティリティを使用するhttp://publib.boulder.ibm.com/infocenter/wmbhelp/v7r0m0/index.jsp?topic=%2Fcom.ibm.etools.mft.doc%2Faf03900_.htm と、プロパティ値を問題なく取得できます。

しかし、可能であればJava経由で取得したいと思っています。

これについて何か助けてくれてありがとう！

Websphere Message Broker Toolkit 7 を使用しており、自動バー ビルドを作成しようとしています。

次のコマンドを実行しているときに、次のエラーが発生します。

これは他の場所で言及されているのを見ましたが、まだ解決策を見つけていません。このフローには Input Terminal ノードが含まれていることがわかります。

よろしく、

サパトス

簡単な MessageBroker フローを作成しています。MQInput Node -> Compute -> MQOutput Node に進み、すべての Compute は次のようになります。

CALL CopyEntireMessage(); SET OutputRoot.Properties.MessageFormat='XML1';

メッセージ形式を Binary1 から XML1 に変更するだけです。ただし、MQOutput ノードは失敗し、Failure 接続に沿ってメッセージを送信します。MQOutput ノードが失敗する理由がよくわかりません。