Thrift 是一个开源的跨语言服务开发框架，由Facebook开发并贡献给了Apache基金会。它通过定义一种中间表示（IDL，Interface Description Language）来描述数据结构和服务接口，然后使用Thrift编译器将这些定义转换为不同编程语言的代码，简化了分布式系统中服务器和客户端之间的通信。这个文档是关于如何使用Thrift在Java环境下开发服务器和客户端的详细指南。
1. 创建 THRIFT 文件
创建Thrift文件是整个过程的第一步。Thrift文件（如`testJava.thrift`）定义了服务接口和数据类型。在`testJava.thrift`的例子中，定义了一个名为`Something`的服务，它有一个名为`ping`的方法，返回一个i32类型的整数。Thrift IDL语法简洁且直观，类似于C或C++的头文件。
```thrift
namespace java Test
service Something {
i32 ping()
}
```
1.1 编写 `testJava.thrift`
- `namespace java Test` 指定了生成的Java代码应该放在`Test`这个包下。
- `service Something` 定义了一个名为`Something`的服务。
- `i32 ping()` 是服务中的一个方法，无参数，返回一个整数。
1.2 运行 THRIFT 编译器
使用Thrift编译器将`testJava.thrift`文件转换为Java代码。在命令行中执行：
```
thrift --gen java testJava.thrift
```
这将在当前目录下生成一个`gen-java`文件夹，其中包含了Java服务接口、数据结构以及必要的辅助类。
2. 创建 JAVA 服务器
2.1 编写 `SomethingImpl.java`
实现服务接口`Something`。你需要创建一个类，如`SomethingImpl`，实现`Something`接口，并提供`ping`方法的实现。
```java
public class SomethingImpl implements Something.Iface {
@Override
public int ping() {
// 实现ping方法的具体逻辑
return 0;
}
}
```
2.2 创建 `Server.java`
创建一个Java服务器，使用`TServer`类来启动和管理Thrift服务。例如：
```java
import org.apache.thrift.server.TServer;
import org.apache.thrift.server.TThreadPoolServer;
import org.apache.thrift.transport.TServerSocket;
public class Server {
public static void main(String[] args) throws Exception {
TServerSocket serverTransport = new TServerSocket(9090);
Something.Processor<SomethingImpl> processor = new Something.Processor<>(new SomethingImpl());
TServer server = new TThreadPoolServer(new TThreadPoolServer.Args(serverTransport).processor(processor));
System.out.println("Starting the server...");
server.serve();
}
}
```
这里，服务器监听9090端口，处理`Something`服务请求。
3. 创建 JAVA 客户端
客户端代码使用Thrift生成的`Something$Client`类与服务器进行通信。创建一个`Client.java`，如下：
```java
import org.apache.thrift.TException;
import org.apache.thrift.transport.TTransport;
import org.apache.thrift.transport.TTransportException;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.protocol.TBinaryProtocol;
public class Client {
public static void main(String[] args) {
try {
TTransport transport = new TSocket("localhost", 9090);
TBinaryProtocol protocol = new TBinaryProtocol(transport);
Something.Client client = new Something.Client(protocol);
transport.open();
System.out.println("Pong: " + client.ping());
transport.close();
} catch (TTransportException e) {
e.printStackTrace();
} catch (TException e) {
e.printStackTrace();
}
}
}
```
4. 编译及运行
4.1 编译
使用Java编译器将生成的Java源代码编译成字节码：
```bash
javac -cp .:`thrift-<version>-lib.jar`:./* Server.java Client.java
```
确保`thrift-<version>-lib.jar`是Thrift库的正确版本。
4.2 运行
首先启动服务器，然后运行客户端：
```bash
java -cp .:`thrift-<version>-lib.jar`:. Server
# 在另一个终端窗口运行
java -cp .:`thrift-<version>-lib.jar`:. Client
```
这样，你就完成了一个简单的Thrift Java服务器和客户端的开发。Thrift的强大之处在于它可以轻松地扩展到其他语言，使得跨语言服务调用变得简单高效。同时，Thrift还支持多种传输协议和处理模型，可以根据实际需求进行选择。
