zeromq

1熱

1答えて

私のマシンにはzmqバージョン4.1.3とpyzmqバージョン15.2.0がインストールされています（私はpip経由ですが、今は覚えていません）。 UDP epgmソケットに接続する必要がありますが、 "プロトコルはサポートされていません"というエラーが表示されます。私はインターネットの広大な広がりを探して答えを見つけました： "--with-pgmオプションでゼロmqを構築する"。誰でもその方

1熱

1答えて

適切なPHPバックグラウンドプロセスを作成するには？

linuxコマンドnohup php filename.php &を使用して、バックグラウンドのPHPプロセスを作成しています。ここでの問題は、filename.phpに含まれるファイルやファイル自体に変更があった場合、現在のプロセスを強制終了して再開する必要があることです。これを防ぐ方法はありますか？私のアプリケーションでは、（プロセスを強制終了して再起動するために）ダウンタイムが必要ないので、

3熱

1答えて

ZeroMQ C++クライアントが受信していません

最近、Pupilアイトラッカーで新しいプロジェクトを開始しました。追加のクライアントに追跡情報をブロードキャストするには、ZeroMQを使用します。私は自分のサーバーが正しく彼らのシンプルなPythonクライアントの例を試みることによって実行されていることを確認しました： import zmq import json #network setup port = "5000" contex

0熱

1答えて

rqワーカーの中でZMQを使用する

python-rqのワーカータスク内にzmqソケットを設定しようとしています。私は仕事関数内contextを作成する場合： def push(user, task_id, data): """Push message to `user` over websocket. """ ctx = zmq.Context() pub = ctx.socket(z

0熱

1答えて

C＃ZeroMQでメッセージからデータを抽出するには？

C++からC#にデータを送信する必要があります。 C++側は、Linuxでは、私はZMQライブラリversion 4.1.4を使用しています。 C#側は、4.1.5 versionに基づいてclrzmq4ライブラリを使用しています。だから私はC++にメッセージを送信する一部：メッセージを取得するための char tempStr[] = "ABCD"; zmq_msg_t zmsg; zmq

0熱

1答えて

"sleep"が削除されたときにZMQ、PUB/SUBのメッセージが失われる

SQLiteデータベースからメッセージをプッシュする小さなコードスニペットがあります（共有オブジェクトファイルとしてインポート）。 zMQは行ID、テーブル名などのデータをプッシュするために使用されますが、コードから「スリープ」が削除されたときに通信に問題があります。コードスニペットは、sqliteデータベースクライアントに適合する構造を持っています。 void callback (void *

3熱

1答えて

ZeroMQの共通のlispバインディング

私はLispを初めて使っていて、勉強しようとしています。特に、ZeroMQライブラリを使用して分散システムを作成しようとしています。これは私の探索コードREPLで ;;hwserver.lisp (defun main() ;; prepare contexts (zmq:with-context (context) (zmq:with-socket (socke

2熱

1答えて

sparkのストリーミングウィンドウタイムスタンプを取得

Spark-streamingを使用して、特定の間隔でゼロMQキューからデータを受信し、それを豊かにして寄木細工ファイルとして保存します。タイムスタンプに特定のストリーミングウィンドウを見つけるにはどうすればよいですか？比較を容易にするためにエンリッチメント中に別のフィールドとして追加することはできますか？いいえ、ストリーミングウィンドウのデータを比較します。私は、各ストリーミングウィンドウのタ

1熱

1答えて

JSONオブジェクトをZmq経由でC++クライアントで送信 - Pythonサーバー

私は、C++クライアントとPythonサーバーを使ってJeromqを使ってJsonオブジェクトを交換しようとしています。 server.py import zmq import json context = zmq.Context() socket = context.socket(zmq.REP) socket.bind("tcp://*:5555") while True:

0熱

1答えて

PythonでZMQ：ZMQの各着信接続のための新しいソケットオブジェクト

ソケットは単にインターフェースにバインドし、このように、すぐにメッセージを受信することができますされています socket.bind("tcp://*:5555") message = socket.recv() 複数の接続がにデータを送信することができるので、そのソケットを同時に、どのように別の送信者を区別する？一方正規ソケットと、着信接続が最初にこのような新しいソケット、スポーンれ、受