python與RPC服務

RPC

1.什麼是RPC

  • RPC 就是爲解決服務之間信息交互而發明和存在的。python

  • RPC(Remote Procedure Call)——遠程過程調用,它是一種經過網絡從遠程計算機程序上請求服務,而不須要了解底層網絡技術的協議。web

    RPC採用客戶機/服務器模式。請求程序就是一個客戶機,而服務提供程序就是一個服務器。
    
    首先,客戶機調用進程發送一個有進程參數的調用信息到服務進程,而後等待應答信息。
    
    在服務器端,進程保持睡眠狀態直到調用信息到達爲止。
    
    當一個調用信息到達,服務器得到進程參數,計算結果,發送答覆信息
    
    而後等待下一個調用信息,最後,客戶端調用進程接收答覆信息,得到進程結果,而後調用執行繼續進行。
RPC就是一種遠程調用函數接口的方式,說白了,就是一種遠程調用函數接口的方式,客戶端和服務端之間約定一種契約(函數接口),而後服務端一直等待客戶端的調用。

有點像日常的WEB網絡請求。

一種用途是在多臺服務器之間互相進行調用。

另外一個用途則在於,不一樣編程語言之間都支持這種方式,像Python更是內置對其的支持,不須要額外安裝什麼庫,因此能夠直接在多語言的服務器之間互相進行調用。

Socket編程就是RPC通訊

2.xmlrp庫

  • 簡單的服務端
  • 像web請求同樣,咱們須要肯定供客戶端訪問的url和端口號,以及供客戶端調用的方法實現,最後要讓咱們服務器一直處於等待被訪問的狀態:
  • rpc_server.py
from xmlrpc.server import SimpleXMLRPCServer

# 調用函數
def respon_string(str):
    return "get string:%s"%str


if __name__ == '__main__':
    server = SimpleXMLRPCServer(('localhost', 8888)) # 初始化
    server.register_function(respon_string, "get_string") # 註冊get_string函數
    print ("Listening for Client")
    server.serve_forever() # 保持等待調用狀態
  • rpc_client.py
from xmlrpc.client import ServerProxy

if __name__ == '__main__':
    server = ServerProxy("http://localhost:8888") # 初始化服務器
    print (server.get_string("RPC RPC")) # 調用get_string函數並傳參,調用get_string讓服務端經過respon_string函數處理請求,並返回。
  • 操做
#服務端啓動:
[root@xujunk tmp]#python3 rpc_server.py
Listening for Client
#客戶端啓動:
[root@xujunk tmp]#python3 rpc_client.py 
get string:RPC RPC      #返回結果

#服務端接到請求:
127.0.0.1 - - [22/Sep/2019 00:12:03] "POST /RPC2 HTTP/1.1" 200 -
相關文章
相關標籤/搜索