MMORPG大型游戏设计与开发（part3 of net）

这一部分需要向大家介绍的是服务器的select以及收发包的具体流程，从核心代码功能上分析网络交互具体过程。

　　首先大家要看第二部分（part2 of net）的代码结构图，因为在接下来的流程过程中会用到其中模块的名称，若是不知道大致的功能那么接下来的解说可能就成为天书了。

　　总体流程为：服务器管理器初始化并创建主套接字连接，进入主循环等待新连接（select），如果有新的连接则将新连接加入连接管理器。不管有没有新的连接，循环会依次处理连接的异常->输入流->输出流->命令处理。其中异常即连接包发送错误的处理，输入流即套接字输入流中如果大小长度不为空则重新拼接包，输出流进行包的拼接，并将未发送的流进行发送，命令处理其实是对输入流的处理，处理（handler）发送过来的包。

　　以下详细说明这几个流程从代码上的实现，以及所在的模块。

　　1、服务器管理器初始化（servermanager）

bool ServerManager::init() {__ENTER_FUNCTIONserversocket_ = new pap_server_common_net::Socket(g_config.billing_info_.port_);Assert(serversocket_);serversocket_->set_nonblocking();socketid_ = serversocket_->getid(); Assert(socketid_ != SOCKET_INVALID); FD_SET(socketid_, &readfds_[kSelectFull]); FD_SET(socketid_, &exceptfds_[kSelectFull]); minfd_ = maxfd_ = socketid_; timeout_[kSelectFull].tv_sec = 0; timeout_[kSelectFull].tv_usec = 0; threadid_ = pap_common_sys::get_current_thread_id(); uint16_t i; for (i = 0; i < OVER_SERVER_MAX; ++i) { serverhash_[i] = ID_INVALID; } return true; __LEAVE_FUNCTION return false; }

　　2、服务器管理器进入主循环（servermanager）

void ServerManager::loop() {__ENTER_FUNCTIONwhile (isactive()) {bool result = false; try { result = select(); Assert(result); //ERRORPRINTF("select"); result = processexception(); Assert(result); //ERRORPRINTF("processexception"); result = processinput(); Assert(result); //ERRORPRINTF("processinput"); result = processoutput(); Assert(result); //ERRORPRINTF("processoutput");  } catch(...) { } try { result = processcommand(); Assert(result); //ERRORPRINTF("processcommand");  } catch(...) { } try { result = heartbeat(); Assert(result); } catch(...) { } } __LEAVE_FUNCTION }

loop

　　3、服务器线程进入select模式

bool ServerManager::select() {__ENTER_FUNCTIONtimeout_[kSelectUse].tv_sec = timeout_[kSelectFull].tv_sec;timeout_[kSelectUse].tv_usec = timeout_[kSelectFull].tv_usec;readfds_[kSelectUse] = readfds_[kSelectFull]; writefds_[kSelectUse] = writefds_[kSelectFull]; exceptfds_[kSelectUse] = exceptfds_[kSelectFull]; pap_common_base::util::sleep(100); int32_t result = SOCKET_ERROR; try { result = pap_common_net::socket::Base::select( maxfd_ + 1, &readfds_[kSelectUse], &writefds_[kSelectUse], &exceptfds_[kSelectUse], &timeout_[kSelectUse]); Assert(result != SOCKET_ERROR); } catch(...) { g_log->fast_save_log(kBillingLogFile, "ServerManager::select have error, result: %d", result); } return true; __LEAVE_FUNCTION return false; }

select

　　4、服务器线程进行异常处理

bool ServerManager::processexception() {__ENTER_FUNCTIONif (SOCKET_INVALID == minfd_ && SOCKET_INVALID == maxfd_)return true; uint16_t connectioncount = billingconnection::Manager::getcount(); billingconnection::Server* serverconnection = NULL; uint16_t i; for (i = 0; i < connectioncount; ++i) { if (ID_INVALID == connectionids_[i]) continue; serverconnection = g_connectionpool->get(connectionids_[i]); Assert(serverconnection); int32_t socketid = serverconnection->getsocket()->getid(); if (socketid_ == socketid) { Assert(false); continue; } if (FD_ISSET(socketid, &exceptfds_[kSelectUse])) { removeconnection(serverconnection); } } return true; __LEAVE_FUNCTION return false; }

processexception

　　5、服务器线程进行输入流处理

bool ServerManager::processinput() {__ENTER_FUNCTIONif (SOCKET_INVALID == minfd_ && SOCKET_INVALID == maxfd_)return true; //no connection  uint16_t i; if (FD_ISSET(socketid_, &readfds_[kSelectUse])) { for (i = 0; i < kOneStepAccept; ++i) { if (!accept_newconnection()) break; } } uint16_t connectioncount = billingconnection::Manager::getcount(); for (i = 0; i < connectioncount; ++i) { if (ID_INVALID == connectionids_[i]) continue; billingconnection::Server* serverconnection = NULL; serverconnection = g_connectionpool->get(connectionids_[i]); Assert(serverconnection); int32_t socketid = serverconnection->getsocket()->getid(); if (socketid_ == socketid) continue; if (FD_ISSET(socketid, &readfds_[kSelectUse])) { //read information if (serverconnection->getsocket()->iserror()) { removeconnection(serverconnection); } else { try { if (!serverconnection->processinput()) removeconnection(serverconnection); } catch(...) { removeconnection(serverconnection); } } } } return true; __LEAVE_FUNCTION return false; }

processinput

　　6、服务器线程进行输出流处理

bool ServerManager::processoutput() {__ENTER_FUNCTIONif (SOCKET_INVALID == maxfd_&& SOCKET_INVALID == minfd_)return false; uint16_t i; uint16_t connectioncount = billingconnection::Manager::getcount(); for (i = 0; i < connectioncount; ++i) { if (ID_INVALID == connectionids_[i]) continue; billingconnection::Server* serverconnection = NULL; serverconnection = g_connectionpool->get(connectionids_[i]); Assert(serverconnection); int32_t socketid = serverconnection->getsocket()->getid(); if (socketid_ == socketid) continue; if (FD_ISSET(socketid, &writefds_[kSelectUse])) { if (serverconnection->getsocket()->iserror()) { removeconnection(serverconnection); } else { try { if (!serverconnection->processoutput()) removeconnection(serverconnection); } catch(...) { removeconnection(serverconnection); } } } } return true; __LEAVE_FUNCTION return false; }

processoutput

　　7、服务器线程进行命令处理

bool ServerManager::processcommand() {__ENTER_FUNCTIONif (SOCKET_INVALID == maxfd_&& SOCKET_INVALID == minfd_)return false; uint16_t i; uint16_t connectioncount = billingconnection::Manager::getcount(); for (i = 0; i < connectioncount; ++i) { if (ID_INVALID == connectionids_[i]) continue; billingconnection::Server* serverconnection = NULL; serverconnection = g_connectionpool->get(connectionids_[i]); //serverconnection = &billing_serverconnection_;  Assert(serverconnection); int32_t socketid = serverconnection->getsocket()->getid(); if (socketid_ == socketid) continue; if (serverconnection->getsocket()->iserror()) { removeconnection(serverconnection); } else { //connection is ok try { if (!serverconnection->processcommand(false)) removeconnection(serverconnection); } catch(...) { removeconnection(serverconnection); } } } return true; __LEAVE_FUNCTION return false; }

processcommand

　　下一部分，我将讲解在网络部分一些重要的代码块。

转载于:https://www.cnblogs.com/liuzhi/p/4084565.html

MMORPG大型游戏设计与开发（part3 of net）相关推荐

MMORPG大型游戏设计与开发（服务器游戏场景地图和区域）
地图的数据以及区域的信息是场景的重要组成部分,这些数据同时存在客户端和服务器,而且都是由编辑器生成的.那么保存的文件数据结构是怎样的?一张3D的场景地图又是怎样处理这些数据的?同时告诉大家这里同样只是 ...
MMORPG大型游戏设计与开发（服务器游戏场景动态场景与副本）
场景的内容讲解到今天算是暂时划上一个句号了,接下来为大家讲解的是AI部分(大型AI),如果有兴趣的朋友不妨持续关注这些文章,大家一起学习和进步.动态场景和副本是场景中特殊的类型,副本在这里想必已经是无 ...
MMORPG大型游戏设计与开发（part5 of net）
上一部分将服务器的具体代码的实现介绍给了大家,想必大家也了解到了服务器处理一次消息的复杂度.如果大家能够将各个过程掌握清楚,就会发觉其实整个逻辑与交互过程是比较清晰的.那么服务器与服务器之间的通讯,其 ...
百万在线：大型游戏服务端开发
进入手游时代,服务端技术也在向前演进.现代游戏服务端既要承载数以万计的在线玩家,又要适应快速变化的市场需求,因此,如何设计合适的架构就成了重中之重.服务端技术并不简单,作为服务端新人,全面掌握服务端技 ...
基于android的2048游戏设计,基于Android平台的2048游戏设计与开发.docx
基于Android平台的2048游戏设计与开发高级操作系统论文(设计) 题目基于Android个人2048 小游戏的设计与开发姓名学号院. 系信息学院专业指导教师职称(学历)目 ...
《基于Unity的2D多人乱斗闯关游戏设计与开发》--小组博客综述
文章目录项目名称项目背景项目简介项目架构项目特色大致功能需求游戏模式/内容项目技术选型项目分工项目具体计划此次项目实训不完全按照项目计划书进行,因为游戏范围太广,可能随时调整游戏 ...
基于Java多线程的打怪升级类游戏设计与开发
摘要:本文论述了通过JAVA多线程.基于JAVA Swing的GUI图形用户界面设计.IO输入输出流.JDBC技术,实现了游戏系统的UI设计.游戏数据的存储.关卡的设置.用户头像的上传与更改.游戏数据 ...
java俄罗斯方块ppt_基于Java俄罗斯方块游戏设计与开发PPT.ppt
基于Java俄罗斯方块游戏设计与开发PPT 基于Java的俄罗斯方块游戏的设计与实现答辩人:xxx 学号:201012120201 指导老师:xxx副教授专业:网络工程学院:信息科学与 ...
游戏设计与开发_独立游戏开发：怎样设计游戏新手教学？
教你画像素画原创出品塞尔达荒野之息 1.游戏新手教学需要考虑的4个问题 1.玩家怎么玩? 2.玩家怎么完成游戏目标? 3.为什么玩家要这么做? 4.玩家何时会采取行动? 动作类游戏,玩家的操作会即时 ...

MMORPG大型游戏设计与开发（part3 of net）

MMORPG大型游戏设计与开发（part3 of net）相关推荐

最新文章

热门文章