當我們執行多個python直譯器例項，還有可能是在不同的機器上時，我們可能會需要通過訊息在不同的直譯器之間交換資料。

    我們需要的不是複雜的訊息佇列，而是簡單的交換無損資訊的話，那麼multiprocessing.connection庫正是我們所需要的。只需要使用幾個簡單的原語便可以輕鬆將各個直譯器聯絡在一起並交換資料了。

    下面看示例：

#一號直譯器執行扮演伺服器角色
from multiprocessing.connection import Listener

def client(conn):
    while True:
        try:
            msg =
 
 conn.recv()
            print(f'Server receive the msg:{msg}')
            conn.send('Got it')
        except:
            print('Server Error')
            break

def server(address,authkey):
    serv = Listener(address,authkey=authkey)
    while True:
        try:
            clients = serv.accept(
 
)
            client(clients)
        except:
            print('Server Error')
            break

server(('',25000),authkey=b'AmosH'

    上面的程式碼是一號直譯器的伺服器程式碼，下面是執行時的效果圖：

    可以看到，所有由send()方法傳送的物件都完整無損的被recv()方法接收到了。任何同pickle相容的物件都可以在連線之間傳遞和接收。

    如果知道這些直譯器會執行在同一臺機器上，那麼可以利用網路作為替代方案。比如使用UNIX的域socket或者Windows的命名管道，只要簡單的把地址改為檔名就可以了，示例如下：

#UNIX
s = Listener('/tmp/myconn',authkey = authkey)
#Windows
s = Listener(r'\\.\pipe\myconn',authkey = authkey)

    一般來說，不應該使用multiprocessing模組來實現面向公眾型的服務。傳遞給Client()和Server()的authkey在這裡是為了幫助認證連線兩端的節點。使用錯誤的金鑰來連線會產生異常。

    注意，這個模組最好適用於能夠長時間執行的連線，而不是大量的短連線。

    如果需要對連線實現更多的底層控制，那麼就不要使用multiprocessing模組。比方說，如果要支援超時、非阻塞I/O或者任何類似的特性，那麼最好使用另一個不同的庫或者直接在socket上實現這些特性。

    微信公眾號：進擊的程式碼Amos

    每天更新Java、python學習資料、技術乾貨。分享見解，共同成長。

    關注公眾號，免費獲取眾多電子版經典教材。