Thirft框架介紹

jopen 10年前發布 | 19K 次閱讀 Thirft WEB服務/RPC/SOA

1、前言

Thrift是一個跨語言的服務部署框架,最初由非死book于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、架構

Thirft框架介紹

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

下載: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()

}

     要生成C++代碼:./thrift --gen cpp tutorial.thrift,結果代碼存放在gen-cpp目錄下
     要生成java代碼:./thrift --gen java tutorial.thrift,結果代碼存放在gen-java目錄下       ….. 

(2) client端和server端代碼編寫

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

下面分析cpp文件下面的CppClient.cpp和CppServer.cpp代碼

Thirft框架介紹

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

在server端,需要實現在.thrift文件中聲明的服務中的所有功能,以便處理client發過來的請求。

【參考資料】
1、 http://wiki.apache.org/thrift/
2、 http://jnb.ociweb.com/jnb/jnbJun2009.html
3、 http://blog.rushcj.com/tag/thrift/
4、 http://www.vvcha.cn/c.aspx?id=31984
5、 http://www.thoss.org.cn/mediawiki/index.php/Thrift%E7%9A%84%E9%80%9A%E4%BF%A1%E6%9C%BA%E5%88%B6%E5%8F%8A%E5%85%B6%E5%9C%A8cassandra%E4%B8%AD%E7%9A%84%E5%BA%94%E7%94%A8

 本文由用戶 jopen 自行上傳分享,僅供網友學習交流。所有權歸原作者,若您的權利被侵害,請聯系管理員。
 轉載本站原創文章,請注明出處,并保留原始鏈接、圖片水印。
 本站是一個以用戶分享為主的開源技術平臺,歡迎各類分享!