Apache Thrift 使用教程

2024-08-07 09:00:14作者：薛曦旖Francesca

项目介绍

Apache Thrift 是一个轻量级、语言无关的软件栈，用于实现点对点的RPC（远程过程调用）。它提供了一系列干净的数据传输、数据序列化和应用层处理的抽象和实现。Thrift 的代码生成系统接受一个简单的定义语言作为输入，并生成跨编程语言的代码，这些代码使用抽象的栈来构建互操作的RPC客户端和服务器。

项目快速启动

安装 Thrift 编译器

首先，你需要安装 Thrift 编译器。以下是安装步骤：

下载 Thrift 源码：

git clone https://github.com/apache/thrift.git
cd thrift

生成配置脚本：
```
./bootstrap.sh
```
配置并编译：
```
./configure
make
sudo make install
```

编写 Thrift 文件

创建一个名为 example.thrift 的文件，内容如下：

namespace java com.example

service HelloService {
    string sayHello(1: string name)
}

生成代码

使用 Thrift 编译器生成代码：

thrift --gen java example.thrift

编写服务端和客户端代码

服务端代码

package com.example;

import org.apache.thrift.server.TServer;
import org.apache.thrift.server.TSimpleServer;
import org.apache.thrift.transport.TServerSocket;
import org.apache.thrift.transport.TTransportException;

public class HelloServer {
    public static void main(String[] args) {
        try {
            HelloServiceImpl handler = new HelloServiceImpl();
            HelloService.Processor<HelloServiceImpl> processor = new HelloService.Processor<>(handler);
            TServerSocket serverTransport = new TServerSocket(9090);
            TServer server = new TSimpleServer(new TServer.Args(serverTransport).processor(processor));
            System.out.println("Starting the simple server...");
            server.serve();
        } catch (TTransportException e) {
            e.printStackTrace();
        }
    }
}

客户端代码

package com.example;

import org.apache.thrift.TException;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocol;
import org.apache.thrift.transport.TSocket;
import org.apache.thrift.transport.TTransport;

public class HelloClient {
    public static void main(String[] args) {
        try {
            TTransport transport = new TSocket("localhost", 9090);
            transport.open();
            TProtocol protocol = new TBinaryProtocol(transport);
            HelloService.Client client = new HelloService.Client(protocol);
            String result = client.sayHello("World");
            System.out.println("Result: " + result);
            transport.close();
        } catch (TException x) {
            x.printStackTrace();
        }
    }
}