spServerr的架构.docVIP

从spserver看HS-HA模式 2009-05-17 18:17 序 在互联网企业里，*nux下的C/C++编程主要的焦点还是server开发，关于不同的server模型，在UNP第30章里有过简单的讨论，这里得出的结论就是多线程和多进程的server模型效率较高。但书中缺乏对多路复用机制的讨论，而当前主流的server模型则是epoll+multi-threads/multi-processes，lighttpd就属于这种模型。本文将探讨一个更加高效的server模型，half-synchorize/half-asynchorize模式。 half-sync/half-async模型 此模式最早是由著名的C++网络编程框架ACE的作者的一篇文章，其主要思想就是用异步的方式来处理IO事件，而用同步的方式来处理业务逻辑，同步和异步之间使用一个队列作为缓冲，如下图： 此模型详细介绍可参考原文。 spserver简介 引用作者对spserver的介绍：spserver 是一个实现了半同步/半异步(Half-Sync/Half-Async)和领导者/追随者(Leader/Follower) 模式的服务器框架，能够简化 TCP server 的开发工作。并且spserve使用了libevent作为底层的异步响应机制的实现。 我抱着一种学习的态度，阅读了其half-sync/half-async模式的实现代码，本文也可以看做是一篇spserver的源码分析。 代码结构 1） spserver：主文件，程序从start方法里启动。 2） speventcb：主要的回调函数实现逻辑。 3） spsession：代表一个会话。 4） sprequest：封装了客户端ip和messageDecoder，个人认为封装的不好。 5） spresponse：封装了响应的内容。 6） spiochannel：封装底层IO。 7） spmsgdecoder：消息解析器，判断消息是否完整。 8） spbuffer：对libevent里的buffer的简单封装。 9） spthread、spthreadpool、spexecutor：线程池的封装。 代码分析 spsession代表一个连接的会话，它属于half-sync/half-async模型的3层结构中的queue，业务逻辑和网络IO通过session中的input buffer和output list来通信。 先来看一下SP_Session类的成员： SP_Sid_t mSid; //session id，详见下一节 ???? struct event * mReadEvent; //和session关联的读写事件 ???? struct event * mWriteEvent; ???? SP_Handler * mHandler; //用户实现业务逻辑的handler ???? void * mArg; //event args ???? SP_Buffer * mInBuffer; //输入缓冲队列 ???? SP_Request * mRequest; //对请求的封装 ???? int mOutOffset; //输出偏移量，以字节为单位，表明out list中已输出的字节数 ???? SP_ArrayList * mOutList; // list of msg，输出的缓冲队列 ???? char mStatus; //当前session的状态，可为eNormal, eWouldExit, eExit ???? char mRunning; //是否在运行 ???? char mWriting; //是否在写 ???? char mReading; //是否在读 ???? unsigned int mTotalRead, mTotalWrite; //本session已读写的字节数 ???? SP_IOChannel * mIOChannel; //关联的IOChannel session是通过SP_SessionManager来进行管理的，它实际上是一个64*1024的二维数组，entry的类型定义如下： typedef struct tagSP_SessionEntry { ???? uint16_t mSeq; ???? uint16_t mNext; ???? SP_Session * mSession; } SP_SessionEntry; 其中每个entry都是通过一个key来标识其在matrix中的坐标，key=1024*row+col，而seq标识这个entry被使用过多少次，通过key和seq就可以形成一个ssion id了。entry中的mNext成员指向list中下