浏览 2718 次
精华帖 (0) :: 良好帖 (0) :: 新手帖 (0) :: 隐藏帖 (0)
|
|
---|---|
作者 | 正文 |
发表时间:2011-03-24
最后修改:2011-03-25
文中先给出了一个比较"脏"的处理方式: import zmq import time context = zmq.Context() receiver = context.socket(zmq.PULL) receiver.connect("tcp://localhost:5557") subscriber = context.socket(zmq.SUB) subscriber.connect("tcp://localhost:5556") subscriber.setsockopt(zmq.SUBSCRIBE, "10001") while True: while True: try: rc = receiver.recv(zmq.NOBLOCK)#这是非阻塞模式 except zmq.ZMQError: break while True: try: rc = subscriber.recv(zmq.NOBLOCK) except zmq.ZMQError: break 显然,如此做既不优雅,还有出现单来源循环不止,另一来源又得不到响应的状况。 自然,官方也做了相应的封装,给了一个相对优雅的实现: import zmq context = zmq.Context() receiver = context.socket(zmq.PULL) receiver.connect("tcp://localhost:5557") subscriber = context.socket(zmq.SUB) subscriber.connect("tcp://localhost:5556") subscriber.setsockopt(zmq.SUBSCRIBE, "10001") poller = zmq.Poller() poller.register(receiver, zmq.POLLIN) poller.register(subscriber, zmq.POLLIN) while True: socks = dict(poller.poll()) if receiver in socks and socks[receiver] == zmq.POLLIN: message = receiver.recv() if subscriber in socks and socks[subscriber] == zmq.POLLIN: message = subscriber.recv() 这种方式采用了平衡兼顾的原则,实现了类似于同一模式多发布端推送的"平衡队列"功能。 (未完待续) 声明:ITeye文章版权属于作者,受法律保护。没有作者书面许可不得转载。
推荐链接
|
|
返回顶楼 | |
发表时间:2011-12-02
push pull倒是是什么模式?
|
|
返回顶楼 | |