thrift学习笔记

最近看到项目有用thrift，值此周日闲着也是闲着，先了解一个大概，后边在项目中再深度感悟吧。这里首先介绍一下thrift是做什么的，一般的我们都知道程序不是简单的自己处理自己的数据，很多大型系统往往需要跨系统进行调用，但是跨系统调用往往有一个问题就是你怎么调用的，聪明的小伙伴也许直接想到了http，但是有没有想过http有什么问题？首先是安全问题啥的，还有就是要不断的json到对象的互相转化什么的。其实都很费时间，如此一来就造成了技术问题导致的响应时间问题。所以对于http来说固然是好，但是否有更好的办法？我们知道网络传输是一层一层的协议的包装。那么显然最快的方式是放到最外层了，省去不必要的链路解析工作。但是我们的tcp/ip肯定是要保留的，因此我们的办法要么就是重新造一个tcp/Ip，要么就是省去最上层的应用层协议，直接怼着tcp来干。这样不就节省了协议解析的时间时间么，对我们的rpc远程调用的本质就是这意思，用http来走的话不是不可以，大如springcloud也都是采用的http来走的，但其实上我们还可以直接走tcp，但是tcp的肯定需要服务端和客户端，因此走tcp的问题就是开发比较费事，那么有没有一套工具让我们开发变快，也就是帮我们自动生成，我们简单的修改一下就可以直接用了，答案是有的，这块比较出名的是facebook开源的thrift。这个thrift就是一个开源的能够生成跨语言rpc调用的客户端和服务端的代码。听起来很厉害，其实本质还是上边说的这些想法的一种实践，主要是thrift能跨语言生成，也就是说我们可以用java去rpc调用python的接口，甚至是C#的接口，这块你是否感觉thrift能够让你的应用跨语言进行rpc调用的功能呢，答案是yes。Thrift解决的痛点问题就是跨语言的rpc调用问题。当然thrift定义了一套规范，这就是thrift协议。

既然如此，如何开始呐？首先我们要知道我们的客户端和服务端的代码不是自己写的，我们只需要将我们客户端和服务端定义的接口定义好，然后让调用我们的thrift来将我们定义的接口生成指定的代码。然后我们拿着这代码到客户端和服务端稍微改造一下，然后添加进去。就ok了，那么如何安装这个thrift工具包？

1.安装

https://thrift.apache.org/download.html

作者这块还是window的老本本，咋就下载这个window。下载好之后，把它配置环境变量，这样我们就可以直接用thrift来调用了。

下载之后就是一个exe文件。您也别觉得可笑，大道至简，大道至简。

2.客户端和服务端代码生成

我们要生成的代码是目标代码，那么我们要编写一些脚本让thrift来生成我们需要的目标语言代码，考虑到rpc调用的本质其实也就是一个标志，这个接口就是标志。因此我们要按thrift的规范写thrift接口。

这块我们学着写一下thrift接口。

//生成java的目录 service.demo，生成的脚本放这个目录下。
namespace java service.demo
//service用来定义接口，Hello表示约定的客户端和服务端的接口的名称，也就是生成的文件的名称
service Hello{
//定义一个接口，helloString，传入和返回数据类型都是string的。string helloString(1:string para)
}

定义好之后，我们保存为thrift后缀的文件。

这个时候，我们用我们的thrift工具来生成我们的java版本的客户端和服务端代码。

Thrift.exe -r gen java tianjingle.thrift  //用thrift来生成java语言的客户端和服务端代码。

在gen-java的目录中

3.使用

拿到我们的Hello.java文件感觉好像哪里不对，不应该是两个java文件么，我们打开看一下。为了查看类方便，我们直接用idea来看。

这块我们要在项目的pom文件中加入thrift的maven依赖，因为thrift生成的是thrift的java的代码。因此我们直接导入：

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

之后我们查看我们idea中的Hello.java代码

我们在类hello的类的层次上看到以下元素。

processor主要用来处理服务端数据交互，helloString_args主要用来rpc调用参数的传递和读写，helloString_result用来处理rpc的结果读写问题。这块记住thrift生成的代码中包括client、server、还有一些定制的读写类即可。

4.测试效果

在上边的做好之后，我们开始写我们的客户端代码。

客户端代码：

public class Client {public static void main(String[] args) {System.out.println("客户端启动....");TTransport transport = null;try {TConfiguration tconfig=new TConfiguration();transport = new TSocket(tconfig,"localhost", 9898, 30000);// 协议要和服务端一致TProtocol protocol = new TBinaryProtocol(transport);Hello.Client client = new Hello.Client(protocol);transport.open();String result = client.helloString("ceshi");System.out.println(result);} catch (TException e) {e.printStackTrace();} finally {if (null != transport) {transport.close();}}}
}

服务端接口实现接口：

public class HelloServiceImpl implements Hello.Iface{@Overridepublic String helloString(String para) throws TException {return "this is thrift server ,i has received your message:"+para;}
}

服务端：

public class Server {/*** 启动thrift服务器* @param args*/public static void main(String[] args) {try {System.out.println("服务端开启....");TProcessor tprocessor = new Hello.Processor(new HelloServiceImpl());// 简单的单线程服务模型TServerSocket serverTransport = new TServerSocket(9898);TServer.Args tArgs = new TServer.Args(serverTransport);tArgs.processor(tprocessor);tArgs.protocolFactory(new TBinaryProtocol.Factory());TServer server = new TSimpleServer(tArgs);server.serve();}catch (TTransportException e) {e.printStackTrace();}}
}

分别启动服务端，客户端。看到控制台打印了输出结果如下。RPC调用成功。

Thrift的工程实践想法：rpc调用肯定是性能比较好的一种调用方式，这块做的比较好的还可以负载均衡进行调用，这样说的话要做好一个rpc，确实要考虑的问题很多。这块我们从开发角度来看，我们应该将系统对外提供的rpc接口统一打包出来，不要一个项目提供多个rpc访问端口，因为那样就会很乱，最后项目变动的代价改动代价就太大了。

参考文献：thrift入门初探-冬至饮雪：https://www.cnblogs.com/fingerboy/p/6424248.html

周末愉快，休息好明上班~