码迷,mamicode.com
首页 > 其他好文 > 详细

GS初始化

时间:2014-11-19 07:05:57      阅读:211      评论:0      收藏:0      [点我收藏+]

标签:style   blog   io   ar   color   os   使用   sp   for   

开启GameServer模式
init函数,现在看看这个大函数干什么的
//这个init也是GameServerUI里面调的,这个线程其实就做了一些初始化的工作,其实这里面没有什么主不主线程,都是在一个进程里面的
void __stdcall GameServer::init()
{
    ///设置最大连接数,现在还不知这个到底干啥的
    Share::SetMaxGcNumb(12000); //指定本GS支持的最大数量
    
    ///log日志,现在服务器写日志,在服务器报错的时候可以查看日志,还有报错时生成dump文件,然后上传ftp服务器,到时可以调试这个dump文件也可以知道在哪里报错
    // Log记录,全局单例,支持多线程。
    m_spLog = NEWSP(Log);
    std::string strLogDir = safe::wcstombs(Plug::GetCurrentPath()) + "Log";
    m_spLog->Init(strLogDir.c_str());
    SetPlug("Log", m_spLog.get());
    
    ///这个usbdog现在我不知道干啥的
    I_USBDog* pDog = NEW(USBDog);
    msg_assertex(pDog,"usb dog 创建失败!"); 
    std::string str = (char*)Plug::GetApp()->m_app_shared;
    if(str != "USBDog")
        return ;

    ///主要是一些配置文件的拷贝,只要模板然后拷贝一份你可以配置
    std::wstring wstrCurPath = Plug::GetCurrentPath();
    CheckFileAndCopy(wstrCurPath + L"option.xml", wstrCurPath + L"option模板.xml");
    CheckFileAndCopy(wstrCurPath + L"DBline.xml", wstrCurPath + L"DBline模板.xml");
    CheckFileAndCopy(wstrCurPath + L"centerOption.xml", wstrCurPath + L"centerOption模板.xml");

    ///在程序中开启控制打印,看变量的值
//#define ALLOC_CONSOLE
#ifdef ALLOC_CONSOLE
    AllocConsole();                        // 开辟控制台 释放:FreeConsole();
    SetConsoleTitle(L"Debug Output");      // 设置控制台窗口标题
    freopen("CONOUT$","w",stdout);         // 重定向输出
    printf("hello!\n");
#endif

    ////为进程指定CPU
    //SetProcessAffinityMask(GetCurrentProcess(), 1L);
    
    ///连接中心服务器,天龙里面是世界服务器,我们这个可以说没啥用,天龙那个是架构的一部分,没咋看天龙那个世界服务器
    /*连接centerServer*/
    m_spCenterTcpLink = NEWSP(CenterTcpLink);
    std::shared_ptr<I_SaveOption> spSaveOpt = NEWSP(SaveOption);
    spSaveOpt->openFile((Plug::GetCurrentPath() + L"centerOption.xml").c_str());
    std::string strIP = safe::wcstombs(spSaveOpt->getStr(L"root.ip"));
    int nPort = spSaveOpt->getInt(L"root.port");
    int nIP = ntohl(inet_addr(strIP.c_str()));
    if (!m_spCenterTcpLink->Connect(nIP, nPort))
    {
        MessageBox(NULL, L"centerServer连接失败!", L"Error!", MB_ICONERROR);
        ::TerminateProcess(::GetCurrentProcess(), 0);
    }

    //获取GameServer端口号
    spSaveOpt->openFile((Plug::GetCurrentPath() + L"option.xml").c_str());
    m_nPort = spSaveOpt->getInt(L"root.port");

    /*    初始化数据库    */
    m_spAsynDBC = NEWSP(asynDBCenter);///主要是mongo数据库的指针和加载任务等级信息,用于创建角色使用

    spSaveOpt->openFile((Plug::GetCurrentPath() + L"DBline.xml").c_str());
    std::string strDBIP =  safe::wcstombs(spSaveOpt->getStr(L"root.ip"));
    std::string strAcountDBName = safe::wcstombs(spSaveOpt->getStr(L"root.AccountDBName"));
    std::string strActorDBName = safe::wcstombs(spSaveOpt->getStr(L"root.ActorDBName"));

    ///这个主要是数据库字段数组的初始化,这个数组的值就是对应到数据库里面的字段的,后面数据库的存取都用到这个数组,类似下面的形式
    {//其中是根绝数组直接定位的
        m_pConfigName[eAccountTable_INC] = "T_INC";
        m_pConfigName[eAccountTable_User] = "T_UserInfo";
        m_pConfigName[eServerTable_INC] = "T_INC";
        m_pConfigName[eServerTable_Actor] = "T_ActorInfo";
        m_pConfigName[eServerTable_Guild] = "T_GuildInfo";
        m_pConfigName[eServerTable_Prop] = "T_PropInfo";
    }
    if(!m_spAsynDBC->Init(true))
    {
        MessageBoxA(GetTopWindow(NULL), "数据库初始化失败!", "Error!", MB_ICONERROR);
        ::TerminateProcess(GetCurrentProcess(), 0);
    }
    ///这个登录过程主要是连接mongo和认证,然后就是保证一些表的存在,数据库现在主要分为账号数据库和角色数据库,这里用suerperamdmin登录,其他数据库也能使用了
    if(!m_spAsynDBC->Login(strDBIP.c_str(), 27017, ShuiHu::eServerDB_AoShiQianXiong, "SuperAdmin", "123456"))
    {
        MessageBoxA(GetTopWindow(NULL), "数据库连接失败!", "Error!", MB_ICONERROR);
        ::TerminateProcess(GetCurrentProcess(), 0);
    }
    ///在ui上显示数据库线程id方便压测的
    OnThreadId(m_spAsynDBC->GetThrID(), L"数据库");

    ///对于长时间没有收到心跳包的客户端会被放入队列中,到时会释放,其实这个没咋看
    I_TimerFactory* pTimeFactory = NEW(TimerFactory);
    SetPlug("TimerFactory", pTimeFactory);
    m_FreeQueueTimer.reset(pTimeFactory->createTimer());
    m_FreeQueueTimer->regTimer(std::bind(&GameServer::FreeQueueTimer, this));
    m_FreeQueueTimer->setInterval(30 * 1000);//(30 * 1000);
    m_FreeQueueTimer->start();
    
    ///定时保存帮会信息,1min
    m_SaveGuildInfoTimer.reset(pTimeFactory->createTimer());
    m_SaveGuildInfoTimer->regTimer(std::bind(&DBSaveTiming::OnSaveGuildInfo, &m_DBSaveTiming));
    m_SaveGuildInfoTimer->setInterval(1 * 60 * 1000);

    ///定时保存道具信息,从道具管理器里面读取,然后保存到数据库,是整个服务器的道具定时存储
    m_SavePropInfoTimer.reset(pTimeFactory->createTimer());
    m_SavePropInfoTimer->regTimer(std::bind(&DBSaveTiming::OnSavePropInfo, &m_DBSaveTiming));
    m_SavePropInfoTimer->setInterval(1 * 60 * 1000);

    ///添加DataLayer单例好像gamemap里面也会用到,最后被废弃了,随后看看
    m_spDataLayer = NEWSP(DataLayer);
    add_singleton("DataLayer", m_spDataLayer.get());
    //m_spDataLayer = NEWSP(GatwayData);
    
    ///网络初始化,就是双向的共享内存的初始化
    if(!m_spDataLayer->Init())
    {
        Plug::PlugMessageBox(L"初始化网络失败!");
        ::TerminateProcess(::GetCurrentProcess(), 0);
    }

    ShareInit(m_spDataLayer.get());
    m_DBSaveTiming.SetAsynDBCPtr(m_spAsynDBC);
    m_DBSaveTiming.SetPropMgrPtr(m_spPropManager);
    m_DBSaveTiming.SetGuildOptPtr(m_spGuildOpt);
    //获取帮会信息
    m_fnGetGuildInfo = std::bind(&GameServer::ProcessGetGuildInfo, this, ph::_1, ph::_2);
    m_spAsynDBC->GetGuildInfos(&m_fnGetGuildInfo);
    //道具信息
    m_funGetUserProp = std::bind(&GameServer::ProcessGetPropInfo, this, ph::_1, ph::_2);
    m_spAsynDBC->GetPropInfos(&m_funGetUserProp);

    m_LiveMgr.m_fnTimeOutDisconnect = std::bind(&GameServer::TimeOutDisconnect, this, ph::_1);
    m_LiveMgr.Init(GetMaxGcNumb());

    m_vecChannel.resize(GetMaxGcNumb());
    m_spThread.reset(new std::thread(std::bind(&GameServer::ProcessThread, this)));//创建一个线程,就是常说的GS线程,其实很多工作都是在这个线程里面做的
    OnThreadId(m_spThread->get_id(), L"GS线程");
}
//可以看出主线程
void Share::ShareInit(I_DataLayer* data_layer)//share是管理所有地图信息的,非常重要
{
    // 加载xls表
    if(!LoadnBodyId())
        Plug::PlugMessageBox("加载nBodyID表失败啊!");//三种职业,两种性别,nbodyid大概就代表地图资源
    if(!LoadLevelInfo())
        Plug::PlugMessageBox("加载角色等级信息失败!");//三种职业,71个等级的等级信息
    if(!LoadMapData())
        Plug::PlugMessageBox("加载地图数据失败!");//现在就有7张地图

    /*地图数量*/

    for(auto itMap : m_mapDataTable)
    {
        auto& pMap = m_mapMap[itMap.first] = NEW(Map);//m_mapMap是地图id对应一个地图指针信息
        pMap->Init(GetMaxGcNumb(), itMap.second.map_path.c_str());//地图的初始化
        pMap->m_fnGetLevelInfo = std::bind(&Share::TGetLevelInfo, this, ph::_1, ph::_2, ph::_3);

        pMap->m_nMapId = itMap.first;
        std::wstring name = L"地图";
        name += boost::lexical_cast<std::wstring>(pMap->m_nMapId);
        OnThreadId(pMap->GetThreadId(), name); //获取线程ID
    }

    m_pDataLayer = data_layer;
    //初始化 跨地图操作模块
    InitAcrossMapOpt();
    InitAcrossManager();
}


void Map::Init(int max_gc_numb,  const char* res_path)
{
    m_pLog = GetPlug(Log);//全局log单例
    msg_assert(m_pLog);

    m_vecPlayerChannel.resize(max_gc_numb);//m_vecPlayerChannel代表了一个地图上的所有玩家
    
    InitTimer();//map里面各种定时器的初始化
    InitOpt();//主要是地图内的一些操作,帮会,组队,关系,交易,npc交互,将这给些给分开有利于模块的独立
    InitMapInfoXml(res_path);//主要是地图的加载,块的划分,格子,2d人物通知都是用的格子,听说3d用的九宫格,只是听说
    InitPropXml();//道具信息的读取
    InitOrnamemtal();//这个不知干啥的
    InitMonsterTypeInfoTable();//怪物信息记载
    InitRegions();//区域的加载(安全区,战斗区)
    InitSkillLevelInfoTable();//技能等级信息
    InitMonsterDropRuleTable();//怪物掉落
    InitPlayerDropRuleTable();//人物掉落
    InitPetArrributeTable();//宠物属性
    InitSkillRestrictInfoTable();//限制技能读取

    InitSkillScript();//技能脚本
    InitMission();//任务
    InitMgr();//管理加载

    Start();//map线程启动
}

 

GS初始化

标签:style   blog   io   ar   color   os   使用   sp   for   

原文地址:http://www.cnblogs.com/zzyoucan/p/4107111.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!