开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 游戏 > 模拟服务器 > 查看源码
SockMsg_DBSrv.cpp
资源名称：LegendOfMir2_Server020418.zip　[点击查看]
上传用户：szopptop
上传日期：2013-04-23
资源大小：1047k
文件大小：11k
源码类别：

模拟服务器

开发平台：

Visual C++

SockMsg_DBSrv.cpp：源码内容
  1. #include "stdafx.h"
  3. VOID WINAPI OnTimerProc(HWND hWnd, UINT uMsg, UINT_PTR idEvent, DWORD dwTime);
  5. UINT WINAPI ProcessLogin(LPVOID lpParameter);
  6. UINT WINAPI ProcessUserHuman(LPVOID lpParameter);
  7. UINT WINAPI ProcessMonster(LPVOID lpParameter);
  8. UINT WINAPI ProcessNPC(LPVOID lpParameter);
  10. BOOL jRegGetKey(LPCTSTR pSubKeyName, LPCTSTR pValueName, LPBYTE pValue);
  12. char g_szRemainBuff[DATA_BUFSIZE];
  13. int g_nRemainBuffLen = 0;
  15. void ProcReceiveBuffer(char *pszPacket, int nRecv)
  16. {
  17. int nBuffLen = nRecv;
  18. char szBuff[DATA_BUFSIZE];
  19. char *pszFirst, *pszEnd = &szBuff[0], *pszDevide;
  20. _TDEFAULTMESSAGE DefMsg;
  21. _TDEFAULTMESSAGE SendDefMsg;
  22. int nCertification;
  23. WORD w1, w2;
  24. LONG lValid;
  25. int nPos;
  26. char szCC[32];
  27. char szEncodeMsg[256];
  29. CReadyUserInfo *pReadUserInfo;
  30. CUserInfo *pUserInfo;
  32. _TCLIENTITEMRCD tClientItemRcd;
  34. if (g_nRemainBuffLen)
  35. memmove(szBuff, g_szRemainBuff, g_nRemainBuffLen);
  37. memmove(&szBuff[g_nRemainBuffLen], pszPacket, nBuffLen + 1);
  39. nBuffLen += g_nRemainBuffLen;
  41. while (nBuffLen)
  42. {
  43. if ((pszFirst = (char *)memchr(pszEnd, '#', nBuffLen)) && (pszEnd = (char *)memchr(pszFirst, '!', nBuffLen)))
  44. {
  45. *pszEnd++ = '';
  47. if (pszDevide = (char *)memchr(pszFirst, '/', pszEnd - pszFirst))
  48. {
  49. *pszDevide++ = '';
  51. nCertification = AnsiStrToVal(pszFirst + 1);
  53. w1 = nCertification ^ 0xAA;
  54. w2 = memlen(pszDevide) - 1;
  55. lValid = MAKELONG(w1, w2);
  57. nPos = fnEncode6BitBufA((unsigned char *)&lValid, szCC, sizeof(LONG), sizeof(szCC));
  58. szCC[nPos] = '';
  60. if (memcmp((pszEnd - nPos - 1), szCC, nPos) == 0)
  61. {
  62. fnDecodeMessageA(&DefMsg, pszDevide);
  64. *(pszEnd - nPos - 1) = '';
  66. switch (DefMsg.wIdent)
  67. {
  68. case DBR_LOADHUMANRCD2:
  69. {
  70. CReadyUserInfo2* pReadyUserInfo2 = new CReadyUserInfo2;
  72. pReadyUserInfo2->m_dwReadyStartTime = GetTickCount();
  73. pReadyUserInfo2->m_nNumOfGenItem = HIBYTE(DefMsg.wParam);
  74. pReadyUserInfo2->m_nNumOfMagic = DefMsg.wSeries;
  75. pReadyUserInfo2->m_nNumOfItem = LOBYTE(DefMsg.wParam);
  77. fnDecode6BitBufA((pszDevide + DEFBLOCKSIZE), (char *)&pReadyUserInfo2->m_THumanRcd, sizeof(_THUMANRCD));
  79. memmove(pReadyUserInfo2->pszData, pszDevide + DEFBLOCKSIZE + HUMANRCDBLOCKSIZE, memlen(pszDevide + DEFBLOCKSIZE + HUMANRCDBLOCKSIZE));
  81. g_xReadyUserInfoList2.AddNewNode(pReadyUserInfo2);
  83. break;
  84. }
  85. case DBR_LOADHUMANRCD:
  86. {
  87. pReadUserInfo = (CReadyUserInfo *)DefMsg.nRecog;
  89. nPos = fnDecode6BitBufA((pszDevide + DEFBLOCKSIZE), (char *)&pReadUserInfo->m_pUserInfo->m_THumanRcd, sizeof(_THUMANRCD));
  91. char *pszData;
  93. pszData = (pszDevide + DEFBLOCKSIZE + HUMANRCDBLOCKSIZE);
  95. if (HIBYTE(DefMsg.wParam)) // Decode General Item
  96. {
  97. pReadUserInfo->m_pUserInfo->m_nNumOfGenItems = HIBYTE(DefMsg.wParam);
  99. _TGENITEMRCD GenItemRcd;
  100. char szVal[5];
  102. for (int i = 0; i < HIBYTE(DefMsg.wParam); i++)
  103. {
  104. _LPTGENERALITEMRCD lptGenItemRcd = new _TGENERALITEMRCD;
  106. if (lptGenItemRcd)
  107. {
  108. fnDecode6BitBufA(pszData, (char *)&GenItemRcd, sizeof(_TGENITEMRCD));
  110. memcpy(lptGenItemRcd->szMakeIndex, GenItemRcd.szItem, 12);
  112. ZeroMemory(szVal, sizeof(szVal));
  114. memcpy(szVal, &lptGenItemRcd->szMakeIndex[1], 3);
  115. lptGenItemRcd->nStdIndex = AnsiStrToVal(szVal);
  116. memcpy(szVal, &lptGenItemRcd->szMakeIndex[4], 4);
  117. lptGenItemRcd->nDura = AnsiStrToVal(szVal);
  118. memcpy(szVal, &lptGenItemRcd->szMakeIndex[8], 4);
  119. lptGenItemRcd->nDuraMax = AnsiStrToVal(szVal);
  121. pReadUserInfo->m_pUserInfo->m_lpTGenItemRcd.AddNewNode(lptGenItemRcd);
  123. pszData += GENITEMRCDBLOCKSIZE;
  124. }
  125. }
  126. }   
  128. if (DefMsg.wSeries) // Decode Magic
  129. {
  130. pReadUserInfo->m_pUserInfo->m_nNumOfMagics = DefMsg.wSeries;
  132. for (int i = 0; i < DefMsg.wSeries; i++)
  133. {
  134. _LPTHUMANMAGICRCD lpHumanMagicRcd = new _THUMANMAGICRCD;
  136. if (lpHumanMagicRcd)
  137. {
  138. fnDecode6BitBufA(pszData, (char *)lpHumanMagicRcd, sizeof(_THUMANMAGICRCD));
  139. pReadUserInfo->m_pUserInfo->m_lpTMagicRcd.AddNewNode(lpHumanMagicRcd);
  140. pszData += MAGICRCDBLOCKSIZE;
  142. //#ifdef _DEBUG
  143. // _RPT3(_CRT_WARN, "%d - %d - %dn", lpHumanMagicRcd->btLevel, lpHumanMagicRcd->btUseKey, lpHumanMagicRcd->nCurrTrain);
  144. //#endif
  145. }
  146. }
  147. }   
  149. if (LOBYTE(DefMsg.wParam)) // Decode Item
  150. {
  151. pReadUserInfo->m_pUserInfo->m_nNumOfItems = LOBYTE(DefMsg.wParam);
  152. // pReadUserInfo->m_pUserInfo->m_lpTItemRcd = (_LPTUSERITEMRCD)GlobalAlloc(GPTR, sizeof(_TUSERITEMRCD) * DefMsg.wParam);
  154. for (int i = 0; i < LOBYTE(DefMsg.wParam); i++)
  155. {
  156. _LPTUSERITEMRCD lpTItemRcd = new _TUSERITEMRCD;
  158. if (lpTItemRcd)
  159. {
  160. fnDecode6BitBufA(pszData, (char *)lpTItemRcd, sizeof(_TUSERITEMRCD));
  161. pReadUserInfo->m_pUserInfo->m_lpTItemRcd.AddNewNode(lpTItemRcd);
  162. pszData += ITEMRCDBLOCKSIZE;
  163. }
  164. }
  165. }
  167. if (DefMsg.wTag) // Decode Horse
  168. {
  169. if (!pReadUserInfo->m_pUserInfo->m_lpTHorseRcd)
  170. pReadUserInfo->m_pUserInfo->m_lpTHorseRcd = new _THORSERCD;
  172. fnDecode6BitBufA(pszData, (char *)pReadUserInfo->m_pUserInfo->m_lpTHorseRcd, sizeof(_THORSERCD));
  173. }
  175. if (pReadUserInfo->m_pUserInfo->m_pxPlayerObject)
  176. {
  177. pReadUserInfo->m_pUserInfo->m_pxPlayerObject->MakeFeature();
  178. pReadUserInfo->m_pUserInfo->m_pxPlayerObject->Initialize();
  179. pReadUserInfo->m_pUserInfo->m_pxPlayerObject->m_fIsAlive = TRUE;
  181. pReadUserInfo->m_pUserInfo->m_btCurrentMode = USERMODE_PLAYGAME;
  182. }
  184. break;
  185. }
  186. case DBR_MAKEITEMRCD:
  187. {
  188. pUserInfo = (CUserInfo *)DefMsg.nRecog;
  190. _LPTUSERITEMRCD lpTItemRcd = new _TUSERITEMRCD;
  192. if (lpTItemRcd)
  193. {
  194. nPos = fnDecode6BitBufA((pszDevide + DEFBLOCKSIZE), (char *)lpTItemRcd, sizeof(_TUSERITEMRCD));
  196. pUserInfo->m_lpTItemRcd.AddNewNode(lpTItemRcd);
  198. fnMakeDefMessage(&SendDefMsg, SM_ADDITEM, (int)pUserInfo->m_pxPlayerObject, 0, 0, 1);
  200. if (lpTItemRcd->szMakeIndex[0] != 'G')
  201. {
  202. g_pStdItemSpecial[lpTItemRcd->nStdIndex].GetStandardItem(&tClientItemRcd);
  203. g_pStdItemSpecial[lpTItemRcd->nStdIndex].GetUpgradeStdItem(&tClientItemRcd, lpTItemRcd);
  204. }
  206. memcpy(tClientItemRcd.szMakeIndex, lpTItemRcd->szMakeIndex, 12);
  208. tClientItemRcd.nDura = lpTItemRcd->nDura;
  209. tClientItemRcd.nDuraMax = lpTItemRcd->nDuraMax;
  211. nPos =  fnEncode6BitBufA((unsigned char *)&tClientItemRcd, szEncodeMsg, sizeof(_TCLIENTITEMRCD), sizeof(szEncodeMsg));
  212. szEncodeMsg[nPos] = '';
  214. pUserInfo->m_pxPlayerObject->SendSocket(&SendDefMsg, szEncodeMsg);
  215. }
  217. break;
  218. }
  219. case DBR_MAKEITEMRCD2:
  220. {
  221. CPlayerObject* pPlayerObject = (CPlayerObject *)DefMsg.nRecog;
  223. pUserInfo = pPlayerObject->m_pUserInfo;
  225. _LPTUSERITEMRCD lpTItemRcd = new _TUSERITEMRCD;
  227. if (lpTItemRcd)
  228. {
  229. nPos = fnDecode6BitBufA((pszDevide + DEFBLOCKSIZE), (char *)lpTItemRcd, sizeof(_TUSERITEMRCD));
  231. pUserInfo->m_lpTItemRcd.AddNewNode(lpTItemRcd);
  233. fnMakeDefMessage(&SendDefMsg, SM_ADDITEM, (int)pUserInfo->m_pxPlayerObject, 0, 0, 1);
  235. if (lpTItemRcd->szMakeIndex[0] != 'G')
  236. {
  237. g_pStdItemSpecial[lpTItemRcd->nStdIndex].GetStandardItem(&tClientItemRcd);
  238. g_pStdItemSpecial[lpTItemRcd->nStdIndex].GetUpgradeStdItem(&tClientItemRcd, lpTItemRcd);
  239. }
  241. memcpy(tClientItemRcd.szMakeIndex, lpTItemRcd->szMakeIndex, 12);
  243. tClientItemRcd.nDura = lpTItemRcd->nDura;
  244. tClientItemRcd.nDuraMax = lpTItemRcd->nDuraMax;
  246. nPos =  fnEncode6BitBufA((unsigned char *)&tClientItemRcd, szEncodeMsg, sizeof(_TCLIENTITEMRCD), sizeof(szEncodeMsg));
  247. szEncodeMsg[nPos] = '';
  249. pUserInfo->m_pxPlayerObject->SendSocket(&SendDefMsg, szEncodeMsg);
  250. }
  252. break;
  253. }
  254. }
  255. }
  256. }
  258. nBuffLen -= (pszEnd - pszFirst);
  259. }
  260. else
  261. break;
  262. } // while
  264. if (pszFirst && (nBuffLen > 0))
  265. {
  266. memmove(g_szRemainBuff, pszFirst, nBuffLen);
  267. g_nRemainBuffLen = nBuffLen;
  268. #ifdef _DEBUG
  269. _RPT2(_CRT_WARN, "ProcReceiveBuffer:%d, %sn", g_nRemainBuffLen, pszFirst);
  270. #endif
  271. }
  272. else
  273. g_nRemainBuffLen = 0;
  274. }
  276. VOID WINAPI OnProcessUserHuman(HWND hWnd, UINT uMsg, UINT_PTR idEvent, DWORD dwTime);
  278. LPARAM OnClientSockMsg(WPARAM wParam, LPARAM lParam)
  279. {
  280. switch (WSAGETSELECTEVENT(lParam))
  281. {
  282. case FD_CONNECT:
  283. {
  284. if (CheckSocketError(lParam))
  285. {
  286. InsertLogMsg(IDS_CONNECT_DBSERVER);
  288. KillTimer(g_hMainWnd, _ID_TIMER_CONNECTSERVER);
  290. UINT dwThreadIDForMsg = 0;
  291. unsigned long hThreadForMsg = 0;
  293. // SetTimer(g_hMainWnd, _ID_TIMER_PROCESSUSERHUMAN, 1, (TIMERPROC)OnProcessUserHuman);
  294. if (hThreadForMsg = _beginthreadex(NULL, 0, ProcessLogin, NULL, 0, &dwThreadIDForMsg))
  295. {
  296. // SetThreadPriority((HANDLE)hThreadForMsg, THREAD_PRIORITY_HIGHEST);
  297. hThreadForMsg = _beginthreadex(NULL, 0, ProcessUserHuman, NULL, 0, &dwThreadIDForMsg);
  298. hThreadForMsg = _beginthreadex(NULL, 0, ProcessMonster, NULL, 0, &dwThreadIDForMsg);
  299. hThreadForMsg = _beginthreadex(NULL, 0, ProcessNPC, NULL, 0, &dwThreadIDForMsg);
  300. }
  302. int nPort;
  304. if (!jRegGetKey(_GAME_SERVER_REGISTRY, _TEXT("LocalPort"), (LPBYTE)&nPort))
  305. nPort = 5000;
  307. InitServerSocket(g_ssock, &g_saddr, _IDM_SERVERSOCK_MSG, nPort, 1);
  309. InsertLogMsg(IDS_STARTSERVICE);
  310. SendMessage(g_hStatusBar, SB_SETTEXT, MAKEWORD(0, 0), (LPARAM)_T("Ready"));
  311. }
  312. else
  313. {
  314. closesocket(g_csock);
  315. g_csock = INVALID_SOCKET;
  317. SetTimer(g_hMainWnd, _ID_TIMER_CONNECTSERVER, 10000, (TIMERPROC)OnTimerProc);
  318. }
  320. break;
  321. }
  322. case FD_CLOSE:
  323. {
  324. closesocket(g_csock);
  325. g_csock = INVALID_SOCKET;
  327. InsertLogMsg(IDS_DISCONNECT_DBSERVER);
  329. break;
  330. }
  331. case FD_READ:
  332. {
  333. char szPacket[8096];
  335. int nRecv = recv((SOCKET)wParam, szPacket, sizeof(szPacket), 0);
  337. #ifdef _DEBUG
  338. _RPT1(_CRT_WARN, "ClientSockMsg[FD_READ]:%dn", nRecv);
  339. #endif
  340. szPacket[nRecv] = '';
  342. ProcReceiveBuffer(szPacket, nRecv);
  344. break;
  345. }
  346. }
  348. return 0L;
  349. }