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
