Thirft架構介紹

1、前言

Thrift是一個跨語言的服務部署架構，最初由Facebook于2007年開發，2008年進入Apache開源項目。Thrift通過一個中間語言(IDL, 接口定義語言)來定義RPC的接口和資料類型，然後通過一個編譯器生成不同語言的代碼（目前支援C++,Java, Python, PHP, Ruby, Erlang, Perl, Haskell, C#, Cocoa, Smalltalk和OCaml）,并由生成的代碼負責RPC協定層和傳輸層的實作。

本文組織結構如下：1）引言 2）架構3）支援的資料傳輸格式、資料傳輸方式和服務模型 4）Thrift安裝 5）利用Thift部署服務

。

2、架構

<a href="http://dongxicheng.org/wp-content/uploads/2011/03/arthitecture2.jpg"></a>

Thrift實際上是實作了C/S模式，通過代碼生成工具将接口定義檔案生成伺服器端和用戶端代碼（可以為不同語言），進而實作服務端和用戶端跨語言的支援。使用者在Thirft描述檔案中聲明自己的服務，這些服務經過編譯後會生成相應語言的代碼檔案，然後使用者實作服務（用戶端調用服務，伺服器端提服務）便可以了。其中protocol（協定層, 定義資料傳輸格式，可以為二進制或者XML等）和transport（傳輸層，定義資料傳輸方式，可以為TCP/IP傳輸，記憶體共享或者檔案共享等）被用作運作時庫。上圖的詳細解釋參考引用【1】。

3、 支援的資料傳輸格式、資料傳輸方式和服務模型

（1）支援的傳輸格式

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安裝

安裝要求：

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） client端和server端代碼編寫

client端和sever端代碼要調用編譯.thrift生成的中間檔案。

下面分析cpp檔案下面的CppClient.cpp和CppServer.cpp代碼

<a href="http://dongxicheng.org/wp-content/uploads/2011/03/thrift3.jpg"></a>

在client端，使用者自定義CalculatorClient類型的對象（使用者在.thrift檔案中聲明的服務名稱是Calculator， 則生成的中間代碼中的主類為CalculatorClient）， 該對象中封裝了各種服務，可以直接調用（如client.ping()）, 然後thrift會通過封裝的rpc調用server端同名的函數。

在server端，需要實作在.thrift檔案中聲明的服務中的所有功能，以便處理client發過來的請求。

【參考資料】