解析tcp交互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

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