Python進程專題8：分布集群的消息傳遞

wh469012917 發布于2019-07-30 17:41 / 3653人閱讀

摘要：代表網絡地址的元組或者代表域套接字的文件名，或者代表形式的字符串，代表遠程系統本地計算機的為上的一條命名管道。是一個整數，當參數指定了一個網絡連接時，對應于傳遞給套接字的方法的值，默認為。

上一篇文章：Python進程專題7：托管對象
下一篇文章：Python進程專題9：關于進程的實用工具函數

使用multiprocessing模塊的程序不僅可以于運行在同一計算機的其它程序進行消息傳遞，還可以于位于不到計算機的遠程系統程序進行消息傳遞。其中的multiprocessing.connection子模塊包含該目的的函數和類：

connections.Client(address,family,authenticate,authkey)

連接到另一個進程，此進程必須已經正在監聽地址address。
address:代表網絡地址的元組(hostname,port),或者代表UNIX域套接字的文件名，或者代表
r"servernamepipepipename"形式的字符串，代表遠程系統servername(本地計算機的servername為".")上的一條Windows命名管道。

family:表示地址格式的字符串。一般是"AF_INET"、"AF_UNIX"、或"AF_PIPE".如果省略此參數，將從address的格式退出它的值。

backlog:是一個整數，當address參數指定了一個網絡連接時，對應于傳遞給套接字的listen()方法的值，backlog默認為1。

authenticate:一個布爾標志，指定是否使用摘要身份驗證。
authkey:包含身份驗證密鑰的字符串，如果忽略此參數，將使用current_process().authkey的值。

此函數的返回值是Connection對象，管道中有講過。

connections.Listener(address,family,backlog,authenticate,authkey)

實現了一臺服務器，用于偵聽和處理Client()函數發送的連接。
如果省略address參數，將選擇默認地址，如果同時省略address和family兩個參數，將選擇本地系統上速度最快的可用通信模式。

Listener實例listener支持一下方法和屬性。

屬性或方法名	介紹
listener.accept()	接受一個新連接，并返回一個Connetion對象。如果身份驗證失敗，將引發Authentication-Error異常
listener.address	偵聽器正在使用的地址
listener.close()	關閉偵聽器正在使用的管道或套接字
listener.last_accepted	接受的最后一個客戶端的地址。

實例：服務器端與客戶端發送消息

服務器端代碼：

#服務器端，負責監聽客戶端并實現簡單的遠程操作
from multiprocessing.connection import Listener
serv=Listener(("",11111),authkey="123456".encode())
while True:
    conn=serv.accept()
    while True:
        try:
            x,y=conn.recv()
        except EOFError:
            print("出錯了")
            break
        result=x+y
        conn.send(result)
    conn.close()

客戶端代碼：

#客戶端，向服務器端發送消息
from multiprocessing.connection import Client
conn=Client(("localhost",11111),authkey="123456".encode())
conn.send((5,6))
r=conn.recv()
print(r)


conn.send(("mark","帥哥"))
r=conn.recv()
print(r)
conn.close()

客戶端打印結果：

11
mark帥哥

GPU云服務器云服務器分布式消息傳遞服務器消息的傳遞分布式與集群的區別集群和分布式的區別

文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。

轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/42353.html

Python進程專題9：關于進程的實用工具函數

摘要：上一篇文章進程專題分布集群的消息傳遞下一篇文章進程專題函數解析返回所有活動子進程的對象組成的列表返回系統上的數量，如果能夠確定的話返回當前進程的對象在實用各種打包工具如進行凍結的應用程序中，次函數應該作為主程序的首行。上一篇文章：Python進程專題8：分布集群的消息傳遞下一篇文章：Python進程專題10：GIL 函數解析 activite_children() 返回...

妤鋒シ 2019-07-30 17:41 評論0 收藏0
Python進程專題7：托管對象

摘要：連接帶遠程管理器對象，該對象的地址在構造函數中支出。在當前進程中運行管理器服務器。啟動一個單的子進程，并在該子進程中啟動管理器服務器。如果無法序列號對象將引發異常。上一篇文章：Python進程專題6：共享數據與同步下一篇文章：Python進程專題8：分布集群的消息傳遞進程不支持共享對象，上面描述的創建共享值和數組，但都是指定的特殊類型，對高級的Python對象（如：字典、列表、用...

DevYK 2019-07-30 17:41 評論0 收藏0
Python進程專題6：共享數據與同步

摘要：可以使用標準的索引切片迭代操作訪問它，其中每項操作均鎖進程同步，對于字節字符串，還具有屬性，可以把整個數組當做一個字符串進行訪問。當所編寫的程序必須一次性操作大量的數組項時，如果同時使用這種數據類型和用于同步的單獨大的鎖，性能將極大提升。上一篇文章：Python進程專題5：進程間通信下一篇文章：Python進程專題7：托管對象我們現在知道，進程之間彼此是孤立的，唯一通信的方式是隊...

Yuanf 2019-07-30 17:41 評論0 收藏0
Python進程專題5：進程間通信

摘要：上一篇文章進程專題進程池下一篇文章進程專題共享數據與同步模塊支持的進程間通信主要有兩種管道和隊列。隊列底層使用管道和鎖，同時運行支持線程講隊列中的數據傳輸到底層管道中，來實習進程間通信。上一篇文章：Python進程專題4：進程池Pool下一篇文章：Python進程專題6：共享數據與同步 multiprocessing模塊支持的進程間通信主要有兩種：管道和隊列。一般來說，發送較少的大...

eccozhou 2019-07-30 17:41 評論0 收藏0
PySpark SQL 相關知識介紹

摘要：大數據除了體積和速度外，數據的多樣性和準確性也是大數據的一大特點。這些也被稱為大數據的特征。介紹是一個解決大數據問題的分布式可伸縮的框架。介紹計算的模型最早出現在谷歌的一篇研究論文中。相關鏈接介紹是一個通用的分布式編程框架。本文作者：foochane?本文鏈接：https://foochane.cn/article/2019060601.html 1 大數據簡介大數據是這個時代最...

CoderStudy 2019-07-24 10:56 評論0 收藏0