問題タブ [zeromq]

クラスター全体に負荷を分散するパイプラインをセットアップする場合、メッセージが送信される場所をログに記録したいと考えています。これは私が考えていることです（python）：

しかし、私はこれについて話しているものを見つけることができません。どんな助けでも大歓迎です。

私の無知を失礼しますが、node.jsとZeroMQの（何かのような）概要は何ですか？

ZeroMQ で永続化を管理するのは誰ですか?

Python 言語で ZeroMQ クライアントを使用する場合、永続化を管理するために使用できるプラグイン/モジュールは何ですか?

ZeroMQ を使用するパターンを知りたいです。

This is related to an earlier question I had asked about what sort of middleware one can use for developing a client/server app.

Among the options suggested, I was intrigued by zeroMQ and its capabilities.

Since morning, I have been researching on using zeroMQ for my application. However, since my client is a Adobe AIR/FLEX, I see a steep curve in using zeroMQ since there are no bindings available for actionscript.

Google search shows a popular client called STOMP that can be used for messaging in flex based applications but there doesn't seem to be any STOMP adapter for zeroMQ either.

This leaves me with other alternatives such as RabbitMQ or ActiveMQ (since they both seem to have STOMP adapters) as possible middleware choices.

How hard/easy it is to develop to stomp adapter for zeroMQ? I hardly found any documentation on writing an adapter. Or is it worth writing an adapter for zeroMQ than focus on, say, using RabbitMQ that supports STOMP.

Finally, what are other popular alternatives to STOMP for Flex on the client side and leverage zeroMQ on the middleware part.

Thanks Dece

アプリのスケーリングを改善するために何ができるかについての私の絶え間ない学習曲線の一部として、私は現在、キューイングの方向性を見つけようとしています。つまり、ジョブキューイングまたはワークロード処理のどちらか好きなフレーズです。

遠い昔、私は IBM MQ/Series を使用していました。これは金融アプリで機能しましたが、思い出すと非常に重かったです。

私は MSMQ を知っていますし、他にもかなりの数の MSMQ について聞いたことがあります。

しかし、最初に、ここに私のコンテキストがあります

AJAX呼び出しなどを介してJavascript（主にjQueryなど）のフロントエンドにデータなどを提供するC＃/ .NETバックエンドWebアプリがあります。特定のアクションにいくつかのファイルのアップロード、いくつかのレコードの設定が含まれる状況がありますデータベースへのエントリ、一部のユーザーへのメール送信など。もちろん、時間の遅延が発生する可能性があるため、このプロセスを「オンライン」/「リアルタイム」にしたくありません。Webサーバー/データベースなどのオーバーヘッドがあると確信しています.

では、キューに入れて処理する必要がある「メッセージ」の種類を考えると、(ここで簡単に言うべきではないと思いますが!) 良い出発点は何でしょうか? MSMQ や SQL 2008 サービス ブローカ、または ZeroMQ などを使用して実行する必要がありますか? それとも、単純に独自の軽量ワークロード キュー サービスを作成する必要がありますか?

全体像を見ないと完全な推奨事項を作成するのは難しいことを改めて認識しましたが、出発点はありがたく受け取りました!

デビッド

ZeroMQガイドの図41で定義されている標準のLRUキューを使用していますが、消えたエンドポイント（サーバーのクラッシュ、OOMキラー、これらの線に沿ったもの）にメッセージを送信しないように、保護を追加する方法を考えています。 ）。

ドキュメントから、XREPは、存在しないエンドポイントに送信される場合にメッセージをドロップするだけであり、そのことについて通知を受ける方法がないことを読みました。そのような通知を受け取る方法はありますか？最初に「ping」を送信する必要がありますが、応答がない場合、その「ワーカー」は私にとって死んだ肉です。メッセージが返されるのは、pingを送信したのと同じクライアントであることをどうやって知ることができますか？

それとも、私のユースケースはZeroMQに適していませんか？メッセージが受信されたことを確認したいだけです。知らないうちにメッセージが床に落とされたくないのですが...

ZeroMQマルチスレッド C++ サーバーの例を実行しようとしています。

OS X 10.6.5、gcc バージョン 4.2.1 (Apple Inc. ビルド 5664)、および zeromq2 の最新のマスター ブランチ (12 月 1 日) を使用。ただし、サーバーを起動した直後にランタイム エラーが発生します (./server を使用)。

ブログで提供されているコードは最新ではありませんか? または、設定を間違えましたか？それ以外の場合、このマシンでは ZMQ が正常に機能しているようです (単純な要求/応答ソケット パターン)。

私はZeroMQを試し、何かを機能させようとしています。私が最初に考えたのは、inprocトランスポートを使用してREP / REQを設定し、2つのスレッド間でメッセージを送信できるかどうかを確認することでした。以下のコードのほとんどはclzmqの例から取られていますが、機能していないようです。

サーバーとクライアントの両方がトランスポートにバインドされていますが、クライアントがそれを実行しようとすると、Sendブロックされてそこにとどまります。私はZeroMQの経験がないので、最初にどこを見ればよいかわかりません。助けていただければ幸いです。問題のある（攻撃的な）コードは次のとおりです。

編集：

私は以下の答えの助けを借りてこれを機能させましたが、ローカルトランスポートにバインドするサーバーとリモートトランスポートに接続するクライアントがBindあるConnectので、これを考えると意味があります。更新されたコードは次のとおりです。

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

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

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

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

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

これに適したパターンは何ですか？複数のコンテキスト？メッセージのすべてのパターンが組み立てられて同期されるまで待機しますか？