 | TXZMQ.Zeromq에 대한 꼬인 바인딩 |
| 지금 다운로드 | |
TXZMQ. 순위 및 요약
광고
TXZMQ. 태그
TXZMQ. 설명
Zeromq에 대한 트위스트 바인딩 TXZMQ는 쉽게 Zeromq 소켓을 꼬인 이벤트 루프 (원자로)로 통합 할 수있는 Python 라이브러리입니다 .TXZMQ는 기본 이벤트 루프 통합을 수행 할 수있는 클래스 ZMQConnection의 클래스 zmqconnection의 클래스 zeromq 소켓에 대한 지원을 소개합니다. 해당 클래스, ZmqPubConnection 및 ZmqSubConnection의 특수한 니스 기능을 Pub / Sub Sockets의 특수한 니스 기능을 추가하는 데있어서 ZMQPubConnection 및 ZmqSubConnection의 특수 기능을 추가 할 수 있습니다. 즉시 메시지를 수신하면 (현재 사용 가능한 메시지를 읽고 대기중인 메시지를 병렬로 읽으려고 시도합니다) .Example : 가져 오기 SysFrom OptParse OptionParserfrom Twisted.Internet 가져 오기 반응기, DeferFrom Twisted.python import LogObserver = log.fileLogObserver (sys.stderr) log.addobserver (observer.emit) parser = optionParser ( "") parser.add_option ( "- m", "--method", dest = "method", help = "0mq 소켓" 연결 : 바인드 | 연결 ") parser.add_option ("- e ","- endpoint ", dest ="끝점 ", help ="0mq 끝점 ") parser.add_option ("- m ","- mode ", dest = "mode", help = "mode : publisher | 가입자") parser.set_defaults (method = "connect", endpoint = "epgm : // eth1; 239.0.5.3 : 10011") (옵션, args) = 파서. txzmq 가져 오기 zmqfactory, zmqencepoint, zmqpubconnection, zmqpubconnectionimport timezf = zmqfactory () zmq_ode (options.method, options.endpoint)에서 options.mode == "publisher": s = zmpubconnection (zf, e) def publish () : data = str (time.time ()) "publishing % r"% 데이터 s.publish (데이터) Reautor.Calllater (1, 게시) 게시 () else : s = zmqsubconnection (zf, e) s. 구독 ( "") DEF DEF DEPRINT (* ARGS) : 인쇄 "메시지 수신 : % r"% (args,) s.gotmessage = doprintreactor.run () 요구 사항 : · 파이썬 · Zeromq 라이브러리> = 2.1 (2.1.4로 크게 테스트 됨) · PYZMQ. · 트위스트
TXZMQ. 관련 소프트웨어
