pyzmq

0熱

1答えて

zmqソケットを持つtcpサーバーを作成したいと思います。次のコードは、Pythonのasyncioのioloopを使ってzmqソケットを使ってtcpサーバーを作成します。次のコードでは、着信接続を待機するzmqソケットを作成しています。コルーチンrecv_and_processは、接続をリッスンし、着信接続に応答するwhileループを持つソケットを作成します。私の質問は、whileループを排

1熱

1答えて

なぜこの非同期コードが停止しないのですか？

次のコードスニペットには、サーバーとクライアントの2つのコルーチンがあります。クライアントコルーチンには、10秒後にwhileループを切断するロジックがあり、15秒後にサーバーが停止する必要があります。スクリプトを実行すると、これは停止しません。理想的には、15秒後に停止する必要がありますが、これは起こっていません。あなたは、コードを実行した場合 import asyncio import t

1熱

1答えて

"middlend"インターフェースを備えたZeroMQプログラムを設計する

私はZeroMQを初めて使用しているので、この種の質問には申し訳なく思っています。また、暗証番号ZeroMQのマニュアルを読んで、テストケースを書くと、私のプログラム。私の最初のバージョンはROUTER（フロントエンドとして）とDEALER（バックエンドとして）を使用していました。以下を参照してください： [ clients N] --> [ Frontend ] --> [ Backend ]

0熱

1答えて

ZMQのbind_to_random_portは期待通りに動作しない

I持って次のコード： context = zmq.Context() socket = context.socket(zmq.PAIR) communication_string = "{protocol}".format(protocol='tcp://*:') port = socket.bind_to_random_port(communication_string, min_po

0熱

1答えて

同じポートにバインドされた複数のZMQサーバにIDを設定する

Python 3.4でZMQ DEALER-ROUTERパターンを実装しています。このcode from ZMQ guideは私のプログラムの中核です。各クライアントの識別情報を簡単に設定します（例1,2,3,4）。しかし、同じ数のサーバーワーカーを起動すると、クライアントとペアになっていません。 1人のサーバーワーカーが、異なるIDを持つクライアントに応答する場合があります。質問：サーバーワ

6熱

2答えて

Windows 10でJupyterのノートブックのpythonクラッシュ

私は週を探索し、運がない別のソリューションを試してみました。私は1年以上前に戻って同じ問題を抱えているいくつかの他の人を見ました。問題：のWindows 10はプロ私は、Python 3.6.2と最新のアナコンダ5ビルドを使用していますし、すべてのパッケージが最新に更新されている15063.674 構築します。 Jupiter Notebookを実行すると、しばらくすると、「pythonが動作

1熱

1答えて

aiozmq/zmqを正しく閉じるには？

バックエンドが実行されていないときにこの問題に遭遇しました。あなたがここに私の場合を再現するために、本当に簡単なデモを見つけることができます（あなたには、いくつかの時間のテストを保存したい場合は、1にタイムアウトを減らすことができます）： #!/usr/bin/env python3 import threading import logging import asyncio from

3熱

1答えて

バイト配列を文字列とバックに変換する

私のpythonバックエンドは、'\x00k\x8bEg'のようなバイト配列をIDとして使用します。私は、この操作を元に戻すと、私を取り戻すしたいと思い006b8b4569 ：正しく私のnodejsフロントエンドでそれらを表示するために、私は怒鳴る hex_data = binascii.hexlify('\x00k\x8bEg') text_string = hex_data.decode('

0熱

1答えて

ZeroMQ：PAIRソケットが使用しているポートを見つける方法は？

接続後にZeroMQ（実際にはpyzmq）ポートに接続されているポートを確認する方法はありますか？例えば ... import zmq context = zmq.Context() socket = context.socket(zmq.PAIR) port = socket.bind_to_random_port("tcp://*") # some other code that mi

1熱

1答えて

Pythonマルチプロセッシングクラス/オブジェクトソリューションでZeroMQがハングアップする

Python（pyzmq）でZeroMQをマルチプロセッシングと併用しようとしています。 minmal（ない）の動作例として、私はサーバクラスとクライアントクラスの両方がmultiprocessing.Processから継承されています。子プロセスとして、クライアントのメッセージを印刷する必要があり、サーバ子プロセスにメッセージを送信する必要があります：私はこれを実行する場合 #mpzmq_cla