thrift类图

TNonblockingServer

ThreadManager threadManager_;vector<TNonblockingIOThread> ioThreads_;stack<TConnection*> connectionStack_;Processor processer;TProtocolFactory inputProtocolFactory_;TProtocolFactory outputProtocolFactory_;

serveregisterEventshandleevent(server socket可读回调）

TSocket

int socket_int portstring addressint recvTimeout_;

openclosesetRecvTimesetSendTimesetNoDelay...

TFramedTransport

  uint32_t rBufSize_;  uint32_t wBufSize_;  boost::scoped_array<uint8_t> rBuf_;  boost::scoped_array<uint8_t> wBuf_;  uint32_t bufReclaimThresh_;boost::shared_ptr<TTransport> transport_;

readFramereadallwrite...

TBinaryProtocol

Transport_* trans_;

readMessageBeginreadStructBeginreadStructBegin...

TTransport

readreadallwritewriteEnd...

TConnection

TProcessor processor_;TSocket tSocket_;TNonblockingIOThread* ioThread_;  TNonblockingServer* server_;TProtocol inputProtocol_;TProtocol outputProtocol_;

workSockettransition...

TProtocol