首页 > 其他 > 详细

Thrift学习记录

时间:2015-03-31 17:37:32      阅读:166      评论:0      收藏:0      [点我收藏+]

Thrift学习记录

Thrift是一个软件框架,用来进行可扩展且跨语言的服务的开发。它结合了功能强大的软件堆栈和代码生成引擎,以构建在C++,Java,Python,PHP,Ruby,Erlang, Perl, Haskell, C#, Cocoa, JavaScript, Node.js, Smalltalk, and OCaml等等编程语言间无缝结合的、高效的服务。

Thrift服务开发的三个步奏:(如下图)

编写Thrift IDL,运行thrift命令生成相应的服务代码。

服务端编码(需要thrift生成的服务代码)。

客户端编码(需要thrift生成的服务代码)

 

一、编写Thrift IDL:

在*.thrift文件中,有以下基本类型。

基本类型:

       bool:布尔值,true 或 false,对应 Java 的 boolean

       byte:8 位有符号整数,对应 Java 的 byte

       i16:16 位有符号整数,对应 Java 的 short

       i32:32 位有符号整数,对应 Java 的 int

       i64:64 位有符号整数,对应 Java 的 long

       double:64 位浮点数,对应 Java 的 double

       string:utf-8编码的字符串,对应 Java 的 String

结构体类型:

struct:定义公共的对象,类似于 C 语言中的结构体定义,在 Java 中是 一个 JavaBean

容器类型:

       list:对应 Java 的 ArrayList

       set:对应 Java 的 HashSet

       map:对应 Java 的 HashMap

异常类型: 

exception:对应 Java 的 Exception

服务类型:

service:对应服务的类

实例:

环境搭建:下载JDK,并且配置环境变量。(JDK在ghost的系统里已经配置好)

 

下载:thrift-0.9.2.exe

生成服务代码命令:将*.thrift文件和thrift-0.9.2.exe放在同一目录下

使用cmd进入该目录下:

thrift-0.9.2.exe -r -gen java ./thriftTest.thrift

 

将生成的java文件分别拷贝至服务端和客户端,进行下步编码。

二、支持的数据传输格式、数据传输方式和服务模型(*为重点关注)

  1. 数据传输协议

TBinaryProtocol – 二进制格式.

TCompactProtocol – 压缩格式

TJSONProtocol – JSON格式(*)

TSimpleJSONProtocol –提供JSON只写协议, 生成的文件很容易通过脚本语言解析。

TDebugProtocol – 使用易懂的可读的文本格式,以便于debug

  1. 支持的数据传输方式

TSocket -阻塞式socker

TFramedTransport – 以frame为单位进行传输,非阻塞式服务中使用。

TFileTransport – 以文件形式进行传输。

TMemoryTransport – 将内存用于I/O. java实现时内部实际使用了简单的ByteArrayOutputStream。

TZlibTransport – 使用zlib进行压缩, 与其他传输方式联合使用。当前无java实现。

TBufferedTransport – 对某个transport对象操作的数据进行buffer,即从buffer中读取数据进行传输,或将数据直接写入到buffer

  1. 支持的服务模型

       TSimpleServer – 简单的单线程服务模型,常用于测试

TThreadedServer – 多线程服务模型使用标准的阻塞式IO,每个请求创建一个线程

TThreadPoolServer – 多线程服务模型,使用标准的阻塞式IO。(*)

TNonblockingServer – 多线程服务模型,使用非阻塞式IO(需使用TFramedTransport数据传输方式)(*)

三、服务端编码

实现服务处理接口impl(工作量大在接口impl类的业务实现编写)

创建TProcessor(协议层与用户实现的服务代码的纽带)

创建TServerTransport(数据传输方式)

创建TProtocol(数据传输协议)

创建TServer(服务模型)

启动Server

实例:

TProcessor tprocessor = new HelloWorldService.Processor<HelloWorldService.Iface>(new HelloWorldImpl());

// 简单的单线程服务模型,一般用于测试 ()

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();

四、客户端编码

创建Transport(数据传输方式)

创建TProtocol(数据传输协议)

基于TTransport和TProtocol创建 Client

调用Client的相应方法

实例:

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);

    HelloWorldService.Client client = new HelloWorldService.Client(protocol);

transport.open();

String result = client.XXXX ();

}

 

 

实际开发过程:Spring+Thrift

服务器端使用说明

 

  1. 1.     Trend.thrift.dao:spring 的dao层
  2. Trend.thrift.service:IDL生成的java文件
  3. 3.     Trend.thrift.service.impl:具体的业务实现类

 

  1. 4.     Thrift-service.xml

 

 

客户端使用说明:

 

  1. 1.     Trend.thrift.controller:调用接口获取接口返回的数据()

 

  1. 2.     Trend.thrift.service: IDL生成的java文件
  2. 3.     Thrift-client.xml:配置thrift连接池

 

  1. 4.     Thrift.properties:目前以此方式配置,后期加入订阅广播方式实现分布式部署。

 

Thrift学习记录

原文:http://www.cnblogs.com/libaoting/p/thrift.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!