zeromq

0熱

1答えて

私は自分でZeroMQを勉強しています。私はPUBをサーバー（バインド）、SUBをクライアント（接続）としてテストして正常に動作しました。反対（クライアント（接続）としてのPUB、サーバー（バインド）としてのSUB）も正常に動作します。クライアントとして別のSUBソケットを接続すると、例外やエラーが発生して何かがうまくいかなくなります。ここは私のコード例です。 #include <zmq.h

1熱

1答えて

ZMQ：複数の同時リクエストとポーリングでREQ/REPが失敗する

ZeroMQで奇妙な動作が発生しましたが、私は今一日中デバッグしようとしています。問題を再現する最小限のスクリプト例です。これはPython3で実行できます。 REPソケットを持つ1台のサーバが起動し、REPソケット付きの5台のクライアントが基本的に同時に接続します。その結果、最初のいくつかのメッセージの後に何らかの理由でサーバーがブロックされ始めます。 poller.poll(1000)は無期

0熱

2答えて

zmqパイソンはC++を公開私はのpython3中とZeroMQの加入者（<strong><code>zhelpers.hpp</code></strong>を使用して）<code>c++</code>でZeroMQの出版社を持っている

をサブスクライブします。問題は、サブスクライバにメッセージが記録されていないことです。 ZeroMQフィルターに問題があると思います。私は、c++に.setsockopt()を正しく使用してpythonパブリッシャーからのメッセージを受け取る方法を理解できません。 Pythonの出版社： import zmq context = zmq.Context() socket =

0熱

1答えて

ソケットを閉じた後、ZeroMQがメッセージの待機をブロックしないようにするにはどうすればよいですか？

この小さなテストスクリプトは私の問題を示しています。それは、メッセージを送信し、すべてのソケットを閉じて、ただ待って、終了することはありません。 ZMQ_LINGERを0に設定すると、キューに入れられたすべてのメッセージがすぐに破棄されるはずなので、なぜNode.jsプロセスを終了させることができないのですか？ const zmq = require('zmq') const bindUrl

0熱

1答えて

czmq： "PUB/SUB + security"のコード例を検索

私はこの記事の後ろに「http://hintjens.com/blog:49」と書いてあります。 "stonehouse"のテストコードは "PUSH/PULL"を使用し、 "PUB/SUB"を使用するように修正しようとしています。しかし、私の初期の素朴な試みは失敗します（プッシュ/プルのために働く以下のコード）。私が見逃したことはありますか？ところで、czmqは本当にPUB/SUBで動作しますが

2熱

1答えて

クラスZMQContextが見つかりません

私はUbuntu 14.04の仮想マシン内でnginx 1.4.6およびphp 5.5上でWebサーバーを実行していますので、ZeroMQ拡張機能をインストールする必要があります。私は（UNIXライクなシステムに構築するにはセクション）ZMQ上の指示に従っている、PHPの私のバージョンに対してそれをコンパイルし、指示hereのような結合PHP言語を追加して/etc/php5/cli/php.ini

0熱

1答えて

ZMQ_SUB（フィルターなし）でZMQ_CONFLATEが機能しない

私はzeromq-4.1.4ライブラリーとcppzmqをリアルタイム高速サーバーと低速クライアントにインストールしています。クライアントとサーバーの両方に、パブリッシュとサブスクライブ用の2つのポートがあり、TCP-IP経由で通信します。サーバーは、それ自身の速い速度でメッセージを送信します。クライアントは最新のメッセージを受信し、計算が遅くなり、メッセージをサーバーに戻します。受信したメッセ

1熱

1答えて

ZMQからのメッセージでPopenからstdoutをrecv

subprocess.Popenとzmqソケットからstdout/stderrをポーリングするベストプラクティスの方法はありますか？私の場合、私の主なプログラムはPopenサブプロセスを生成しています。サブプロセスはzmq経由でメッセージを発行します。私はメインプログラムで購読します。 zmq.Pollerでは複数のzmqソケットで待機していますが、これをサブプロセス自体の出力とインターリーブし

2熱

1答えて

C＃のCurveZMQの例とCurveZMQを使用するときにSetOption（）をCURVE_SECRETKEYに使用できないのはなぜですか？

CurveZMQを使用して、クライアントとサーバー間の通信のための安全な認証と機密性を確保します。しかし、私はC＃で例を見つけることができません。私はAPIドキュメントをステップバイステップで実行しようとしています。そして、CURVE_PUBLICKEY、CURVE_SECRETKEY、およびCURVE_SERVERKEYの設定で問題が発生しました。ここに私のコードです。 \ R \ ZeroM