1、前言
Thrift是一個跨語言的服務部署框架,最初由Facebook于2007年開發,2008年進入Apache開源項目。
Thrift特征如下:
1)Thrift有自己的跨機器通信框架,并提供一套庫
2)Thrift是一個代碼生成器,按照它的規則,可以生成多種編程語言的通信過程代碼
Thrift通過一個中間語言(IDL, 接口定義語言)來定義RPC的接口和數據類型,然后通過一個編譯器生成不同語言的代碼(目前支持C++,java, Python, php, Ruby, Erlang, Perl, Haskell, C#, Cocoa, Smalltalk和OCaml),并由生成的代碼負責RPC協議層和傳輸層的實現。
2、架構
1).thrift文件定義數據結構和服務接口
2)代碼生成器生成若干符合約定通信格式的代碼
3)thrift應用框架:包括thrift自身提供的庫函數
4)第三方庫:按照運行的模式,生成的代碼中可能需要調用第三方庫
Thrift實際上是實現了C/S模式,通過代碼生成工具將接口定義文件生成服務器端和客戶端代碼(可以為不同語言),從而實現服務端和客戶端跨語言的支持。用戶在Thirft描述文件中聲明自己的服務,這些服務經過編譯后會生成相應語言的代碼文件,然后用戶實現服務(客戶端調用服務,服務器端提服務)便可以了。其中PRotocol(協議層, 定義數據傳輸格式,可以為二進制或者xml等)和transport(傳輸層,定義數據傳輸方式,可以為TCP/ip傳輸,內存共享或者文件共享等)被用作運行時庫。
3、 支持的數據傳輸格式、數據傳輸方式和服務模型
(1)支持的傳輸格式:是對傳輸協議的封裝,傳輸采用二進制、XML或text來表示信息
TBinaryProtocol – 二進制格式.
TCompactProtocol – 壓縮格式
TJSONProtocol – JSON格式
TSimpleJSONProtocol –提供JSON只寫協議, 生成的文件很容易通過腳本語言解析。
TDebugProtocol – 使用易懂的可讀的文本格式,以便于debug
(2) 支持的數據傳輸方式:信息的傳輸渠道以及讀寫方式
TSocket -阻塞式socker
TFramedTransport – 以frame為單位進行傳輸,非阻塞式服務中使用。
TFileTransport – 以文件形式進行傳輸。
TMemoryTransport – 將內存用于I/O. java實現時內部實際使用了簡單的ByteArrayOutputStream。
TZlibTransport – 使用zlib進行壓縮, 與其他傳輸方式聯合使用。當前無java實現。
(3)支持的服務模型
TSimpleServer – 簡單的單線程服務模型,常用于測試
TThreadPoolServer – 多線程服務模型,使用標準的阻塞式IO。
TNonblockingServer – 多線程服務模型,使用非阻塞式IO(需使用TFramedTransport數據傳輸方式)
4、 Thrift安裝
下載:http://incubator.apache.org/thrift/download/
安裝要求:
Unix/linux 系統,windows+cygwin
C++語言:g++、boost
java 語言:JDK、Apache Ant
其他語言:Python、PHP、Perl, etc…
編譯安裝:./configure –》make –》make install
1、 利用Thrift部署服務
主要流程:編寫服務說明,保存到.thrift文件 –》根據需要, 編譯.thrift文件,生成相應的語言源代碼 –》根據實際需要, 編寫client端和server端代碼。
(1)編寫服務說明,保存到.thrift文件
一般將服務放到一個.thrift文件中,服務的編寫語法與C語言語法基本一致,在.thrift文件中有主要有以下幾個內容:變量聲明、數據聲明(struct)和服務接口聲明(service, 可以繼承其他接口)。
下面分析Thrift的tutorial中帶的例子tutorial.thrift
包含頭文件:
59行:include “shared.thrift”–
指定目標語言:
65行:namespace cpp tutorial–
定義變量:
80行:const i32 INT32CONSTANT = 9853–
定義結構體:
103行:struct Work {
1: i32 num1 = 0,
2: i32 num2,
3: Operation op,
4: optional string comment,
}—
定義服務:
service Calculator extends shared.SharedService {
void ping(),
i32 add(1:i32 num1, 2:i32 num2),
i32 calculate(1:i32 logid, 2:Work w) throws (1:InvalidOperation ouch),
oneway void zip()
}
(2)根據需要, 編譯.thrift文件,生成相應的語言源代碼,以java和C++語言為例
要生成C++代碼:./thrift --gen cpp tutorial.thrift,結果代碼存放在gen-cpp目錄下
要生成java代碼:./thrift --gen java tutorial.thrift,結果代碼存放在gen-java目錄下
(3) 根據需要,編寫client端和server端代碼
client端和sever端代碼要調用編譯.thrift生成的中間文件。
下面分析cpp文件下面的CppClient.cpp和CppServer.cpp代碼
在client端,用戶自定義CalculatorClient類型的對象(用戶在.thrift文件中聲明的服務名稱是Calculator, 則生成的中間代碼中的主類為CalculatorClient), 該對象中封裝了各種服務,可以直接調用(如client.ping()), 然后thrift會通過封裝的rpc調用server端同名的函數。
在server端,需要實現在.thrift文件中聲明的服務中的所有功能,以便處理client發過來的請求。
新聞熱點
疑難解答