1. 程式人生 > >Python通過Manager方式實現多個無關聯程序共享資料

Python通過Manager方式實現多個無關聯程序共享資料

Python實現多程序間通訊的方式有很多種,例如佇列,管道等。
但是這些方式只適用於多個程序都是源於同一個父程序的情況。
如果多個程序不是源於同一個父程序,只能用共享記憶體,訊號量等方式,但是這些方式對於複雜的資料結構,例如Queue,dict,list等,使用起來比較麻煩,不夠靈活。
Manager是一種較為高階的多程序通訊方式,它能支援Python支援的的任何資料結構。
它的原理是:先啟動一個ManagerServer程序,這個程序是阻塞的,它監聽一個socket,然後其他程序(ManagerClient)通過socket來連線到ManagerServer,實現通訊。

manager.py程式碼,實現server和client兩個類

# encoding=utf-8
__author__ = '[email protected]'
''' 程序間通訊 ''' from multiprocessing.managers import BaseManager from multiprocessing import RLock MANAGER_PORT = 6000 MANAGER_DOMAIN = '0.0.0.0' MANAGER_AUTH_KEY = 'aaaaaaaaaaaaaaa' #定義一個Manager類 class InfoManager(BaseManager): pass class DictItem(): def __init__(self, ): self.items = dict() def set(self, key, value): self.items[key] = value def get(self, key): return self.items.get(key) def __setitem__(self, key, value): self.set(key, value) #為這個manager類註冊儲存容器,也就是通過這個manager類實現的共享的變數, #這個變數最好是一個類例項,自己定義的或者python自動的類的例項都可以 #這裡不能把d改成dict(),因為Client那邊執行d['keyi']='value'的時候會報錯:d這個變數不能修改 d = DictItem() lock = RLock() InfoManager.register('dict', callable=lambda: d) InfoManager.register('open_qq_login_lock', callable=lambda: lock) class ManagerServer(): ''' multiprocess Manager服務類 ''' def __init__(self, domain, port, auth_key): self.domain = domain self.port = port self.auth_key = auth_key def start_manager_server(self): self.queue_manager = InfoManager(address=('', self.port), authkey=self.auth_key) # self.dict = self.queue_manager.dict() self.server = self.queue_manager.get_server() def run(self): self.start_manager_server() self.server.serve_forever() def stop(self): self.server.shutdown() self.is_stop = 1 class ManagerClient(): ''' 訪問mutiprocess Manager的類 ''' def __init__(self, domain, port, auth_key): self.domain = domain self.port = port self.auth_key = auth_key # self.get_share_dict() self.info_manager = InfoManager(address=(self.domain, self.port), authkey=self.auth_key) self.info_manager.connect() def get_dict(self): # self.dict = m.dict() self.dict = self.info_manager.dict() return self.dict def get_open_qq_login_lock(self): self.open_qq_login_lock = self.info_manager.open_qq_login_lock() return self.open_qq_login_lock if __name__ == '__main__': pass

用法
1.啟動一個ManagerServer,這個程序是阻塞的

import manager

def run():
    manager_server = manager.ManagerServer(manager.MANAGER_DOMAIN, manager.MANAGER_PORT, manager.MANAGER_AUTH_KEY)
    manager_server.run()
if __name__ == '__main__':
    run()

2.例項化一個client,獲取共享的變數

# 程序間共享變數
manager_client = manager.ManagerClient(manager.MANAGER_DOMAIN, manager.MANAGER_PORT, manager.MANAGER_AUTH_KEY)
share_dict = manager_client.get_dict()
open_qq_login_lock = manager_client.get_open_qq_login_lock()

注意:
1.對client獲取的變數修改,不會影響server那邊的變數,例如server中,client1獲取變數params1,把它修改為params2,server那邊的資料不會修改。如果要修改server的資料,需要呼叫server的方法,把server那邊的資料重新整理。