Java thrift服务器和客户端创建实例代码

下面我将为你详细讲解“Java thrift服务器和客户端创建实例代码”的完整攻略，过程中我会给出两个示例来说明。

创建Thrift服务器

第一步：定义接口和服务

在创建Thrift服务器之前，需要先定义一个接口和一个服务实现该接口。这里以一个简单的示例为例：服务端提供一个加法运算的服务。

定义接口

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

namespace java com.example.addition

service AdditionService {
     i32 add(1:i32 a, 2:i32 b)
}

在这个Thrift文件中，我们定义了一个Java package com.example.addition，其中包含了一个名为 AdditionService 的服务接口，该接口包含一个add方法，接受两个整型参数并返回它们的和。

实现服务

接下来，我们需要实现服务接口中的方法。在 com.example.addition 包下创建一个 AdditionServiceImpl.java 文件，代码如下：

package com.example.addition;

import org.apache.thrift.TException;

public class AdditionServiceImpl implements AdditionService.Iface {
    @Override
    public int add(int a, int b) throws TException {
        return a + b;
    }
}

该类实现了 com.example.addition.AdditionService.Iface 接口，其中 add 方法返回两个传入参数的和。

第二步：生成代码

接下来，我们需要用 Thrift 编译器生成 Java 代码。打开终端，进入 .thrift 文件所在目录，执行以下命令：

thrift --gen java AdditionService.thrift

该命令将生成 Java 代码，生成的代码位于 gen-java/com/example/addition 目录下。其中包括服务接口和客户端代码。

第三步：实现服务

接下来，我们需要创建一个 Thrift 服务器并实现服务。在 com.example.addition 包下创建一个 AdditionServer.java 文件，代码如下：

package com.example.addition;

import org.apache.thrift.TProcessor;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocolFactory;
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 AdditionServer {
    private static int port = 9090;

    public static void main(String[] args) throws TTransportException {
        TServerSocket serverTransport = new TServerSocket(port);
        TBinaryProtocol.Factory protocolFactory = new TBinaryProtocol.Factory();
        TProcessor processor = new AdditionService.Processor<>(new AdditionServiceImpl());

        TServer server = new TSimpleServer(new TServer.Args(serverTransport)
                .protocolFactory(protocolFactory)
                .processor(processor));
        System.out.println("Starting server on port " + port + "...");
        server.serve();
    }
}

该类创建了一个简单的 Thrift 服务器，在9090端口接收请求。其中，processor 参数是我们根据Thrift文件自动生成的一个类，它是一个携带所有所需处理器和协议对象的适配器。在 TServer.Args 中设置 processor 和 protocolFactory 参数，最后调用 serve 方法启动服务器。

第四步：启动服务器

通过 AdditionServer 中的 main 方法启动服务，可以在终端中看到输出 Starting server on port 9090... 提示服务已启动。

创建Thrift客户端

客户端是用于连接到服务器并调用其方法的代码。需要遵循以下步骤来创建Thrift客户端。

第一步：创建连接

通过访问Thrift服务器并创建 TSocket 对象来连接服务器。在 com.example.addition 包下创建一个名为 AdditionClient.java 的文件，代码如下：

package com.example.addition;

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

public class AdditionClient {
    private static final String HOST = "localhost";
    private static final int PORT = 9090;

    private TTransport transport;
    private AdditionService.Client client;

    public AdditionClient() throws TTransportException {
        transport = new TSocket(HOST, PORT);
        transport.open();

        TProtocol protocol = new TBinaryProtocol(transport);
        client = new AdditionService.Client(protocol);
    }

    public int add(int a, int b) throws TTransportException {
        return client.add(a, b);
    }

    public void close() {
        transport.close();
    }
}

在该代码中，我们使用 localhose 和 9090 连接到服务器。 AdditionClient 类的构造函数中创建了一个 TSocket 对象，在该连接上打开 TTransport， 然后创建一个 AdditionService.Client 对象，并将它分配给 client 属性。

第二步：调用远程服务

调用客户端的方法来调用 AdditionServer 定义的远程服务。在 AdditionClient 类中添加以下代码：

AdditionClient client = new AdditionClient();
int a = 5;
int b = 3;
int result = client.add(a, b);
System.out.printf("%d + %d = %d\n", a, b, result);
client.close();

在这个 main 方法中，我们创建了一个 AdditionClient 对象，并通过 client.add(a, b) 调用了服务端的 add 方法。如果一切正常，你应该可以在控制台上看到结果 5 + 3 = 8。

到这里为止，Java Thrift服务器和客户端的创建实例代码已经讲解完毕了，希望这些内容能够对你有所帮助！