Python RPC 不會？不妨看看這篇文章

1. 前言

大家好，我是安果！

RPC，全程為 Remote Procedure Call，是一種進(jìn)程間的通信方式，它采用「 服務(wù)端 / 客戶機(jī) 」模式，是一種請求響應(yīng)模型

其中，服務(wù)端負(fù)責(zé)提供服務(wù)程序、響應(yīng)請求做具體的實現(xiàn)邏輯，客戶機(jī)負(fù)責(zé)請求調(diào)用

主流的 RPC 框架包含：

• 阿里的 Dubbo

• Facebook 的 Thrift

• Google 的 gRpc

• 新浪微博的 Motan

• Golang 生態(tài)的 rpcx

其中，gRpc 和 Thrift 是跨語言的 RPC 服務(wù)框架，并且 Thrift 相比性能更高

本篇文章以 Thrift 為例，聊聊 Python 中使用 RPC 的流程

2. thriftpy2 介紹

Thrift 是一種接口描述語言和二進(jìn)制通訊協(xié)議，它可以被用來定義和創(chuàng)建跨語言的服務(wù)，使得不同語言的客戶端、服務(wù)器之間能進(jìn)行高效透明的通信

thriftpy2 是在 Thrift 的基礎(chǔ)上進(jìn)行二次封裝，使用它編寫 RPC 更加方便快捷

項目地址：https://github.com/Thriftpy/thriftpy2

首先，我們在虛擬環(huán)境下安裝依賴包

# 安裝依賴
pip3 install thriftpy2

然后，如果是 Windows，建議在 Pycharm 中安裝  thrift 插件

PS：該插件可以方便我們編寫 Thrift 通訊文件

下載地址：https://plugins.jetbrains.com/plugin/7331-thrift-support

3. 實戰(zhàn)一下

首先，根據(jù)需求編寫 Thrift 通訊文件

比如，該文件定義 2 個方法

• 無參函數(shù) ping

• 登錄 login

  包含兩個參數(shù)：username、password

# foo.thrift

service PingPong{
    string ping(),
    string login(
        1: string username,
        2: string password
    )
}

然后，編寫服務(wù)端代碼

根據(jù) Thrift 通訊文件中定義的方法，編寫具體的實現(xiàn)邏輯

創(chuàng)建一個服務(wù)對象，指定綁定的 ip 地址及端口號，開啟服務(wù)并監(jiān)聽消息

# rcp_server.py

import thriftpy2
from thriftpy2.rpc import make_server

# 讀取通信配置文件
pingpong_thrift = thriftpy2.load("foo.thrift", module_name="pingpong_thrift")

class Dispatcher(object):
    """根據(jù)通信配置文件定義的方法，重寫實現(xiàn)方法"""

    def ping(self):
        """
        Ping一下
        :return:
        """
        return "pong"

    def login(self, username, password):
        """
        登錄
        :param username: 用戶名
        :param password: 密碼
        :return:
        """
        print('獲取客戶端傳過來的參數(shù)，用戶名:',username,"，密碼：",password)
        return '登錄成功！'


# 創(chuàng)建服務(wù),指定本地ip地址及監(jiān)聽端口號
server = make_server(pingpong_thrift.PingPong, Dispatcher(), '192.168.40.217', 9000)

# 開啟服務(wù)并監(jiān)聽
server.serve()

接著，編寫客戶端代碼

這里，根據(jù)服務(wù)端提供的 ip 地址、端口號，創(chuàng)建客戶端連接對象，調(diào)用通信文件中定義好的方法

PS：如果客戶端在遠(yuǎn)程執(zhí)行，需要將 Thrift 通訊文件放置到同級目錄下執(zhí)行

# rcp_client.py

import thriftpy2
from thriftpy2.rpc import make_client

# 讀取通信配置文件
pingpong_thrift = thriftpy2.load("foo.thrift", module_name="pingpong_thrift")

# 創(chuàng)建客戶端
client = make_client(pingpong_thrift.PingPong, '192.168.40.217', 9000)

# 調(diào)用通信文件中定義好的方法（實際調(diào)用服務(wù)端的方法）
print(client.ping())
print(client.login('root', 'pwd'))

最后，分別運(yùn)行服務(wù)端和客戶端的代碼

使用 WireShark 進(jìn)行抓包分析，能發(fā)現(xiàn)服務(wù)端和客戶端通訊的方式及數(shù)據(jù)傳輸過程

4. 最后

企業(yè)項目中，常用的 HTTP 的特點是簡單、開發(fā)方便，上手簡單、是主流的數(shù)據(jù)傳輸協(xié)議

相比 HTTP 或 H2，RPC 的主要優(yōu)勢體現(xiàn)在安全高、性能消耗低、傳輸效率高、服務(wù)治理方便上，所以我們可以根據(jù)實際項目需求選擇合理的數(shù)據(jù)通信方式