Thrift简明教程

Thrift是个RPC框架，它的目标是为各种流行的开发语言提供便利的RPC调用机制，而不需要使用那些开销巨大的方式，比如SOAP。

Thrift使用语言中立的服务定义文件(IDL，接口描述语言)，描述数据类型和服务接口。这个文件会被用作引擎的输入，编译器生成代码为每种支持的语言生成RPC客户端代码库。这种静态生成的设计让它非常容易被开发者所使用，而且因为类型验证都发生在编译期而非运行期，所以代码可以很有效率地运行。

Apache Thrift，它采用接口描述语言(IDL)定义并创建服务，支持可扩展的跨语言服务开发，所包含的代码生成引擎可以在多种语言中，如 C++, Java, Python, PHP, Ruby, Erlang, Perl, Haskell, C#, Cocoa, Smalltalk 等创建高效的、无缝的服务，其传输数据采用二进制格式，相对 XML 和 JSON 体积更小，对于高并发、大数据量和多语言的环境更有优势。

Thrift 服务开发流程，简单概述如下：

1、定义IDL文件(xxx.thrift文件)

2、用xxx.thrift文件生成Java代码(服务接口文件)

3、服务端实现(创建服务)：实现服务接口，开启服务器

4、客户端实现(服务消费)：引入接口，进行远程调用。

Thrift 环境

总体感觉，安装thrift环境，不算简单，而且很多人不清楚安装的那些，到底能干啥？

Mac 安装thrift可参考：https://blog.csdn.net/u010827436/article/details/44303897

目前感觉，安装thrift的目的，就是能够使用thrift 命令，将xxx.thrift文件生成Java代码(仅个人简单的理解)；而生成Java代码有多种方式，安装thrift对初学者来说，占据学习的一部分事件，不推荐。

下面快速开始一个简单的Demo，供初学者对thrift有一个直观的了解。

1、定义一个IDL接口描述文件

namespace java com.ljheee.thrift service QueryService{ string query(1:string query) } 

这个IDL接口描述文件，采用平台中立、语言中立的方式，描述数据类型和服务接口；即RPC调用过程中，调用方与服务提供方之间通信，传输的什么数据结构、调用的哪个服务接口，是需要在这个.thrift文件中约定清楚的。

具体文件含义参考：

2、用xxx.thrift文件生成Java代码(服务接口文件)

如果已经安装了thrift环境，那么可以直接使用命令

thrift -gen java demoHello.thrift

生成Java代码的命令，win、Mac下都相同。命令执行后，会生成一个gen-java文件夹。

如果还没有安装thrift，不要紧，我这里提供一个下载，先快速上手，预览全观。（复制里面全部内容，新建文件到对QueryService.java）
https://github.com/ljheee/thrift-demo/blob/master/src/main/java/com/ljheee/thrift/service/QueryService.java
其实由第1步的QueryService.thrift文件，大概可以看出，定义了一个Java service，里面有一个方法query(String query)。可以预测，它大概是要定义一个接口：

public interface QueryService { public String query(String query) ; } 

事实上，就是这样。该接口就是服务提供方和服务调用方之间的约定。服务端通过完成接口的具体实现，对外提供服务，客户端引入该Java接口，进行远程调用。当然这只是简单描述，thrift生成的QueryService接口里面也有很多它特定的东西，如传输协议、序列化方式等。

3、服务端实现(创建服务)

实现服务接口，开启服务器。

把第2步生成的Java文件（QueryService.java），copy到服务器端工程，注意package不要错，然后新建类implements QueryService.Iface

package com.ljheee.thrift.service.impl; import com.ljheee.thrift.service.QueryService; import org.apache.thrift.TException; public class QueryServiceImpl implements QueryService.Iface { @Override public String query(String query) throws TException { return "Hello,"+query; } } 

开启服务器，等待客户端远程调用

package com.ljheee.thrift; import com.ljheee.thrift.service.QueryService; import com.ljheee.thrift.service.impl.QueryServiceImpl; import org.apache.thrift.TProcessor; import org.apache.thrift.protocol.TBinaryProtocol; import org.apache.thrift.server.TServer; import org.apache.thrift.server.TSimpleServer; import org.apache.thrift.transport.TServerSocket; public class Server { public static final int SERVER_PORT = 9999; public static final String SERVER_IP = "localhost"; public static final int TIMEOUT = 30000; public static void main(String[] args) { try { System.out.println("QueryService TSimpleServer start ...."); TProcessor tprocessor = new QueryService.Processor<QueryService.Iface>(new QueryServiceImpl()); // 简单的单线程服务模型，一般用于测试 TServerSocket serverTransport = new TServerSocket(SERVER_PORT); TServer.Args tArgs = new TServer.Args(serverTransport); tArgs.processor(tprocessor); tArgs.protocolFactory(new TBinaryProtocol.Factory()); // tArgs.protocolFactory(new TCompactProtocol.Factory()); // tArgs.protocolFactory(new TJSONProtocol.Factory()); TServer server = new TSimpleServer(tArgs); server.serve(); } catch (Exception e) { System.out.println("Server start error!!!"); e.printStackTrace(); } } } 

4、客户端实现(服务消费)

引入生成接口，进行远程调用。

同样把第2步生成的Java文件(QueryService.java)，copy到客户端工程里面。本系统为演示方便，在同一个工程中放入了server 和Client的类。

package com.ljheee.thrift; import com.ljheee.thrift.service.QueryService; import org.apache.thrift.TException; import org.apache.thrift.protocol.TBinaryProtocol; import org.apache.thrift.protocol.TProtocol; import org.apache.thrift.transport.TSocket; import org.apache.thrift.transport.TTransport; import org.apache.thrift.transport.TTransportException; /** * Created by lijianhua04 on 2018/7/27. */ public class Client { public static final int SERVER_PORT = 9999; public static final String SERVER_IP = "localhost"; public static final int TIMEOUT = 30000; public static void main(String[] args) { TTransport transport = null; try { transport = new TSocket(SERVER_IP, SERVER_PORT, TIMEOUT); // 协议要和服务端一致 TProtocol protocol = new TBinaryProtocol(transport); // TProtocol protocol = new TCompactProtocol(transport); // TProtocol protocol = new TJSONProtocol(transport); QueryService.Client client = new QueryService.Client(protocol); transport.open(); String result = client.query("ljh"); System.out.println("Thrify client result =: " + result); } catch (TTransportException e) { e.printStackTrace(); } catch (TException e) { e.printStackTrace(); } finally { if (null != transport) { transport.close(); } } } } 

工程结构目录

https://github.com/ljheee/thrift-demo