txzmq

Enlaces retorcidos para Zeromq
Descargar ahora

txzmq Clasificación y resumen

Anuncio publicitario

  • Rating:
  • Licencia:
  • GPL
  • Nombre del editor:
  • Andrey Smirnov
  • Sitio web del editor:
  • http://smira.ru

txzmq Etiquetas


txzmq Descripción

Enlaces retorcidos para Zeromq TXZMQ es una biblioteca de Python que permite integrar los sockets de Zeromq fácilmente en el bucle de eventos retorcido (Reactor) .TXZMQ introduce el soporte para los sockets generales de Zeromq por Clase ZMQConnection que puede realizar la integración básica de la bucle de eventos, el envío de mensajes de recepción en la manera no bloqueadora, dispersión- Reúnase los mensajes multipart. Los descendientes especiales de esa clase, ZmqpubConnection y ZMQSubConnection agregue características especiales para Pub / Sub Sockets. Otros tipos de zócalos podrían derivarse fácilmente de ZMQConnection, excepto para los sockets req / representantes que pueden requerir más trabajo, ya que la respuesta debe ser enviada Inmediatamente después de recibir el mensaje (actualmente, ZMQConnection intentará leer todos los mensajes disponibles y escribir mensajes en cola en paralelo). Ejemplo: Importar Sysfrom Option OptionParserfrom Twisted.internet Importar reactor, Deferfrom Twisted.python Importar logobserver = log.filelogobserver (sys.stderr) log.addobserver (Observer.Emit) Parser = OptionParser ("") parser.add_option ("- M", "--Method", Dest = "Método", Ayuda = "Toma 0mq Conexión: BIND | Conectar ") parser.add_option (" - e "," --endpoint ", destr =" finalpoint ", help =" 0mq endpoint ") parser.add_option (" - m "," --mode ", DEST = "MODE", AYUDA = "MODO: Publisher | Suscriptor") parser.set_defaults (Método = "Conectar", Endpoint = "EPGM: // ETH1; 239.0.5.3: 10011") (Opciones, Args) = Parser. parse_args () de TXZMQ Importar ZMQFFACTORY, ZMQENDPOINT, ZMQPUBCONECTORION, ZMQSUBCONNEYIMPORT TIMEZF = ZMQFFACTORY () E = ZMQENDPOINT (OPCIONES.METHOD, options.endpoint) if option.mode == "Publisher": S = ZmqpubConnection (ZF, E) DEF Publish (): DATA = STR (Time.Time ()) Imprimir "Publishing% R"% Datos S.Publish (Datos) Reactor.Calllater (1, Publish) Publicar () Else: S = ZMQSUBCONECTORION (ZF, E) S. Suscríbase ("") DEF DOPRINT (* ARGS): Imprimir "Mensaje recibido:% R"% (Args,) S.GotMessage = DOPRINTRECOR.RUN () Requisitos: · Python · Zeromq Library> = 2.1 (muy probado con 2.1.4) · Pyzmq · Torcido


txzmq Software relacionado

Sobre nosotros