python與RPC服務


RPC

1.什么是RPC

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

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

    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 -


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM