记录下我们游戏服务器的架构

游戏服务器逻辑架构图

我自己设计的游戏逻辑架构图

游戏服务器程序框架图

程序入口代码

// 读取此服务器相关配置  Log.Notice("Config", "Checking config file: %", config_file);  if(Config.MainConfig.SetSource(config_file, true))  {   Log.Success("Config", "Passed without errors.");   sLog.Close();  }else  {   return false;  }    g_server_id = Config.MainConfig.GetIntDefault("ServerInfo", "ServerID", 1);  g_max_connect = Config.MainConfig.GetIntDefault("ServerInfo", "MaxConnect", 500);  g_server_name = Config.MainConfig.GetStringDefault("ServerInfo", "ServerName", "PDKMainServer");    // 是否主服务器  // 连接人数上限  if (g_server_id == 1)  {   is_main_gs = true;  }

 // 开始时间管理  //gTimeManager.Run();    // 设置日志级别  sLog.Init(0, GAMEFRAME_LOG);

 sLog.outBasic(BANNER, BUILD_TAG, BUILD_HASH_STR, CONFIG, PLATFORM_TEXT, ARCH);  sLog.outErrorSilent(BANNER, BUILD_TAG, BUILD_HASH_STR, CONFIG, PLATFORM_TEXT, ARCH); // Echo off.    // 初始化随机种子  InitRAndomNumberGenerators();    new CPlayerManager;  new CRoomManager;  new CModuleManager;  new CAccountManager;  //new CMatchManager;    new CMatchManager;

 ThreadPool.Startup();

 //// 初始化DB  //if(!_StartDB())  //{  // Database::CleanupLibs();  // sLog.Close();  // return false;  //}

 //// 检查DB版本  暂不处理  //if(!CheckDBVersion())  //{  // sLog.Close();  // return false;  //}

 //// 清理数据库  暂不处理  //if(do_database_clean)  //{  // sLog.outDebug("Entering database maintenance mode.");  // new DatabaseCleaner;  // DatabaseCleaner::getSingleton().Run();  // Delete DatabaseCleaner::getSingletonPtr();  // sLog.outDebug("Maintenance finished.");  //}

 ////事件处理机制  暂不加入  //new EventMgr;

 new CSessionsManager;

 int LogLevel = Config.MainConfig.GetIntDefault("LogLevel", "FileLogLevel", 2);  sLog.SetFileLoggingLevel(LogLevel);

 //CGameFrameSession::InitPacketHAndlerTable();

 GameRunnable* gr = new GameRunnable();  ThreadPool.ExecuteTask(gr);    new SocketMgr;  new SocketGarbageCollector;

 RegisterProtocols();

 string host = Config.MainConfig.GetStringDefault("Listen", "Host", DEFAULT_HOST);  int wsport = Config.MainConfig.GetIntDefault("Listen", "ServerPort", DEFAULT_SERVER_PORT);

 new ServerConnect();  sServerConnect.Startup();

 ListenSocket<ClientSocket> * cl = new ListenSocket<ClientSocket>(host.c_str(), wsport);

 sSocketMgr.SpawnWorkerThreads();

 bool authsockCreated = cl->IsOpen();  if(authsockCreated )  { #ifdef WIN32   ThreadPool.ExecuteTask(cl); #endif

  sLog.outString("Hooking signals...");   signal(SIGINT, _OnSignal);   signal(SIGTERM, _OnSignal);   signal(SIGABRT, _OnSignal); #ifdef _WIN32   signal(SIGBREAK, _OnSignal); #else   signal(SIGHUP, _OnSignal); #endif

  /* write pid file */   FILE* fPid = fopen("logonserver.pid", "w");   if(fPid)   {    uint32 pid; #ifdef WIN32    pid = GetCurrentProcessId(); #else    pid = getpid(); #endif    fprintf(fPid, "%", (unsigned int)pid);    fclose(fPid);   }

  uint32 loop_counter = 0;   //ThreadPool.Gobble();   sLog.outString("Success! Ready fOrconnections");   while(mrunning.GetVal())   {    loop_counter++;    if (!(loop_counter %2)) // 2s    {     //sAccountMgr.CheckUpdate();    }

   if(!(loop_counter %5))    {     //sInfoCore.TimeoutSockets();     sSocketGarbageCollector.Update();     //sSessionsManager.CheckPing();

    //CheckForDeadSockets();     // Flood Protection     UNIXTIME = time(NULL);     g_localTime = *localtime(&UNIXTIME);    }        if (!(loop_counter %600)) // 10mins    {     //sAccountMgr.CheckDelete();    }

   if(!(loop_counter %300)) // 5mins    {     ThreadPool.IntegrityCheck();    }

   if(!(loop_counter %5))    {     UNIXTIME = time(NULL);     g_localTime = *localtime(&UNIXTIME);    }

   Arcemu::Sleep(1000);   }

  sLog.outString("Shutting down...");   signal(SIGINT, 0);   signal(SIGTERM, 0);   signal(SIGABRT, 0); #ifdef _WIN32   signal(SIGBREAK, 0); #else   signal(SIGHUP, 0); #endif  }  else  {   LOG_ERROR("ErrOrcreating sockets. Shutting down...");  }

 gr->SetThreadState(THREADSTATE_TERMINATE);

 cl->Close();

 sSocketMgr.CloseAll(); #ifdef WIN32  sSocketMgr.ShutdownThreads(); #endif

 // kill db  sLog.outString("Waiting fOrdatabase to close..");

 ThreadPool.Shutdown();

 Delete ServerConnect::getSingletonPtr();

 // Delete pid file  remove("logonserver.pid");

 Delete SocketMgr::getSingletonPtr();  Delete SocketGarbageCollector::getSingletonPtr();  Delete CSessionsManager::getSingletonPtr();  Delete CMatchManager::getSingletonPtr();    Delete cl;

 UnregisterProtocols();

 LOG_BASIC("Shutdown complete.");  sLog.Close();

 Delete CModuleManager::getSingletonPtr();  Delete CRoomManager::getSingletonPtr();  Delete CPlayerManager::getSingletonPtr();  

 //string host = Config.MainConfig.GetStringDefault("Listen", "Host", DEFAULT_HOST);  //int wsport = Config.MainConfig.GetIntDefault("Listen", "WorldServerPort", DEFAULT_WORLDSERVER_PORT);

 return true;

总结

网络模块分两部分，一个是跟账号服务器通信的ServerConnect，一个是跟客户端通信的ListenSocket<ClientSocket>，网络模块获取的数据都放到Session里面CSessionsManager类负责管理，CGameLogic游戏逻辑是在GameRunnable线程中运行的

转自：http://www.dcscms.com/article/content.php?seq=21

游戏服务器架构分析