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();
}
}
}
}
工程结构目录
