python中的BaseManager通信（二）文件二分

提供服务部分（运行时在接收端未打开前不能关闭）

#mainsec.py
from multiprocessing import Process, Queue
from multiprocessing.managers import BaseManager
class Worker(Process):
    def __init__(self, q):
        self.q = q
        super(Worker, self).__init__()
    def run(self):
        self.q.put('local hello')
if __name__ == '__main__':
    queue = Queue()
    w = Worker(queue)
    w.start()
    class QueueManager(BaseManager): pass

    QueueManager.register('get_queue', callable=lambda: queue)
    m = QueueManager(address=('127.0.0.1', 50000), authkey='abc')
    s = m.get_server()
    s.serve_forever()

接收方（接收）：

#subthir.py
from multiprocessing.managers import BaseManager
class QueueManager(BaseManager): pass
QueueManager.register('get_queue')
m = QueueManager(address=('127.0.0.1', 50000), authkey='abc')
m.connect()
queue = m.get_queue()
print m.address
print queue.get()

结果：

 ('127.0.0.1', 50000)

 2 local hello