---
#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客戶端便能登錄游戲大廳，并在其它客戶端上顯示到此玩家信息了！

總結

以上是生活随笔為你收集整理的网狐框架分析八--web登录游戏大厅流程的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。