Thrift in python

发布时间:2019-09-15 09:58:38编辑:auto阅读(1778)

    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已经帮做好了。具体组件怎么选择,多尝试吧。


关键字