最近看到项目有用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接口。
代码语言:javascript复制//生成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的代码。因此我们直接导入:
代码语言:javascript复制 <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.测试效果
在上边的做好之后,我们开始写我们的客户端代码。
客户端代码:
代码语言:javascript复制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();
}
}
}
}
服务端接口实现接口:
代码语言:javascript复制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;
}
}
服务端:
代码语言:javascript复制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
周末愉快,休息好明上班~