Thrift in python

Thrift官网上的文档很少，从网上搜到的也大都千篇一律，即使是《Thrift: the missing guide》对如何构建python的server和client也没有进行详尽讲述。本博特意看了下thrift提供的python lib，对书写相应的server和client进行了简单的总结，如有错误，欢迎大家指正。

1. Thrift network stack

Transport

Transport网络读写（socket，http等）抽象，用于和其他thrift组件解耦。

Transport的接口包括：open, close, read, write, flush, isOpen, readAll。

Server端需要ServerTransport（对监听socket的一种抽象），用于接收客户端连接，接口包括：listen, accept, close。

python中Transport的实现包括：TSocket, THttpServer, TSSLSocket, TTwisted, TZlibTransport，都是对某种协议或框架的实现。还有两个装饰器，用于为已有的Transport添加功能，TBufferedTransport（增加缓冲）和TFramedTransport（添加帧）。

在创建server时，传入的时Tranport的工厂，这些Factory包括：TTransportFactoryBase（没有任何修饰，直接返回），TBufferedTransportFactory（返回带缓冲的Transport）和TFramedTransportFactory（返回帧定位的Transport）。

Protocol

Protocol用于对数据格式抽象，在rpc调用时序列化请求和响应。

TProtocol的实现包括：TJSONProtocol，TSimpleJSONProtocol，TBinaryProtocol，TBinaryPotocolAccelerated，TCompactProtocol。

上面每种类型，都有对应的Factory类，用于创建该类对象。

Processor

Processor对stream读写抽象，最终会调用用户编写的handler已响应对应的service。具体的Processor有compiler生成，用户需要实现service的实现类。

Server

Server创建Transport，输入、输出的Protocol，以及响应service的handler，监听到client的请求然后委托给processor处理。

TServer是基类，构造函数的参数包括：

1) processor, serverTransport

2) processor, serverTransport, transportFactory, protocolFactory

3) processor, serverTransport, inputTransportFactory, outputTransportFactory, inputProtocolFactory, outputProtocolFactory

TServer内部实际上需要3）所列的参数，1）和2）会导致对应的参数使用默认值。

TServer的子类包括：TSimpleServer, TThreadedServer, TThreadPoolServer, TForkingServer, THttpServer, TNonblockingServer, TProcessPoolServer

TServer的serve方法用于开始服务，接收client的请求。

2. Code generated

constants.py: 包含声明的所有常量

ttypes.py: 声明的struct，实现了具体的序列化和反序列化

SERVICE_NAME.py: 对应service的描述文件，包含了：

Iface: service接口定义

Client: client的rpc调用桩

Processor: 处理service的具体方法调用，需要传入server端实现的handler

3. 用法

Thrift的用法实际上很简单，定义好IDL，然后实现service对应的handler（方法名、参数列表与接口定义一致接口），最后就是选择各个组件。需要选择的包括：Transport（一般都是socket，只是十分需要选择buffed和framed装饰器factory），Protocol，Server。

就是这么简单，大部分事情thrift已经帮做好了。具体组件怎么选择，多尝试吧。

Thrift in python,古老的榕树,5-wow.com