問題タブ [producer]

C++ コンポーネントと Java コンポーネントの間で 2 つのプロセスで通信するメッセージ ブローカーとして ActiveMQ を使用したいと考えています。例えば。C++ コンポーネントがパブリッシャーで、Java コンポーネントがサブスクライバーです (複数のサブスクライバーが存在する場合もあります)。ActiveMQ Web サイトを見ると、ツール OpenWire と ActiveMQ-CPP について言及されています。ただし、Web サイトのすべての例では、生産者と消費者の両方に同じ言語を使用しています。

私の質問は次のとおりです。

1.ActiveMQ は異なる言語のプロデューサー/コンシューマーに対して機能しますか?

2.異なるプロセスで？どのように？

私は2つのプロセスを持っています:

共通にマッピングされたメモリの共有領域があります

これで、Producer はメモリにデータを書き込みます。コンシューマはメモリからデータを読み取ります。

どうすればこれを達成できますか?

Apache（mod_wsgi、prefork）によって提供されるPylonsWebアプリケーションがあります。Apacheが原因で、アプリケーションコードを同時に実行する複数の個別のプロセスがあります。「ライブ」応答時間を改善するために、アプリケーションがバックグラウンドで処理するために延期したい重要ではないタスクのいくつか。だから私はタスクキューについて考えています。多くのApacheプロセスがこのキューにタスクを追加し、単一の別個のPythonプロセスがそれらを1つずつ処理してキューから削除します。

キューは、停電やサーバーの再起動などによってキューに入れられた未処理のタスクが失われないように、ディスクに永続化することが望ましいです。問題は、そのようなキューを実装するための合理的な方法は何でしょうか。

私が試したことについては、単純なSQLiteデータベースと、キュー項目を格納するための単一のテーブルから始めました。負荷テストで、同時実行性のレベルを上げると、予想どおり「データベースロック」エラーが発生し始めました。迅速な「n」ダーティな修正は、SQLiteをMySQLに置き換えることでした。並行性の問題をうまく処理しますが、私がしなければならない単純なことにはやり過ぎのように感じます。キュー関連のDB操作も、プロファイリングレポートに目立つように表示されます。

何かを使用して、それぞれが異なるオペレーティングシステムの異なるマシンで実行されている複数のコンシューマー/プロデューサーとシステムを調整する必要があります。私はこれを行うためにMySqlを使用することを研究してきましたが、それは途方もなく難しいようです。

私の要件は単純です。消費者/プロデューサーをいつでも追加または削除できるようにしたいので、相互に依存するべきではありません。当然、データベースは2つをうまく分離します。

MySql用のQ4Mメッセージキュープラグインを見てきましたが、使用するのが複雑なようです。

システムを可能な限り最適に構築する方法について、いくつかの情報が本当に必要です。

私は生産者/消費者の問題、特にバウンドバッファバージョンを解決するプログラムを書いています(私はそれらが同じことを意味すると信じています)。プロデューサーは x 個の乱数を生成します。x はプログラムのコマンド ライン パラメータです。現時点では、プログラムが無限ループに陥っていると思いますが、なぜそれが発生しているのかはわかりません。セマフォを正しく実行していると思います。

次のようにコンパイルします: gcc -o prodcon prodcon.cpp -lpthread -lrt 次に、./prodcon 100(生成する乱数値の数) を実行します。

これは私のコードです。

以下のプログラムをコピーして、IDE で実行してみてください。これは単純な Produce Consumer の実装です。1 つの Producer スレッドと 1 つの Consumer スレッドを使用すると問題なく動作しますが、それぞれ 2 つ使用すると失敗します。このプログラムがハングする理由を教えてください。または、他に何か問題があるのでしょうか。

activemq で単一のコンシューマーの複数のプロデューサーを実装する方法についてのリファレンスを指摘できる人はいますか? または、非常に単純な実装を提供できます。これは非常に役立ちます。

ありがとう

スタンドアロンの Java Web アプリケーションから WSRP インターフェイスを生成して、スタンドアロンのフロントエンドとバックエンド以外に、ポータル (Liferay、IBM websphere ポータル) にフロントエンドを埋め込むことができるようにするつもりです。

これを達成するための推奨される方法は何ですか? 仕事をしていると思われる WSRP プロデューサー Java ライブラリーを見つけることができません。WSRP プロバイダー、コンシューマー、およびポートレットの仕様をネイティブにサポートするため、WSRP の一般的な方法は、それらの間でポータルをリンクしているようです。

ご協力いただきありがとうございます、

Android/DalvikVM でハンドラーがどのように処理されるのか疑問に思っています。私は Android 用のアプリケーションを作成しています。あるクラスには、別のクラスからメッセージを受け取る Handler メソッドがあります。Handler メソッドは Thread として機能し、同じクラスの run() メソッドに対して非同期になりますか、それとも run() メソッドのコード行が完了するまで待機しますか (一種のアトミック操作)? または、他の何か？

Handler メソッドでメッセージをキューに追加し、run() メソッド (プロデューサー-コンシューマー) でメッセージを処理および削除したいので、疑問に思っています。

私のコード構造:

ハンドラーのコードはいつ実行されますか? run() メソッドのコードはどこかで中断されますか? バッファが破損しないように、run() およびハンドラ メソッドのコードの周りに、同期やセマフォなどを用意する必要がありますか?

プロデューサーとして機能しているときに、Jboss Portal 2.7.2 で WSRP URL 書き換えがサポートされているかどうかを知っている人はいますか?

現在、URL の書き換えはコンシューマーで行われ、特別な WSRP トークンを見つけるために (Jboss から返された) マークアップを解析する必要があります。これはパフォーマンスに影響を与える可能性があり、URL をプロデューサー (この場合は Jboss) に直接提供することで改善できます。

よろしく、ジョナサン