一個輕量級的tcp交互,thrift的使用

Apache Thrift 是 Facebook 實現的一種高效的、支持多種編程語言的遠程服務調用的框架。java

  • 安裝thrift 從官網下載 而後按照./configure,make,make install 方式進行安裝,其餘系統能夠參照官網http://thrift.apache.org/docs/install/
  • 定義thrift文件, 至關於通信雙方的接口定義,
    bool Boolean, one byte * 
    i8 (byte) Signed 8-bit integer * 
    i16 Signed 16-bit integer *
     i32 Signed 32-bit integer *
     i64 Signed 64-bit integer * 
    double 64-bit floating point value *
     string String * binary Blob (byte array) 
    * map<t1,t2> Map from one type to another 
    * list<t1> Ordered list of one type 
    * set<t1> Set of unique elements of one type

     

    類型參考https://git-wip-us.apache.org/repos/asf?p=thrift.git;a=blob_plain;f=tutorial/tutorial.thrift
  • 用thrift生成關於thrift定義的代碼,對應各類語言,我這主要是python,也能夠其餘的c++,java,命令是thrift --gen <language> <Thrift filename>
  • server和client的編寫,server要多考慮無阻塞,多進程,保證服務正常,調用thrift生成的類,對應定義好的數據類型。
    def init_handler():
        """ sub-process init handler """
        signal.signal(signal.SIGINT, signal.SIG_DFL)
        signal.signal(signal.SIGTERM, signal.SIG_DFL)
        signal.signal(signal.SIGHUP, signal.SIG_DFL)
        signal.signal(signal.SIGUSR1, debug)
    
    def main():
        """ The main entrance """
        port = sys.argv[1]
        signal.signal(signal.SIGINT, exit_signal_handler)
        signal.signal(signal.SIGTERM, exit_signal_handler)
        signal.signal(signal.SIGHUP, exit_signal_handler)
        signal.signal(signal.SIGUSR1, debug)
    
        gc.set_threshold(20000, 10, 10)
        handler = MaitreyaHandler()
        processor = Maitreya.Processor(handler)
        transport = TSocket.TServerSocket(port=port)
        tfactory = TTransport.TBufferedTransportFactory()
        pfactory = TBinaryProtocol.TBinaryProtocolFactory()
    
        # server = TProcessPoolServer(processor, transport, tfactory, pfactory)
        server = TGeventServer.TGeventProcessPoolServer(processor, transport, tfactory, pfactory)
        server.setNumWorkers(WORKER_NUM)
    
        server.setPostForkCallback(init_handler)
    
        print "server started..."
        server.serve()
相關文章
相關標籤/搜索