網狐框架分析八--web登錄游戲大廳流程

---
#1.web客戶端代碼分析
web客戶端傳4個值，userID，passWord，IPAddr，IPPort，最后2個是連接服務器用的，userID和passWord是驗證用戶信息用的。
以下是客戶端代碼：
    var userID = $('#userID').val();
var passWord = $('#passWord').val();
var IpAddr = $('#IpAddr').val();
var IpPort = $('#IpPort').val();
var host = "ws://"+IpAddr+":"+IpPort+"/ws"; //host地址，用來連接服務器

var jsonData = {};
jsonData.MainCmdID = 1;
jsonData.SubCmdID = 2;
jsonData.userID = 1;
jsonData.passWord = hex_md5(passWord);      //對密碼進行md5加密處理
toStr = JSON.stringify(jsonData);       //把數據轉換為json格式
OutputLog(toStr);

try{
socket = new WebSocket(host);   //連服務器
OutputLog('Socket Status: '+socket.readyState);
socket.onopen = function(){
var myData = new Date();    //獲取當前時間信息
OutputLog(myData.toLocaleString()+'Socket Status: '+socket.readyState+'(open)');
socket.send(toStr); //向服務器發送消息
}
socket.onmessage = function(msg){   //收到服務器消息
var myData = new Date();
var jsonData = JSON.stringify(msg.data);
var jsonObj = window.JSON.parse(jsonData);
OutputLog(myData.toLocaleString()+":"+jsonObj);//輸出服務器消息
}
socket.onclose = function(){//接收服務器關閉消息
var myData = new Date();
OutputLog(myData.toLocaleString()+'Socket Status: '+socket.readyState+' (Close)');
}
}catch(exception){//異常處理
OutputLog('Error' + exception);
}

    
---
#2.服務器處理web客戶端請求
線程CServerSocketRSThread::OnEventThreadRun() 不停循環執行，
 CServerSocketItem::OnRecvCompleted()函數中的recv捕獲客戶端信息事件。
 根據：
 //接收數據
int iRetCode = recv(m_hSocket, (char *)m_cbRecvBuf + m_wRecvSize, sizeof(m_cbRecvBuf)-m_wRecvSize, 0);
if (iRetCode <= 0)
{
CloseSocket(m_wRountID);
return true;
}


//TODO 根據連接類型來做接受數據后的處理
//連接類型檢測
if (this->m_connectType == ConnectType_unknow){
string s((char *)m_cbRecvBuf);
if (s.find("HTTP") != string::npos){
this->m_connectType = ConnectType_websocket;
}
else{
this->m_connectType = ConnectType_socket;
}
}
判斷是否是web信息，然后發送給子項去處理具體消息。


然后在CAttemperEngineSink::OnEventTCPNetworkRead()函數中捕獲網絡事件，
增加函數：
    ///< qsz 解析網絡登錄包
if (Command.wMainCmdID == MDM_WEB_MSG)
{
OutputDebugString((char *)pData);
char* resulData = new char[wDataSize + 1];
memcpy(resulData, pData, wDataSize);
resulData[wDataSize] = '\0';


std::string stResult = resulData;
Json::Reader readerJson;
Json::Value  valueJson;


if (readerJson.parse(stResult, valueJson))
{
Command.wMainCmdID = valueJson["MainCmdID"].asInt();
Command.wSubCmdID = valueJson["SubCmdID"].asInt();
//MainCmdID = 11, SubCmdID = 222,   field1=11,field2=222
}
else
return false;


if (Command.wMainCmdID == MDM_GR_LOGON)
{
int userID = valueJson["userID"].asInt();
std::string passWord = valueJson["passWord"].asString();///< 客戶端上傳時已轉成md5
CMD_GR_LogonByUserID * pLogonByUserID = new CMD_GR_LogonByUserID;
pLogonByUserID->dwPlazaVersion = VER_PLAZA_FRAME;
pLogonByUserID->dwUserID = userID;
lstrcpyn(pLogonByUserID->szPassWord, passWord.c_str(), passWord.length() + 1);
pData = pLogonByUserID;
}
解析處理函數消息。




最后增加自己的函數處理返回消息，並發送給客戶端。
void CAttemperEngineSink::SendDataEx(DWORD dwSocketID, WORD wMainCmdID, WORD wSubCmdID, void * pData, WORD wDataSize){
int connectType = m_pITCPNetworkEngine->getConnectType(dwSocketID);
if (connectType == 2){//ConnectType_websocket
//TODO tmx Data2WebData處理
Json::Value root;
Json::Value arrayObj;
Json::Value item;


item["MainCmdID"] = 1;
item["SubCmdID"] = 1;


arrayObj.append(item);
root["array"] = arrayObj;
root.toStyledString();
std::string out = root.toStyledString();


OutputDebugString("======CAttemperEngineSink::SendDataEx======\n");
OutputDebugString(out.c_str());
m_pITCPNetworkEngine->SendData(dwSocketID, wMainCmdID, wSubCmdID, (void*)out.c_str(), out.length() );


item.clear();
arrayObj.clear();
root.clear();
}
else{
if (wDataSize == 0)
{
m_pITCPNetworkEngine->SendData(dwSocketID, wMainCmdID, wSubCmdID);
}
else{
m_pITCPNetworkEngine->SendData(dwSocketID, wMainCmdID, wSubCmdID, pData, wDataSize);
}
}
}


至此，web客戶端便能登錄游戲大廳，並在其它客戶端上顯示到此玩家信息了！