 | TXZMQゼロームのねじれの結束 |
| 今すぐダウンロード | |
TXZMQ ランキングとまとめ
広告
TXZMQ タグ
TXZMQ 説明
ゼロームのためのねじれの結束 TXZMQは、簡単にZEROMQソケットをチープルのツイストイベントループに統合することを可能にするPythonライブラリです.TXZMQは、基本的なイベントループ統合、非ブロッキング方式での送受信メッセージ、散布を行うことができるクラスZMQConnectionによって一般ZEROMQソケットをサポートします。 Multipart Messages用に収集。そのクラスの特別な子孫、ZMQPUBConnection、およびZMQSUBConnectionは、PUB / SUBソケットに特別な素晴らしい機能を追加します。その他のソケットタイプは、応答を送信する必要があるので、より多くの作業を必要とする可能性があるREQ / REPソケットを除いて、ZMQConnectionから簡単に導き出すことができます。メッセージを受信する直後（現在ZMQConnectionは、使用可能なすべてのメッセージを並行して読み取ろうとします）.example：optparseインポートoptionParserFrom Twisted.Internetインポートリアクトル、Twisted.PythonインポートLogoBserver = log.FileLogobServer（sys.stderr） log.addobserver（observer.emit）parser = optionParser（ ""）parser.add_option（ " - m"、 " - method"、dest = "method"、help = "0mqソケット接続：bind | connect "）parser.add_option（" - e "、" - endpoint "、dest =" endpoint "、help =" 0mqエンドポイント "）parser.add_option（" - m "、" --mode "、 dest = "mode"、help = "mode：publisher | subscriber"）parser.set_defaults（method = "connect"、endpoint = "epgm：// eth1; 239.0.5.3：10011"）（オプション、args）=パーサー。 TXZMQのimport ZMQFactory、ZMQENDPOINT、ZMQPUPCONNECTION、ZMQSUBCONCONETIMPORT TIMEZF = ZMQFFARTORY（）E = ZMQENDPOINT（options.method、options.Endpoint） （）：data = str（time.time（））印刷 "publishing％r"％データs.publish（データ）Reaulter.calllater.Calllater（1、publish）publish（）Publish（）：s = zmqsubConnection（zF、e）s。 subscribe（ ""）DEF DOPRINT（* ARGS）：印刷 "メッセージ受信：％R"％（args、）s.gotmessage = doprintReactor.run（）要件： ・Python ・ZEROMQライブラリー> = 2.1（2.1.4で重くテスト済み） ・Pyzmq. ・ねじれた
TXZMQ 関連ソフトウェア
