Thrift Java 實戰入門：從 IDL 到跨語言 RPC
Thrift 由 Facebook 開源，現為 Apache 項目，解決**大數據量、多語言、高性能**跨進程通信需求。支持 C++、Java、Python、PHP、Go、Node.js 等 15+ 語言，通過 IDL（接口定義語言）定義數據結構與服務接口，自動生成各語言客戶端/服務端代碼。
一、核心架構分層
- Business Logic (Your Code)：業務實現類。
- Generated Service Stubs：IDL 生成的 Client/Server 接口代碼。
- TProtocol：序列化協議（二進制/JSON/壓縮）。
- TTransport：傳輸層（Socket/HTTP/內存/文件/加密）。
- Underlying I/O：阻塞/非阻塞/異步網絡 I/O。
二、IDL 數據類型體系
| 類別 | 類型 | 對應 Java |
|---|
| 基礎類型 | bool | boolean (1 byte) |
| byte | byte |
| i16 | short |
| i32 | int |
| i64 | long |
| double | double |
| string | String (UTF-8) |
| binary | byte[] |
| 結構體 | struct { 1: i32 id, 2: string name } | 生成 Java Bean (實現 TBase) |
| 容器 | list<t> / set<t> / map<t1,t2> | List/Set/Map |
| 異常 | exception | extends Exception |
| 服務 | service MyService { i32 add(1:i32 a, 2:i32 b) } | 生成 Client/Processor 接口 |
三、傳輸協議選型指南
| 協議 | 特點 | 適用場景 |
|---|
| TBinaryProtocol | 二進制、高效、跨語言通用 | **默認首選**，生產環境標準 |
| TCompactProtocol | VLQ 變長編碼，體積更小 | 帶寬敏感、移動端、大對象傳輸 |
| TJSONProtocol | JSON 文本，可讀、調試友好 | Web 前端直連、調試、異構系統集成 |
| TSimpleJSONProtocol | 只寫 JSON，極簡 | 腳本語言單向調用 |
| TDebugProtocol | 文本可讀，僅調試 | 開發調試階段 |
四、傳輸層與 Server 類型
| 層級 | 實現 | 特點 |
|---|
| Transport | TSocket | 阻塞 Socket，最常用 |
| TFramedTransport | 幀編碼，非阻塞，配合 NIO |
| TFileTransport | 文件讀寫，無 Java 實現 |
| TMemoryTransport | 內存 ByteArray，測試用 |
| TZlibTransport | zlib 壓縮，無 Java 實現 |
| Server | TSimpleServer | 單線程阻塞，測試用 |
| TThreadPoolServer | 線程池阻塞，生產常用 |
| TNonblockingServer | NIO 非阻塞，高併發 |
五、完整構建步驟（以 Java 為例）
- 下載
thrift-0.9.3.exe 重命名放入 C:\Windows（或任意 PATH 目錄）。
- 編寫
ThriftServer.thrift IDL 文件。namespace java com.example.thrift
service ThriftServer {
string sayHello(1: string name)
i32 add(1: i32 a, 2: i32 b)
}
- 生成代碼：
thrift -r -gen java ThriftServer.thrift → 生成 gen-java 目錄。
- 將生成代碼複製到 Server/Client 模塊，實現
ThriftServer.Iface 接口。public class ThriftServerImpl implements ThriftServer.Iface {
@Override public String sayHello(String name) { return "Hello " + name; }
@Override public int add(int a, int b) { return a + b; }
}
- Server 端啟動：
TProcessor processor = new ThriftServer.Processor<ThriftServer.Iface>(new ThriftServerImpl());
TServerTransport transport = new TServerSocket(9090);
TServer server = new TThreadPoolServer(new TThreadPoolServer.Args(transport).processor(processor));
server.serve();
- Client 端調用：
TTransport transport = new TSocket("localhost", 9090);
TProtocol protocol = new TBinaryProtocol(transport);
ThriftServer.Client client = new ThriftServer.Client(protocol);
transport.open();
System.out.println(client.sayHello("Thrift"));
System.out.println(client.add(3, 5));
transport.close();
六、跨應用部署注意事項
- Server 端打包生成的 Thrift 代碼為 JAR，Client 端作為依賴引入（Maven install/deploy）。
- IDL 變更需**重新生成代碼、重新部署雙端**，不支持動態 Schema 演進（不如 Protobuf/gRPC 靈活）。
- 異常處理：定義
exception 並在服務拋出，Client 捕獲 TApplicationException 解析。
- 超時與重試：Client 端配置
TConfiguration 或自行封裝重試邏輯。
七、總結
Thrift 以「IDL 驅動代碼生成、多協議多傳輸可插拔」實現了高性能跨語言 RPC。優勢在於成熟穩定、語言覆蓋廣、二進制協議高效；短板在於 IDL 變更需重新編譯部署、無內建服務治理（需配合 Zookeeper/Consul）、社區活躍度不如 gRPC。存量項目維護首選，新項目可評估 gRPC/Protobuf。
