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