txzmq Draaide bindingen voor ZEROMQ
Download nu

txzmq Rangschikking & Samenvatting

txzmq Tags

Python-bibliotheek Gedraaid bindingen ZeroMQ sockets Twisted bindingen ZeroMQ

txzmq Beschrijving

Gedraaide bindingen voor ZEROMQ TXZMQ is een Python-bibliotheek die het mogelijk maakt om gemakkelijk ZEROMQ-aansluitingen in gedraaide gebeurtenislus (reactor) te integreren .TXZMQ Introduceert ondersteuning voor algemene ZEROMQ-aansluitingen per klas ZMQConnection die de integratie van de basisgebeurtenis van de gebeurtenislus, het ontvangen van berichten op niet-blokkerende wijze kan verzenden, verzamelen voor Multipart-berichten. Speciale afstammelingen van die klasse, ZMQPUBCONNECTION en ZMQSUBCONNECTIE Voeg speciale leuke functies toe voor pub / sub-aansluitingen. Andere socketypes kunnen gemakkelijk worden afgeleid van ZMQConnection, behalve voor Req / Rep-aansluitingen, omdat het antwoord mogelijk moet worden verzonden Direct na ontvangst van het bericht (momenteel zal ZMQConnection proberen alle beschikbare bericht te lezen en in de wachtrij-berichten in parallel te lezen) .Example: import sysfrom optparse import optionParserFrom twisted.Internet importreactor, deferfrom twisted.python import logobserver = log.filelogobserver (Sys.Stderr) Log.addobserver (Observer.emit) Parser = OptionParker ("") Parser.ADD_OPTION ("- M", "--method", Dest = "Methode", Help = "0MQ-aansluiting Aansluiting: Bind | Connect ") PARDERER.ADD_OPTION (" - E "," - DUNDPOINT ", DEST =" ENDPOECT ", HELP =" 0MQ ENDPOINT ") PARDERER.ADD_OPTION (" - M "," - MODE ", Dest = "Modus", Help = "Modus: uitgever | abonnee") parser.set_defaults (methode = "verbinden", eindpunt = "EPGM: // eth1; 239.0.5.3: 10011") (opties, args) = parser. PARSE_ARGS () van TXZMQ import ZMQFACTORY, ZMQENDPOINT, ZMQPUBCONNECTION, ZMQSUBCONNECTIONIMPORT TIMEZF = ZMQFACTORY () E = ZMQendpoint (opties.method, options.endpoint) als opties.mode == "Uitgeverij": S = ZMQPUBCONNECTION (ZF, E) Def Publiceer (): Data = Str (Time.Time ()) Print "Publiceren% R"% gegevens S.Publish (data) reactor.calllater (1, Publiceren) Publiceren () anders: S = ZMQSUBCONNECTIE (ZF, E) S. Abonneren ("") Def DoPrint (* AGS): Print "Bericht ontvangen:% R"% (args,) S.Gotmessage = DoprintREACTOR.Run () Vereisten: · Python · ZeromQ-bibliotheek> = 2.1 (zwaar getest met 2.1.4) · Pyzmq · Twisted

txzmq Gerelateerde software