目錄
- 環境準備
- 編寫.thrift文件
- 生成python對應的thrift代碼
- 編寫服務端
- 編寫客戶端用于測試
- 測試服務端
近期在項目中存在跨編程語言協作的需求，使用到了Thrift。本文將記錄用python實現Thrift服務端的方法。
環境準備
- 根據自身實際情況下載對應的Thrift編譯器，比如我在Windows系統上使用的是thrift-0.9.3.exe 。下載地址：http://archive.apache.org/dist/thrift/
- python安裝thrift庫：pip install thrift
編寫.thrift文件
.thrift文件定義了Thrift服務端和Thrift客戶端的通信接口，在該文件中定義的接口需由服務端實現，并可被客戶端調用。Thrift編譯器會調用.thrift文件生成不同語言的thrift代碼，用于之后實現thrift服務端或thrift客戶端。
.thrift文件的編寫規則可參考Thrift白皮書。下面將以demo.thrift文件舉例
service DemoService{
string ping(1:string param)
mapi32,string> get_int_string_mapping_result(1:i32 key, 2:string value)
bool get_bool_result()
}
生成python對應的thrift代碼
使用以下命令可以生成不同語言的thrift代碼：
thrift --gen language> Thrift filename>
通過thrift-0.9.3.exe --gen py demo.thrift 命令生成python版本的thrift文件，文件夾為gen-py，如下所示：
編寫服務端
編寫服務端server.py，用于實現在demo.thrift文件中定義的接口功能。
from thrift.transport import TSocket
from thrift.transport import TTransport
from thrift.protocol import TBinaryProtocol
from thrift.server import TServer
import sys
sys.path.append("./gen-py/")
from demo import DemoService
import random
class DemoServer:
def __init__(self):
self.log = {}
def ping(self, param):
return "echo:" + param
def get_int_string_mapping_result(self, key, value):
return {key: value}
def get_bool_result(self):
return random.choice([True, False])
if __name__ == '__main__':
# 創建處理器
handler = DemoServer()
processor = DemoService.Processor(handler)
# 監聽端口
transport = TSocket.TServerSocket(host="0.0.0.0", port=9999)
# 選擇傳輸層
tfactory = TTransport.TBufferedTransportFactory()
# 選擇傳輸協議
pfactory = TBinaryProtocol.TBinaryProtocolFactory()
# 創建服務端
server = TServer.TThreadPoolServer(processor, transport, tfactory, pfactory)
# 設置連接線程池數量
server.setNumThreads(5)
# 啟動服務
server.serve()
編寫客戶端用于測試
編寫客戶端client.py，用于測試服務端功能是否可用。
from thrift import Thrift
from thrift.transport import TSocket
from thrift.transport import TTransport
from thrift.protocol import TBinaryProtocol
import sys
sys.path.append("./gen-py/")
from demo import DemoService
if __name__ == '__main__':
transport = TSocket.TSocket('127.0.0.1', 9999)
transport = TTransport.TBufferedTransport(transport)
protocol = TBinaryProtocol.TBinaryProtocol(transport)
client = DemoService.Client(protocol)
# 連接服務端
transport.open()
recv = client.ping("test")
print(recv)
recv = client.get_int_string_mapping_result(10, "MyThrift")
print(recv)
recv = client.get_bool_result()
print(recv)
# 斷連服務端
transport.close()
編寫完成后，整個項目結構如下圖所示：
測試服務端
運行服務端server.py后，運行客戶端client.py，打印的內容如下：
echo:test
{10: 'MyThrift'}
True
此時客戶端能夠正常調用服務端所提供的接口。（PS：在調試過程中，也許需要修改gen-py文件夾中Thrift編譯器生成的python代碼）
以上就是python實現Thrift服務端的方法的詳細內容，更多關于python實現Thrift服務端的資料請關注腳本之家其它相關文章！
您可能感興趣的文章:- python thrift搭建服務端和客戶端測試程序
- python thrift 實現 單端口多服務的過程
- python3.7通過thrift操作hbase的示例代碼
- python使用thrift教程的方法示例
- python利用thrift服務讀取hbase數據的方法
- python 如何用urllib與服務端交互(發送和接收數據)
- Python連接Java Socket服務端的實現方法
- python 實現客戶端與服務端的通信
- python網絡編程socket實現服務端、客戶端操作詳解
- Python Websocket服務端通信的使用示例
