 | txzmq.ارتباطات ملتوية ل Zeromq |
| التحميل الان | |
txzmq. الترتيب والملخص
الإعلانات
txzmq. العلامات
txzmq. وصف
ارتفاعات ملتوية لزراعة TXZMQ هي مكتبة Python تسمح بإدماج مآخذ Zeromq بسهولة في حلقة الحدث الملتوية (مفاعل). TXZMQ يقدم الدعم لمقابس Zeromq العامة بواسطة Class ZMQConnection التي يمكنها القيام بدمج حلقة الحدث الأساسي، ورسائل المرسل التي تلقيها بطريقة غير حظر، مبعثرة اجتمع من أجل الرسائل متعددة الأجزاء متعددة الفئة، ZMQPubConnection و ZMQSubConnection إضافة ميزات مميزة لطيفة لحانة / Sub Sockets. يمكن أن تكون أنواع مأخذ توصيل أخرى بسهولة من ZMQConnection باستثناء مآخذ REQ / REP التي قد تتطلب المزيد من العمل، كما يجب أن يرسل الرد على الفور عند تلقي الرسالة (حاليا ZMQConnection سيحاول قراءة جميع الرسائل المتاحة والكتابة رسائل في قائمة الانتظار بالتوازي). إعماد: استيراد Sysfrom OptPlse استيراد OptionParserFrom ملتوية. LOG.ADDOBSERVER (OBSERVER.EMIT) Parser = OptionParser ("") parser.add_option ("- m"، "- method"، dest = "الطريقة"، مساعدة = "0mq المقبس الاتصال: BIND | Connect ") Parser.add_option (" - E "،" - - نقطة "، dest =" نقطة النهاية "، مساعدة =" 0mq EndPoint ") parser.add_option (" - m "،" - m "، dest = "الوضع"، مساعدة = "الوضع: الناشر | المشترك") Parser.Set_Defaults (الطريقة = "Connect"، ENDPOINT = "EPGM: // eth1؛ 239.0.5.3: 10011") (خيارات، Args) = محلل. parse_args () من txzmq استيراد zmqfactory، zmqendpoint، zmqpubconnection، zmqsubconnectionimport timezf = zmqfactory () e = zmqendpoint (خيارات. method، options.endpoint) إذا كانت الخيارات. method == "publisher": s = zmqpubconnection (zf، e) def نشر (): البيانات = Str (Time.time.time.time ()) طباعة "Publishing R" بيانات S.Publish (البيانات) Reactor.calllater (1، نشر) نشر () آخر: S = ZMQSubConnection (ZF، E) S. اشترك ("") Def Dopint (* Args): طباعة "الرسالة المستلمة: R" (Args،) S.Gotmessage = DORINTREACTOR.RUN () المتطلبات: بيثون مكتبة Zeromq> = 2.1 (اختبار بشدة مع 2.1.4) pyzmq. الملتوية
txzmq. برامج ذات صلة
