thrift的简单使用

写在前面

本文一起看下一种由facebook出品的rpc框架thrift。

源码 。

1：开发步骤

1:编写thrift idl文件
2：根据thrift idl文件生成java模板代码
3：继承模板代码的*.Iface接口给出server的具体服务实现
4：使用模板的HelloWorldService.Processor编写server端
5：使用HelloWorldService.Client编写服务端调用程序

2：实战

• 准备编译生成器
  这里 。

• idea准备插件
  

无该步骤也可以

• 编写idl
  hello.thrift:

service HelloWorldService {string say(1: string username)
}

• 通过生成器生成模板文件

$ ./thrift-0.19.0.exe -gen java hello.thrift

生成的模板Java文件很长，主要关注如下几个类即可：

Iface：服务端通过实现此接口提供同步服务
AsyncIface：服务端通过实现此接口提供异步服务
Client:客户端通过此类的实例对象以同步的方式访问服务端
AysyncClient：客户端通过此类的是实例以异步的方式访问服务端

将生成的代码拷贝到项目，备用。

• pom

<dependency><groupId>org.apache.thrift</groupId><artifactId>libthrift</artifactId><version>0.19.0</version>
</dependency>

• service实现类

public class HelloWorldServiceImpl implements HelloWorldService.Iface {@Overridepublic String say(String username) throws TException {return "Hello " + username;}
}

• server类

public class SimpleServer {public static void main(String[] args) throws Exception {ServerSocket serverSocket = new ServerSocket(ServerConfig.SERVER_PORT);TServerSocket serverTransport = new TServerSocket(serverSocket);HelloWorldService.Processor processor =new HelloWorldService.Processor<HelloWorldService.Iface>(new HelloWorldServiceImpl());TBinaryProtocol.Factory protocolFactory = new TBinaryProtocol.Factory();TSimpleServer.Args tArgs = new TSimpleServer.Args(serverTransport);tArgs.processor(processor);tArgs.protocolFactory(protocolFactory);// 简单的单线程服务模型 一般用于测试TServer tServer = new TSimpleServer(tArgs);System.out.println("Running Simple Server");tServer.serve();}
}

启动。

• client类

public class SimpleClient {public static void main(String[] args) {TTransport transport = null;try {transport = new TSocket(ServerConfig.SERVER_IP, ServerConfig.SERVER_PORT, ServerConfig.TIMEOUT);TProtocol protocol = new TBinaryProtocol(transport);HelloWorldService.Client client = new HelloWorldService.Client(protocol);transport.open();String result = client.say("Leo");System.out.println("Result =: " + result);} catch (TException e) {e.printStackTrace();} finally {if (null != transport) {transport.close();}}}
}

运行：

Result =: Hello LeoProcess finished with exit code 0

酱！！！

写在后面

参考文章列表

Apache Thrift系列详解(一) - 概述与入门 。