开发速度快(二)

稳定/广泛使用Thrift的数据类型Thrift的协议Thrift的传输层Thrift的服务端类型Thrift入门示例(一)

编写Thrift

Thrift读音[θrɪft]是一个轻量级、跨语言的远程服务调用框架最初由Facebook开发后面进入Apache开源项目。

它通过自身的IDL中间语言,

并借助代码生成引擎生成各种主流语言的RPC服务端/客户端模板代码。

Thrift支持多种不同的编程语言包括C、Java、Python、PHP、Ruby等本系列主要讲述基于Java语言的Thrift的配置方式和具体使用。

Thrift软件栈分层从下向上分别为传输层(Transport

Layer)、协议层(Protocol

Layer)传输层负责直接从网络中读取和写入数据它定义了具体的网络传输协议比如说TCP/IP传输等。

协议层(Protocol

Layer)协议层定义了数据传输格式负责网络传输数据的序列化和反序列化比如说JSON、XML、二进制数据等。

处理层(Processor

Layer)处理层是由具体的IDL接口描述语言生成的封装了具体的底层网络传输和序列化方式并委托给用户实现的Handler进行处理。

服务层(Server

Layer)整合上述组件提供具体的网络线程/IO服务模型形成最终的服务。

(一)

IDL文件利用编译生成器自动生成服务端骨架(Skeletons)和客户端桩(Stubs)。

从而省去开发者自定义和维护接口编解码、消息传输、服务器多线程模型等基础工作。

服务端只需要按照服务骨架即接口编写好具体的业务处理程序(Handler)即实现类即可。

客户端只需要拷贝IDL定义好的客户端桩和服务对象然后就像调用本地对象的方法一样调用远端服务。

(二)

通过维护Thrift格式的IDL接口描述语言文件注意写好注释即可作为给Client使用的接口文档使用也自动生成接口代码始终保持代码和文档的一致性。

且Thrift协议可灵活支持接口的可扩展性。

(三)

Protobuf且更加易读易懂特别是RPC服务接口的风格就像写一个面向对象的Class一样简单。

初学者只需参照thrift.apache.org/一个多小时就可以理解Thrift

(四)

Java、Python、PHP、Ruby、Erlang、Perl、Haskell、C#、Cocoa、JavaScript、Node.js、Smalltalk等多种语言即可生成上述语言的服务器端和客户端程序。

对于我们经常使用的Java、PHP、Python、C支持良好虽然对iOS环境的Objective-C(Cocoa)支持稍逊但也完全满足我们的使用要求。

(五)

Thrift在很多开源项目中已经被验证是稳定和高效的例如Cassandra、Hadoop、HBase等国外在Facebook中有广泛使用国内包括百度、美团小米、和饿了么等公司。

Thrift

Thrift可以让用户选择客户端与服务端之间传输通信协议的类别在传输协议上总体划分为文本(text)和二进制(binary)传输协议。

为节约带宽提高传输效率一般情况下使用二进制类型的传输协议为多数有时还会使用基于文本类型的协议这需要根据项目/产品中的实际需求。

常用协议有以下几种

TBinaryProtocol二进制编码格式进行数据传输TCompactProtocol高效率的、密集的二进制编码格式进行数据传输TJSONProtocol

使用JSON文本的数据编码协议进行数据传输TSimpleJSONProtocol只提供JSON只写的协议适用于通过脚本语言解析

TSocket使用阻塞式I/O进行传输是最常见的模式TNonblockingTransport使用非阻塞方式用于构建异步客户端TFramedTransport使用非阻塞方式按块的大小进行传输类似于Java中的NIO

TSimpleServer单线程服务器端使用标准的阻塞式I/OTThreadPoolServer多线程服务器端使用标准的阻塞式I/OTNonblockingServer单线程服务器端使用非阻塞式I/OTHsHaServer半同步半异步服务器端基于非阻塞式IO读写和多线程工作任务处理TThreadedSelectorServer多线程选择器服务器端对THsHaServer在异步IO模型上进行增强

Thrift入门示例

IDL编译器下载地址http://thrift.apache.org/docs/install。

b).

下载Windows安装环境的.exe文件将thrift.exe的路径加入环境变量中。

在Idea上安装Thrift编辑插件。

c).

由于未指定代码生成的目标下。

这里生成一个HelloWorldService.java类文件文件大小超过数千行下面截取一部分核心代码。

public

org.apache.thrift.TException;}public

interface

org.apache.thrift.async.AsyncMethodCallbackString

resultHandler)

org.apache.thrift.TException;}public

static

org.apache.thrift.TServiceClient

implements

org.apache.thrift.TServiceClientFactoryClient

{public

getClient(org.apache.thrift.protocol.TProtocol

prot)

getClient(org.apache.thrift.protocol.TProtocol

iprot,

org.apache.thrift.protocol.TProtocol

oprot)

Client(org.apache.thrift.protocol.TProtocol

prot)

Client(org.apache.thrift.protocol.TProtocol

iprot,

org.apache.thrift.protocol.TProtocol

oprot)

org.apache.thrift.async.TAsyncClient

implements

org.apache.thrift.async.TAsyncClientFactoryAsyncClient

{private

org.apache.thrift.async.TAsyncClientManager

org.apache.thrift.protocol.TProtocolFactory

Factory(org.apache.thrift.async.TAsyncClientManager

clientManager,

org.apache.thrift.protocol.TProtocolFactory

protocolFactory)

clientManager;this.protocolFactory

AsyncClient

getAsyncClient(org.apache.thrift.transport.TNonblockingTransport

transport)

AsyncClient(org.apache.thrift.protocol.TProtocolFactory

protocolFactory,

org.apache.thrift.async.TAsyncClientManager

clientManager,

org.apache.thrift.transport.TNonblockingTransport

transport)

org.apache.thrift.async.AsyncMethodCallbackString

resultHandler)

___transport);this.___currentMethod

method_call;___manager.call(method_call);}//

省略.....}//

}对于开发人员而言使用原生的Thrift框架仅需要关注以下四个核心内部接口/类Iface,

AsyncIface,

Iface服务端通过实现HelloWorldService.Iface接口向客户端的提供具体的同步业务逻辑。

AsyncIface服务端通过实现HelloWorldService.Iface接口向客户端的提供具体的异步业务逻辑。

Client客户端通过HelloWorldService.Client的实例对象以同步的方式访问服务端提供的服务方法。

AsyncClient客户端通过HelloWorldService.AsyncClient的实例对象以异步的方式访问服务端提供的服务方法。

(二)

新建maven工程引入thrift的依赖这里使用的是版本0.10.0。

dependencygroupIdorg.apache.thrift/groupIdartifactIdlibthrift/artifactIdversion0.10.0/version/dependencyb).

将生成类的HelloWorldService.java源文件拷贝进项目源文件目录中并实现HelloWorldService.Iface的定义的say()方法。

public

ServerSocket(ServerConfig.SERVER_PORT);TServerSocket

serverTransport

TServerSocket(serverSocket);HelloWorldService.Processor

processor

HelloWorldService.ProcessorHelloWorldService.Iface(new

HelloWorldServiceImpl());TBinaryProtocol.Factory

protocolFactory

TBinaryProtocol.Factory();TSimpleServer.Args

tArgs

TSimpleServer.Args(serverTransport);tArgs.processor(processor);tArgs.protocolFactory(protocolFactory);//

一般用于测试TServer

TSimpleServer(tArgs);System.out.println(Running

Simple

TSocket(ServerConfig.SERVER_IP,

ServerConfig.TIMEOUT);TProtocol

protocol

TBinaryProtocol(transport);HelloWorldService.Client

client

HelloWorldService.Client(protocol);transport.open();String

result

client.say(Leo);System.out.println(Result

result);}

运行服务端程序服务端在指定端口监听客户端的连接请求控制台输出启动日志

f).

运行客户端程序客户端通过网络请求HelloWorldService的say()方法的具体实现控制台输出返回结果

这里使用的一个基于单线程同步的简单服务模型一般仅用于入门学习和测试

本文对Thrift的概念做了相关介绍体验了一番thrift程序如何编写