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{
@Override
public 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
周末愉快，休息好明上班~