（八）高性能服务器架构设计总结4——以flamigo服务器代码为例.docx

（八）高性能服务器架构设计总结4——以flamigo服务器代码为例 　　系列目录　　第01篇 主线程与工作线程的分工　　第02篇 Reactor模式　　第03篇 一个服务器程序的架构介绍　　第04篇 如何将socket设置为非阻塞模式　　第05篇 如何编写高性能日志　　第06篇 关于网络编程的一些实用技巧和细节　　第07篇 开源一款即时通讯软件的源码　　第08篇 高性能服务器架构设计总结1　　第09篇 高性能服务器架构设计总结2　　第10篇 高性能服务器架构设计总结3　　第11篇 高性能服务器架构设计总结4二、架构篇　　一个项目的服务器端往往由很多服务组成，就算单个服务在性能上做到极致，支持的并发数量也是有限的。举个简单的例子，假如一个聊天服务器，每个用户的信息是1k，那对于一个8G的内存的机器，在不考虑其它的情况下*1024 / 100 = 1024，实际有838万，但实际这只是非常理想的情况。所以我们有时候需要需要某个服务部署多套，就单个服务的实现来讲还是《框架篇》中介绍的。　　1　　我们举个例子：　　这是蘑菇街TeamTalk的服务器架构。　　MsgServer是聊天服务，可以部署多套，每个聊天服务器启动时都会告诉loginSever和routeSever自己的ip地址和端口号，当有用户上线或者下线的时候，MsgServer也会告诉loginSever和routeSever自己上面最新的用户数量和用户id列表。　　现在一个用户需要登录，先连接loginServer，loginServer根据记录的各个MsgServer上的用户情况，返回一个最小负载的MsgServer的ip地址和端口号给客户端，客户端再利用这个ip地址和端口号去登录MsgServer。当聊天时，位于A MsgServer上的用户给另外一个用户发送消息，如果该用户不在同一个MsgServer上，MsgServer将消息转发给RouteServer，RouteServer根据自己记录的用户id信息找到目标用户所在的MsgServer并转发给对应的MsgServer。　　2　　上面是分布式部署的一个例子，我们再来看另外一个例子。这个例子是单个服务的策略，实际服务器在处理网络数据的时候，如果同时有多个socket上有数据要处理，可能会出现一直服务前几个socket，直到前几个socket处理完毕后再处理后面几个socket的数据。这就相当于，你去饭店吃饭，大家都点了菜，但是有些桌子上一直在上菜，而有些桌子上一直没有菜。这样肯定不好，我们来看下如何避免这种现象： 1int CFtdEngine::HandlePackage(CFTDCPackage *pFTDCPackage,  2 ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?CFTDCSession *pSession) ?  3{ ?  4 ? ?//NET_IO_LOG0(CFtdEngine::HandlePackage\n); ?  5 ? ?FTDC_PACKAGE_DEBUG(pFTDCPackage); ?  6  7 ? ?if (pFTDCPackage-GetTID() != FTD_TID_ReqUserLogin) ?  8 ? ?{ ?  9 ? ? ? ?if (!IsSessionLogin(pSession-GetSessionID())) ? 10 ? ? ? ?{ ?11 ? ? ? ? ? ?SendErrorRsp(pFTDCPackage, pSession, 1, 客户未登录); ?12 ? ? ? ? ? ?return 0; ?13 ? ? ? ?} ?14 ? ?} ?1516 ? ?CalcFlux(pSession, pFTDCPackage-Length()); ?//统计流量 ?1718 ? ?REPORT_EVENT(LOG_DEBUG, Front/Fgateway, 登录请求%0x,19 ? ? ? ? ? ? ? ? ?pFTDCPackage-GetTID()); ?2021 ? ?int nRet = 0; ?22 ? ?switch(pFTDCPackage-GetTID()) ?23 ? ?{ ?2425 ? ?case FTD_TID_ReqUserLogin: ?26 ? ? ? ?///huwp：XX0608：检查过高版本的API将被禁止登录 ?27 ? ? ? ?if (pFTDCPackage-GetVersion()FTD_VERSION) ?28 ? ? ? ?{ ?29 ? ? ? ? ? ?SendErrorR