 | txzmq.Verdrehte Bindungen für Zeromq |
| Jetzt downloaden | |
txzmq. Ranking & Zusammenfassung
Anzeige
txzmq. Stichworte
txzmq. Beschreibung
Verdrehte Bindungen für Zeromq TXZMQ ist eine Python-Bibliothek, mit der Sie einfache Zeromq-Steckdosen in verdrehte Ereigniskreislauf (Reaktor) integrieren können. TXZMQ stellt Unterstützung für allgemeine ZeromQ-Sockel von der Klasse ZMQConnection ein, die eine grundlegende Ereignis-Schleifen-Integration durchführen können, sendet das Empfang von Nachrichten in nicht blockierender Weise, Sammeln Sie für Multipart-Nachrichten. Spezieller Nachkommen dieser Klasse, ZMQPUBCONNECTION und ZMQsubConnection Fügen Sie spezielle nette Funktionen für PUB / SUB-Sockel hinzu. Andere Socket-Typen können leicht von der ZMQConnection abgeleitet werden, mit Ausnahme von REQ / Rep-Buchsen, die möglicherweise mehr Arbeit erfordern, da die Antwort sendet Unmittelbar nach der Empfangsmeldung (derzeit wird ZMQConnection versucht, alle verfügbaren Nachrichten zu lesen und Warteschlangennachrichten in Parallel zu lesen log.addobserver (Observer.EMIT) Parser = OptionParser ("") parser.add_option ("- m", "--method", dest = "Methode", Hilfe = "0MQ Sockel" Anschluss: binden | verbinden ") parser.add_option (" - e "," --endPoint ", dest =" Endpoint ", Hilfe =" 0MQ Endpoint ") parser.add_option (" - m "," --mode ", dest = "MODE", HELP = "MODE: Publisher | Subscriber") parser.set_defaults (Methode = "Connect", Endpoint = "EPGM: // ETH1; 239.0.5.3: 10011") (Optionen, Args) = Parser. parse_args () ab TXZMQ-Import ZMQFactory, ZMQendPoint, ZMQPUBCONNECTION, ZMQsubconnectionImport TimeZF = ZMQFactory () E = ZMQendPoint (Optionen (): data = str (time.time ()) drucken "Publishing% r"% data s.Publish (Daten) reaktor.calllater (1, Publish) Publish () sonst: s = zmqsubconnection (ZF, E) s. Abonnieren ("") Def Doprint (* Args): drucken "Message erhielt:% r"% (args,) s.gotmessage = doprintreactor.run () Anforderungen: · Python · Zeromq-Bibliothek> = 2.1 (stark getestet mit 2.1.4) · Pyzmq. · Verdrehte
txzmq. Zugehörige Software
