Thrift功能和使用

为什么需要Thrift

目前程序开发的模式一般为前后端分离和微服务模式，前端（如nodejs）对数据处理后传递到后端，微服务模式下多个模块之间需要进行数据的交互。我们如何进行更好更快的数据交互呢，目前有主要有两种方式，一种是通过HTTP REST的方式，还有一种就是RPC的方式，Thrift就是属于rpc通信的一种方式。

首先说下REST和Thrift的区别
REST是在HTTP基础上建立的数据交互，数据一般采用JSON格式
Thrift是在Socket基础上进行数据交互，数据传输方式灵活，可以通过二进制的方式传递，Thrift提供序列化和反序列化，也可以使用JSON格式

thrift存在的问题

client端是非线程安全的，如果多个客户端使用同一个socket，就会出现服务端错误，所以需要保证socket单线程使用

使用方式

编写thrift文件，通过该文件生成客户端和服务的的接口文件，分别在server和client实现接口文件中的方法，然后就可以直接调用远程服务了。下面对这个概念分别解释

thrift文件

thrift文件是用来生成客户端和服务端接口的文件，通过一条简单的命令就可以生成：
thrift -r --gen <language> <thrift文件>

thrift语法

基本类型
bool：布尔值对应 java boolean
byte:有符号字节对应 java byte
i16：16位有符号整型对应 java short
i32：32位有符号整型对应 java int
i64：64位有符号整型对应 java long
double：64位浮点型对应 java double
string：字符串对应 java String

List<T>：对应 java List<T>
Set<T>：对应 java Set<T>
Map<key,value>：对应java Map<k,v>

结构体
类似于c/c++中的结构体，在结构体中声明类型，不可以有方法
struct Name{
1:i32 number=10,
2:i64 bigNumber,
3:double decimals,
4:string name="thrifty"
}
结构体中的字段required optional
required字段必须填写
optional字段没有赋值则不会被传输，设置_isset为true后才能传输不被丢失

异常
和结构体类似，只是关键字使用exception

枚举
enum <typename> {
<name>
<name>=value
}

服务
类似java中的接口，具体方法由clinet/server去实现
service <name> {
<returntype> <name>(<arguments>)
<returntype> <name>(<arguments>) [throws (<exceptions>)]
}

生成client/server接口

有了thrift文件之后，就可以通过一条命令直接生成client/server接口了
thrift -r --gen <language> <thrift filename>

最后将生成的文件引入到client/server代码中，进行接口实现，就可以在client进行调用了

下面为完整的生成java代码并进行调用的demo

1 首先需要定义一个thrift文件，里面写上client想要调用server端的方法
hello.thrift

service hello{
   string sayHello()
}

2 生成client/server接口文件

thrift --gen java hello.thrift

在gen-java目录下得到hello.java文件

3 在项目中引入接口文件，并对方法进行实现

image.png

server端将生成的hello.java引入项目中，并将hello.Iface接口进行实现

image.png

这个方法就是我们在thrift中定义的接口方法，由server端进行具体的实现

4 服务端调用thrift中的方法对某一端口进行监控

package thriftServer;

import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.server.TServer;
import org.apache.thrift.server.TThreadPoolServer;
import org.apache.thrift.transport.TServerSocket;
import org.apache.thrift.transport.TServerTransport;
import org.apache.thrift.transport.TTransportFactory;
import thriftInterface.hello;
import thriftService.helloImp;

public class GenServer {

    private void startServer(){

        hello.Processor processor = new hello.Processor<hello.Iface>(new helloImp());
        try{
            TServerTransport transport = new TServerSocket(1234);
            TThreadPoolServer.Args args = new TThreadPoolServer.Args(transport);
            args.processor(processor);
            args.protocolFactory(new TBinaryProtocol.Factory());
            args.transportFactory(new TTransportFactory());
            args.minWorkerThreads(10);
            args.maxWorkerThreads(20);
            TServer server = new TThreadPoolServer(args);
            server.serve();

        }catch (Exception e){
            System.out.println(e);
        }


    }

    public static void main(String[] args) {
        GenServer server = new GenServer();
        server.startServer();
    }
    
}

5 客户端通过Client调用该方法即可

package thriftClient;

import org.apache.thrift.TException;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.protocol.TProtocol;
import org.apache.thrift.transport.*;
import thriftInterface.hello;


public class DemoClient {
    private static final String SERVER_IP = "localhost";
    private static final int SERVER_PORT = 1234;
    private static final int TIMEOUT = 1000;

    private void startClient(String userName) {
        TTransport transport = null;
        try {
            transport = new TSocket(SERVER_IP, SERVER_PORT, TIMEOUT);
            TProtocol protocol = new TBinaryProtocol(transport);
            hello.Client client = new hello.Client(protocol);
            transport.open();
            // 调用服务端的方法
            String res = client.sayHello();
            System.out.println("调用返回结果为：" + res);
        } catch (TTransportException e) {
            e.printStackTrace();
        } catch (TException e) {
            e.printStackTrace();
        } finally {
            if (null != transport) {
                transport.close();
            }
        }
    }

    public static void main(String[] args) {
        DemoClient client = new DemoClient();
        client.startClient("hello");
    }

}

6 执行结果
启动服务端，再启动客户端

image.png

至此，完整的client/server调用就完成了

另，maven依赖如下：

<dependencies>
        <dependency>
            <groupId>org.apache.thrift</groupId>
            <artifactId>libthrift</artifactId>
            <version>0.13.0</version>
        </dependency>

        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-api</artifactId>
            <version>1.7.5</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-log4j12</artifactId>
            <version>1.7.5</version>
        </dependency>


    </dependencies>

image.png