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,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,auth_key):
    self.domain = domain
    self.port = port
    self.auth_key = auth_key
    # self.get_share_dict()
    self.info_manager = InfoManager(address=(self.domain,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_AUTH_KEY)
share_dict = manager_client.get_dict()
open_qq_login_lock = manager_client.get_open_qq_login_lock()

注意：

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

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支援我們。