为什么需要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

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：对应 java List

Set： 对应 java Set

Map： 对应java Map

结构体

类似于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 {

=value

}

服务

类似java中的接口，具体方法由clinet/server去实现

service {

()

() [throws ()]

}

生成client/server接口

有了thrift文件之后，就可以通过一条命令直接生成client/server接口了

thrift -r --gen

最后将生成的文件引入到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(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

image.png

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

另，maven依赖如下：

org.apache.thrift

libthrift

0.13.0

org.slf4j

slf4j-api

1.7.5

org.slf4j

slf4j-log4j12

1.7.5

image.png