博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
thrift学习笔记
阅读量:4212 次
发布时间:2019-05-26

本文共 4019 字,大约阅读时间需要 13 分钟。

最近看到项目有用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的代码。因此我们直接导入:

org.apache.thrift
libthrift
0.14.1

之后我们查看我们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

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

你可能感兴趣的文章
springboot源码解析(四)
查看>>
CompletionService实践
查看>>
YApi在Window上离线安装笔记
查看>>
Mysql学习笔记(十三)查看mysql日志
查看>>
JVM垃圾回收相关知识笔记
查看>>
Curator学习笔记(一)- 读写锁
查看>>
第一次炒股小记
查看>>
《redis in action》ZSet相关命令
查看>>
《redis in action》redis发布订阅
查看>>
《redis in action》sort排序命令
查看>>
《redis in action》redis事务
查看>>
《redis in action》key的自动过期
查看>>
《redis in action》redis持久化简介
查看>>
Oracle RAC Failover 详解
查看>>
批处理 自动修改 IP 地址
查看>>
Oracle RAC LoadBalance
查看>>
v$sql,v$sqlarea,v$sqltext 和 v$sql_plan 说明
查看>>
ORA-31623 When Submitting a Datapump Job [ID 308388.1]
查看>>
Oracle SYSAUX 表空间 说明
查看>>
RAC 安装patch 后启动实例 报错 ORA-00439 feature not enabled- Real Application Clusters 解决方法
查看>>