微信扫一扫 分享朋友圈

已有 1751 人浏览分享

开启左侧

LoginSvr服务器

[复制链接]
1751 0
LoginSvr 服务器

g_gcSock Local    5500端口

1.首先从LoginSvr.cpp  WinMain分析:

    1) CheckAvailableIOCP : 检查是不是NT,2000的系统(IOCP)

    2) InitInstance: 初始化界面,加载WSAStartup

        GetDBManager()->Init( InsertLogMsg, “Mir2_Account“, “sa“, “prg“ );

        数据库管理类,做底层数据库操作。



3)       MainWndProc窗口回调函数OnCommand:

IDM_STARTSERVICE:

创建LoadAccountRecords线程

a). UPDATE TBL_ACCOUNT重置帐户验证状态。

b). 读服务器列表(TBL_SERVERINFO, selGate服务器),加入g_GameServerList

遍历GameServerList列表,把服务器信息加入到一个字符数组g_szServerList中。

c). 启动InitServerThreadForMsg线程。

           d). 调用InitServerSocket函数创建两个线程:

            AcceptThread线程:

            ServerWorkerThread线程:

调用InitServerSocket函数创建两个线程:

     1) AcceptThread线程:

Accept之后生成一个CGateInfo对象,CGateInfo->sock = Accept; 客户端Socket值赋值给结构体。记录客户相关信息。新的套接字句柄用CreateIoCompletionPort关联到完成端口,然后发出一个异步的WSASend或者WSARecv调用(pNewUserInfo->Recv();接收客户端消息),因为是异步函数,WSASend/WSARecv会马上返回,实际的发送或者接收数据的操作由WINDOWS系统去做。然后把CGateInfo对象加入g_GateList中。在客户accept之后,投递一个I/O(recv)。

分析一下g_GateList发现,每个CGateInfo里有sock; UserInfoList,g_SendToGateQ,该网关的相关信息依次(网关对应的sock, 用户列列信息,消息队列),可以为多个LoginGate登录网关服务。



2) ServerWorkerThread线程:

ServerWorkerThread线程工作原理:

循环调用GetQueuedCompletionStatus()函数来得到IO操作结果。阻塞函数。当WINDOWS系统完成WSASend或者WSArecv的操作,把结果发到完成端口。GetQueuedCompletionStatus()马上返回,并从完成端口取得刚完成的WSASend/WSARecv的结果。然后接着发出WSASend/WSARecv,并继续下一次循环阻塞在GetQueuedCompletionStatus()这里。

a).if (g_fTerminated) 线程结束前:循环遍历g_GateList,取出pGateInfo关闭套接字,并删除节点。dwBytesTransferred =0 ,关闭该服务器套接字。

b).while ( pGateInfo->HasCompletionPacket() ) 验证消息格式。

case \“-\“: 发送心跳数据包到每个LoginGate服务器。



case \“A\“:  处理每个LoginGat服务器转发的客户端的消息增加到各自网关(CGateInfo)g_SendToGateQ队列中,然后ThreadFuncForMsg线程进行验证后再发送消息到各个LoginGate服务器。

        pGateInfo->ReceiveSendUser(&szTmp[2]);



case \“O\“: 处理每个网关Accept客户端后增加pUserInfo用户信息到各自网关的UserInfoList列表中。

       pGateInfo->ReceiveOpenUser(&szTmp[2]);



case \“X\“: 处理每个网关收到客户端Socket关闭之后发送过来的消息。设置该网关socket相应状态。

       pGateInfo->ReceiveCloseUser(&szTmp[2]);



case \“S\“:  GameSvr服务器发送的消息,更新TBL_ACCOUNT,验证字段,说明用户已下线,下次登录必须先到LoginSvr服务器再次验证。

       pGateInfo->ReceiveServerMsg(&szTmp[2]);



case \“M\“:  GameSvr服务器发送的消息,创建一个用户的消息,把用户ID,密码,名字插入TBL_ACCOUNT表中插入成功返回SM_NEWID_SUCCESS,否则SM_NEWID_FAIL,把在信息前加#,信息后加!  不做TBL_ACCOUNTADD表的添加,只增加TBL_ACCOUNT表信息。



               ‘A’:是LoginGate 服务器转发客户端消息到g_MsgQueue队列, 由ThreadFuncForMsg线程处理后,转发到各个loginGate服务器

继续投递I/O操作。



启动InitServerThreadForMsg 创建ThreadFuncForMsg线程。c   

收到loginGate服务器发送过来的消息之后,ServerWorkerThread经过数据包分析之后(case \“A\“),把客户端的消息,写入g_SendToGateQ队列中,然后在本线程中再进行处理。

              遍历g_SendToGateQ队列中数据,验证数据包是否正确(#!字符)根据DefaultMsg.wIdent标志

case CM_IDPASSWORD:   处理登陆业务

          遍历UserInfoList用户列表信息,到数据库表TBL_ACCOUNT中找相应信息,如果失败发送(SM_ID_NOTFOUND, SM_PASSWD_FAIL)消息,否则发送SM_PASSOK_SELECTSERVER+ g_szServerList(SelGate服务器列表消息)

SelGate服务器列表消息(对应TBL_SERVERINFO数据库表中数据),供用户选择登录的SelGate服务器。



       CM_SELECTSERVER: 选择服务器(SelGate)

              遍历UserInfoList用户列表信息,根据socket,找到用户密钥,消息解密后,遍历g_GameServerList列表,把用户选择的SelGate服务器转化为IP地址,发送至LoginGate服务器,再转发至客户端。设置该用户SelServer的标志状态。从该网关的UserInfoList用户列表中删除该用户。



CM_ADDNEWUSER:  新注册用户

                     判断用户名是否已存在,失败发送SM_NEWID_FAIL消息,成功,写插入表数据,并发送SM_NEWID_SUCCESS消息到 LoginGate服务器,转发至客户端。



IDM_STOPSERVICE: 停止服务(IOCP模型Server响应客户端请求)

    Close -> OnCommand(IDM_STOPSERVICE, 0L); ->g_fTerminated = TRUE; 三个线程退出。



主要流程:

服务启动后,LoginSvr启动了AcceptThread,和ServerWorkerThread线程,AcceptThread线程接收loginGate,GameSvr服务器连接,加入g_GateList网关列表中,ServerWorkerThread线程从完成端口取得刚完成的WSASend/WSARecv的结果后,进行分析处理两个服务器发送来的消息。服务启动同时,启动ThreadFuncForMsg线程,该线程从g_MsgQueue(iocp读到的loginGate服务器发来的数据)中取出数据,处理数据。投递I/O,利用IOCP模型,发送到loginGate服务器。

举报 使用道具

回复
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

0

关注

2

粉丝

3048

主题
精彩推荐
热门资讯
网友晒图
图文推荐
  • 微信

  • QQ群

QQ|Archiver|手机版|小黑屋|88M2传奇资源网 ( 鲁ICP备20017785号-2 )|网站地图

GMT+8, 2024-7-14 09:40 , Processed in 0.109450 second(s), 35 queries , Gzip On.

Powered by Discuz! X3.4

Copyright © 2001-2020, Tencent Cloud.