Thrift使用一種中間語言IDL,來進行介面的定義,下面來具體講一下IDL可定義的幾種常用資料型別和關鍵字.

常用資料型別及關鍵字

　　基本型別

　　　　thrift不支援無符號的型別,無符號型別可以簡單理解為不能表示負數,只能表示正數的型別,像java的基本資料型別都是有符號的型別.

• byte:有符號位元組
• i32:32位有符號整數,此外還有i16,i64
• double:64位浮點數
• string:二進位制字串
• bool 布林值 true或false

　　結構體型別(struct):

　　　　類似於c語言的結構體定義,在java中會被轉化為javabean類

struct User {
　　1: i32 id;
　　2: string name;
　　3: double salary;
　　4: bool hasCar;
}

　　服務型別(service):

　　　　service:對應服務的介面,內部可定義各種方法,相當於java中建立interface一樣,建立的service經過程式碼生成命令會生成客戶端,服務端的框架程式碼

service Hello{
　　string helloString(1:string s);
　　i32 helloInt(1:i32 i);
　　bool helloBoolean(1:bool b);
　　void helloVoid();
　　string helloNull();
}

　　異常型別(Exception):

exception RequestException {

　　1:i32 code;

　　2:string detail;

}

　　容器型別

　　　　集合中的元素可以是除了service之外的任意型別

　　　list<T>:有序列表,元素可重複

　　　set<T>:無需集合,元素不可重複

　　　map<K,V>:鍵值對集合

　　列舉型別

　　enum Color{

　　　　RED,

　　　　BLUE

　　}

　　名稱空間(namespace)

　　　　可以理解成java中的packet,用於避免一些程式碼衝突,每種語言都有屬於自己的名稱空間的方式,比如java語言,就可以使用java語言的格式

namespace java com.wang.project

　　 此外還有一些語言特性和關鍵字就不一一介紹了,比如可選引數和必選引數,required和optional,定義常量const,引入檔案include等

Thrift支援的傳輸協議

　　Thrift支援多種傳輸協議,我們可以根據自己的需要來選擇合適的型別,總體上來說,分為文字傳輸和二進位制傳輸,由於二進位制傳輸在傳輸速率和節省頻寬上有優勢,所以大部分情況下使用二進位制傳輸是比較好的選擇.

• TBinaryProtocol:使用二進位制編碼格式傳輸,是thrift的預設傳輸協議
• TCompactProtocol:使用壓縮格式傳輸
• TJSONProtocol :使用JSON格式傳輸
• TDebugProtocol – 使用易懂可讀的文字格式進行傳輸，以便於debug
• TSimpleJSONProtocol – 提供JSON只寫的協議，適用於通過指令碼語言解析

Thrift支援的傳輸模式

　　Thrift封裝了一層傳輸層來支援底層的網路通訊,在Thrift中稱為Transport,不僅提供open,close,flush等方法,還有一些read/write方法.

• 　　TSocket:阻塞式IO的Transport實現,用在客戶端.
• 　　TServerSocket:非阻塞式Socket,用於伺服器端,用於監聽TSocket.
• 　　TNonblockingSocket:非阻塞式IO的實現
• 　　TMemoryInputTransport: 封裝了一個位元組陣列byte[]來做輸入流的封裝
• 　　TFramedTransport- 同樣使用非阻塞方式，按塊的大小進行傳輸,輸入流封裝了TMemoryInputTransport　　

Thrift支援的服務模型

　　TSimpleServer:

　　　　這種工作模式只有一個執行緒,迴圈監聽傳過來的請求並對其進行處理,處理完才能接受下一個請求,是一種阻塞式IO的實現,因為效率比較低,實際線上環境一般用不到.一般用於開發時候演示工作流程時使用.　　

　　TNonblockingServer:

這種模式與TsimpleServer最大的區別就是使用NIO,也就是非阻塞是IO的方式實現IO的多路複用,它可以同時監聽多個socket的變化,但因為業務處理上還是單執行緒模式,所以在一些業務處理比較複雜耗時的時候效率還是不高,因為多個請求任務依然需要排隊一個一個進行處理.

　　TThreadPoolServer:

這種模式引入了執行緒池,主執行緒只負責accept,即監聽Socket,當有新的請求(客戶端Socket)來時,就會線上程池裡起一個執行緒來處理業務邏輯,這樣在併發量比較大的時候(但不超過執行緒池的數量)每個請求都能及時被處理,效率比較高,但一旦併發量很大的時候(超過執行緒池數量),後面來的請求也只能排隊等待.

　　TThreadedSelectorServer:

　　　　這是一種多執行緒半同步半非同步的服務模型,是Thrift提供的最複雜最高階的服務模型,內部有一個專門負責處理監聽Socket的執行緒,有多個專門處理業務中網路IO的執行緒,有一個專門負責決定將新Socket連線分配給哪一個執行緒處理的起負載均衡作用的執行緒,還有一個工作執行緒池.這種模型既可以響應大量併發連線的請求又可以快速對wangluoIO進行讀寫,能適配很多場景,因此是一種使用比較高頻的服務模型.

Thrift服務層編碼

try {
            System.out.println("服務端開啟....");
            //1.建立TProcessor
            TProcessor tprocessor = new Hello.Processor<Hello.Iface>(new HelloServiceImpl());
            // 2.建立TserverTransport
            TServerSocket serverTransport = new TServerSocket(9898);
            //3.建立TProtocol
            TBinaryProtocol.Factory factory = new TBinaryProtocol.Factory();

            TServer.Args tArgs = new TServer.Args(serverTransport);
            tArgs.processor(tprocessor);
            tArgs.protocolFactory(factory);
            //4.建立Tserver,傳入需要的引數,server將以上內容整合在一起
            TServer server = new TSimpleServer(tArgs);
            //5.啟動server
            server.serve();
            }catch (TTransportException e) {
            e.printStackTrace();
        }

根據程式碼可以看出服務端編碼基本流程:

　　0.實現服務處理介面impl,重寫介面方法.

　　1.建立TProcessor

　　Processor封裝了從輸入資料流中讀資料和向資料流中寫資料的操作,與服務相關的Processor是由編譯器編譯IDL檔案產生的,它的主要工作是:從連線中讀取資料,把處理交給使用者實現impl,最後把結果寫到連線上.

　　2.建立serverTransport

　　TServerSocket是ServerTransport的阻塞式IO的實現.它實現了監聽埠的作用,accept到的Socket型別都是客戶端的TSocket型別(阻塞式Socket).

　　3.建立TProtocol

　　TProtocol定義了基本的協議資訊,包括傳輸什麼資料,如何解析傳輸的資料.　　　

　　4.建立server

　　根據需要選擇使用不同的服務模式,程式碼中為了演示只是用了最簡單TSimpleServer

　　5.啟動服務

Thrift客戶端編碼

System.out.println("客戶端啟動....");
        TTransport transport = null;
        try {
            //1.建立TTransport
            transport = new TSocket("localhost", 9898, 30000);
            // 2.建立TProtocol  協議要和服務端一致
            TProtocol protocol = new TBinaryProtocol(transport);
            //3.建立Client 開啟transport
            Hello.Client client = new Hello.Client(protocol);
            transport.open();
            //4.呼叫Client響應方法
            String result = client.helloString("哈哈");
            System.out.println("Thrify client result =: " + result);
        } catch (TTransportException e) {
            e.printStackTrace();
        } catch (TException e) {
            e.printStackTrace();
        } finally {
            if (null != transport) {
                transport.close();
            }
        }

 　　新手入門,根據自己的理解以及拜閱了網友們的文章總結的難免有不當之處的,輕噴.

相關博文

  參考資料