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

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

模拟服务器

开发平台：

Visual C++

ClientSockMsg.cpp：源码内容
  1. #include "stdafx.h"
  3. DWORD WINAPI ThreadFuncForMsg(LPVOID lpParameter);
  5. BOOL CheckSocketError(LPARAM lParam);
  7. VOID WINAPI OnTimerProc(HWND hWnd, UINT uMsg, UINT_PTR idEvent, DWORD dwTime);
  9. void OnCommand(WPARAM wParam, LPARAM lParam);
  10. BOOL InitThread(LPTHREAD_START_ROUTINE lpRoutine);
  12. extern SOCKET g_csock;
  14. extern HWND g_hMainWnd;
  15. extern HWND g_hStatusBar;
  16. extern HWND g_hToolBar;
  18. HANDLE g_hMsgThread = INVALID_HANDLE_VALUE;
  20. CWHQueue g_xMsgQueue;
  22. static char WorkBuff[8192];
  23. static int nWorkBuffLen;
  25. LPARAM OnClientSockMsg(WPARAM wParam, LPARAM lParam)
  26. {
  27. switch (WSAGETSELECTEVENT(lParam))
  28. {
  29. case FD_CONNECT:
  30. {
  31. DWORD dwThreadIDForMsg = 0;
  33. if (CheckSocketError(lParam))
  34. {
  35. dwThreadIDForMsg = 0;
  37. if (InitThread(ThreadFuncForMsg))
  38. // if ((g_hMsgThread = CreateThread(NULL, 0, ThreadFuncForMsg, NULL, 0, &dwThreadIDForMsg)) != INVALID_HANDLE_VALUE)
  39. {
  40. KillTimer(g_hMainWnd, _ID_TIMER_CONNECTSERVER);
  42. SetTimer(g_hMainWnd, _ID_TIMER_KEEPALIVE, 5000, (TIMERPROC)OnTimerProc);
  44. InsertLogMsg(IDS_CONNECT_LOGINSERVER);
  45. SendMessage(g_hStatusBar, SB_SETTEXT, MAKEWORD(1, 0), (LPARAM)_TEXT("Connected"));
  46. }
  47. }
  48. else
  49. {
  50. closesocket(g_csock);
  51. g_csock = INVALID_SOCKET;
  53. SetTimer(g_hMainWnd, _ID_TIMER_CONNECTSERVER, 10000, (TIMERPROC)OnTimerProc);
  54. }
  56. break;
  57. }
  58. case FD_CLOSE:
  59. {
  60. closesocket(g_csock);
  61. g_csock = INVALID_SOCKET;
  63. OnCommand(IDM_STOPSERVICE, 0);
  65. break;
  66. }
  67. case FD_READ:
  68. {
  69. int nSocket = 0;
  70. char *pszFirst = NULL, *pszEnd = NULL;
  72. UINT nRecv = 0;
  74. ioctlsocket((SOCKET)wParam, FIONREAD, (u_long *)&nRecv);
  76. if (nRecv)
  77. {
  78. char *pszPacket = new char[nRecv + 1];
  80. nRecv = recv((SOCKET)wParam, pszPacket, nRecv, 0);
  82. pszPacket[nRecv] = '';
  84. if (!(g_xMsgQueue.PushQ((BYTE *)pszPacket)))
  85. InsertLogMsg(_TEXT("[INFO] Not enough queue(g_xMsgQueue) buffer."));
  86. }
  88. break;
  89. }
  90. }
  92. return 0L;
  93. }
  95. void SendExToServer(char *pszPacket)
  96. {
  97. /* int nTotalSendBytes = 0;
  99. while (TRUE)
  100. {
  101. if ((nLen - nTotalSendBytes <= 0) || g_csock == INVALID_SOCKET)
  102. return;
  104. nTotalSendBytes += send(g_csock, pszData, nLen - nTotalSendBytes, 0);
  106. if (nTotalSendBytes < nLen)
  107. pszData += (nLen - nTotalSendBytes);
  108. else 
  109. return;
  110. } */
  112. DWORD dwSendBytes;
  113. WSABUF buf;
  115. buf.len = memlen(pszPacket) - 1;
  116. buf.buf = pszPacket;
  118. WSASend(g_csock, &buf, 1, &dwSendBytes, 0, NULL, NULL);
  119. }