Thrift使用总结篇

工程目录如下：

project 

    idl/

gen.bat

thrift.exe

main.thrift

    res/

a.jpg

    lib/

a.py

其中idl里面存放的是thrift相关的配置文件内容。gen.bat的内容如下:

@ECHO OFF
set THRIFT_CODEDEFINE=main.thrift
if "%1"=="" goto genDefault

:genDefault
call thrift-0.7.0.exe --gen py main.thrift
goto end

:genByArg
call thrift-0.7.0.exe --gen java:hashcode %1
call thrift-0.7.0.exe --gen php %1
call thrift-0.7.0.exe --gen py %1
goto end

:exit
exit /b 1

:end
exit /b 0

可以给它传递一个thrift配置文件然后编译输出相应的代码.

ps:如果是py的话中文是个问题的.需要手工置#coding:utf-8

main.thrift的内容如下

namespace py thriftlib.adspub.thrift

exception ThrfitException {
1: i32 errCode,
2: string msg
}

struct ResultInfo{
1: i32 err,
2: string value,
3: string msg
}

struct A {
1: string type,
2: i32 age
}

struct B {
1: i32 id,
2: list a
}
service InfoService {
ResultInfo deployTemplateCreate(1:B deployObject,2:string username);
list deployPlanList(1:string planName);
}

简单介绍一下如何编写thrift配置文件

数据类型：

bool,byte,i16,i32,i64,double,string,binary[二进制类型，在做文件服务器的时候使用]

structs:定义了一个类对象。其实就是一个OOP里面的类

容器类：list,set:集合,map: 字典。包括了三种容器对象

异常：这个跟传统的异常没有太大的差异

服务：类似于定义了一个接口或纯抽象类。程序员要做的就是去实现这些接口然后就可以暴露给客户端调用了。

定义完了thrift文件之后就可以写代码了

handler = DeployInfoHandler()   # 这个就是实现了接口方法的实现类
processor = DeployInfoService.Processor(handler)
transport = TSocket.TServerSocket("0.0.0.0", 10001)
tfactory = TTransport.TBufferedTransportFactory()
pfactory = TBinaryProtocol.TBinaryProtocolFactory()
server = TServer.TThreadedServer(processor, transport, tfactory, pfactory)
server.serve()

对以上代码的简单分析：

（1）.支持的传输格式

TBinaryProtocol   二进制格式

TCompactProtocol  压缩格式

TJSONProtocol     JSON格式

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

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

（2）. 支持的数据传输方式

TSocket     阻塞式socket

THttpTransport 采用HTTP传输协议进行数据传输

TFramedTransport 以frame为单位传输，非阻塞式服务中使用

TFileTransport 以文件形式进行传输

TMemoryTransport 将内存用于I/0，

TZlibTransport 使用zlib进行压缩。

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

(3). 支持的服务模型[主要是服务端类型]

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

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

TThreadPoolServer 多线程服务模型使用标准的阻塞式IO，预先创建一组线程处理请求

TNonblockingServer 多线程服务模型使用非阻塞IO（需要用TFramedTransport数据传输方式 ）

ps:什么叫阻塞与非阻塞？

阻塞IO：socket的阻塞意味着必须要做完IO包括错误才会返回

非阻塞IO：无论操作是否完成都会立刻返回，需要通过其他方式来判断具体操作是否成功

在网络阻塞严重的时候，网络层没有足够的内存来进行写操作，这时候就会出现写不成功的情况，阻塞情况下会尽可能(有可能被中断)等待到数据全部发送完毕， 对于非阻塞的情况就是一次写多少算多少,没有中断的情况下也还是会出现write 到一部分的情况.

相关客户端代码：

tskt = TSocket.TSocket(ip,port)

tskt.setTimeout(self.timeout)

self.transport = TTransport.TBufferedTransport(tskt)

 protocol = TBinaryProtocol.TBinaryProtocol(self.transport)

client = service_class.Client(protocol)

注意：这里面的服务类名就是生成的thrift的接口类

实际工作中要注意的事项：

1、

2、