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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 游戏 > 模拟服务器 > 查看源码
Robot.cpp
资源名称：SwordOnline.rar　[点击查看]
上传用户：dzyhzl
上传日期：2019-04-29
资源大小：56270k
文件大小：11k
源码类别：

模拟服务器

开发平台：

C/C++

Robot.cpp：源码内容
  1. //******************************************************************************
  2. /*! file       Robot.cpp
  3. *   brief      简要描述
  4. *
  5. * 详细描述
  6. *   author 作者
  7. *   version 版本号
  8. *   date 2003-6-3 16:17:20
  9. *   sa 参考内容
  10. *   todo 需要完成退出时的帐号回收
  11. 退出时角色的删除
  12. g_csPlayerList没有用
  13. *******************************************************************************/
  16. #include "stdafx.h"
  17. #include "resource.h"
  18. #include "Player.h"
  19. #include "Robot.h"
  21. #include <objbase.h>
  22. #include <initguid.h>
  24. #include <process.h>
  25. #include <Shellapi.h>
  27. #include "..RobotManagerprotocol.h"
  28. #include "..RobotManagerstruct.h"
  30. #include "RainbowInterface.h"
  32. #include "library.h"
  33. #include "Macro.h"
  34. #include "Utils.h"
  35. #include "tstring.h"
  36. #include "Inifile.h"
  37. #include "buffer.h"
  38. #include "CriticalSection.h"
  39. #include "Event.h"
  41. using OnlineGameLib::Win32::CIniFile;
  42. using OnlineGameLib::Win32::GetAppFullPath;
  43. using OnlineGameLib::Win32::_tstring;
  44. using OnlineGameLib::Win32::CPackager;
  45. using OnlineGameLib::Win32::CCriticalSection;
  46. using OnlineGameLib::Win32::CEvent;
  49. PLAYER_LIST g_thePlayers;
  51. #define MAX_LOADSTRING 100
  53. // Global Variables:
  54. HINSTANCE g_hInst; // current instance
  55. TCHAR g_szBuffer[MAX_LOADSTRING]; // The title bar text
  56. TCHAR g_szWindowClass[MAX_LOADSTRING]; // The title bar text
  58. // 要跟随的角色的名字
  59. char g_szRoleName[32];
  60. char *g_pRoleName = g_szRoleName;
  62. NOTIFYICONDATA g_nidIconData = { 0 };
  63. const UINT g_unTrayIconID = 500;
  65. #define WM_TRAY_NOTIFY_MSG WM_USER + 0x100
  67. _tstring g_sAppPath;
  68. CIniFile g_theIniFile;
  70. HANDLE g_hWorkThread = INVALID_HANDLE_VALUE;
  71. CEvent g_hQuitEvent( NULL, true, false, "QuitEvent" );
  73. // 相对于RobotManager的客户
  74. IClient *g_pClientToManager = NULL;
  76. OnlineGameLib::Win32::CLibrary g_theRainbowLib( "rainbow.dll" );
  78. typedef HRESULT ( __stdcall * pfnCreateClientInterface )( REFIID riid, void **ppv );
  80. _tstring g_pAddressToManager;
  81. unsigned short g_usPortToManager = 0;
  83. bool StartupNetwork();
  84. void DestroyNetwork();
  85. void FreePlayerList();
  87. unsigned int __stdcall HelperThread( void *pParam );
  88. void OnDispatchTask(const void* pData);
  90. // Foward declarations of functions included in this code module:
  91. ATOM RegisterClass(HINSTANCE hInstance);
  92. BOOL InitInstance(HINSTANCE, int);
  93. LRESULT CALLBACK WndProc(HWND, UINT, WPARAM, LPARAM);
  94. LRESULT CALLBACK About(HWND, UINT, WPARAM, LPARAM);
  96. int APIENTRY WinMain(HINSTANCE hInstance,
  97.                      HINSTANCE hPrevInstance,
  98.                      LPSTR     lpCmdLine,
  99.                      int       nCmdShow)
  100. {
  101.   // TODO: Place code here.
  102. MSG msg;
  103. HACCEL hAccelTable;
  105. // Initialize global strings
  106. LoadString(hInstance, IDS_APP_TITLE, g_szBuffer, MAX_LOADSTRING);
  107. LoadString(hInstance, IDC_ROBOT, g_szWindowClass, MAX_LOADSTRING);
  108. RegisterClass(hInstance);
  110. g_sAppPath = GetAppFullPath( hInstance );
  112. char szIniFile[MAX_PATH];
  113. sprintf( szIniFile, "%srtcfg.ini", g_sAppPath.c_str() );
  115. g_theIniFile.SetFile( szIniFile );
  116. g_usPortToManager = g_theIniFile.ReadInteger( "Robot", "PORT", 5096 );
  118. g_pAddressToManager.resize( MAX_LOADSTRING );
  119. g_theIniFile.ReadString( "Robot", 
  120. "IPAddr", 
  121. const_cast< char * >( g_pAddressToManager.c_str() ), 
  122. MAX_LOADSTRING, 
  123. "..." );
  125. g_theIniFile.ReadString( "Role", "Main", g_szRoleName, 32, "" );
  127. if( !StartupNetwork())
  128. return FALSE;
  130. if (!InitInstance (hInstance, nCmdShow)) 
  131. return FALSE;
  133. ::Shell_NotifyIcon( NIM_ADD, &g_nidIconData );
  135. hAccelTable = LoadAccelerators(hInstance, (LPCTSTR)IDC_ROBOT);
  137. // Main message loop:
  138. while (GetMessage(&msg, NULL, 0, 0)) 
  139. {
  140. if (!TranslateAccelerator(msg.hwnd, hAccelTable, &msg)) 
  141. {
  142. TranslateMessage(&msg);
  143. DispatchMessage(&msg);
  144. }
  145. }
  147. FreePlayerList();
  148. ::Shell_NotifyIcon( NIM_DELETE, &g_nidIconData );
  150. DestroyNetwork();
  152. return msg.wParam;
  153. }
  155. ATOM RegisterClass(HINSTANCE hInstance)
  156. {
  157. WNDCLASSEX wcex = { 0 };
  159. wcex.cbSize = sizeof(WNDCLASSEX); 
  161. wcex.lpfnWndProc = (WNDPROC)WndProc;
  162. wcex.hInstance = hInstance;
  163. wcex.lpszClassName = g_szWindowClass;
  165. return RegisterClassEx(&wcex);
  166. }
  168. BOOL InitInstance(HINSTANCE hInstance, int nCmdShow)
  169. {
  170.    HWND hWnd = NULL;
  172.    g_hInst = hInstance; // Store instance handle in our global variable
  174.    if ( NULL == ( hWnd = CreateWindow(g_szWindowClass, g_szBuffer, 0,
  175. CW_USEDEFAULT, 0, CW_USEDEFAULT, 0, NULL, NULL, hInstance, NULL) ) )
  176.    {
  177.       return FALSE;
  178.    }
  180. g_nidIconData.cbSize = sizeof( NOTIFYICONDATA );
  182. g_nidIconData.hWnd = hWnd;
  183. g_nidIconData.uID = g_unTrayIconID;
  185. g_nidIconData.uCallbackMessage = WM_TRAY_NOTIFY_MSG;
  186. g_nidIconData.uFlags = NIF_MESSAGE;
  188. strcpy( g_nidIconData.szTip, "Robot" );
  189. g_nidIconData.uFlags |= NIF_TIP;
  191. HICON hIcon = NULL;
  193. if ( NULL != ( hIcon = ::LoadIcon( hInstance, MAKEINTRESOURCE( IDI_TRAYICON ) ) ) )
  194. {
  195. g_nidIconData.hIcon = hIcon;
  197. g_nidIconData.uFlags |= NIF_ICON;
  198. } 
  200.    return TRUE;
  201. }
  203. LRESULT CALLBACK WndProc(HWND hWnd, UINT message, WPARAM wParam, LPARAM lParam)
  204. {
  205. int wmId, wmEvent;
  207. switch (message) 
  208. {
  209. case WM_COMMAND:
  210. wmId    = LOWORD(wParam); 
  211. wmEvent = HIWORD(wParam); 
  212. // Parse the menu selections:
  213. switch (wmId)
  214. {
  215. case IDM_ABOUT:
  216.    DialogBox(g_hInst, (LPCTSTR)IDD_ABOUTBOX, hWnd, (DLGPROC)About);
  217.    break;
  218. case IDM_EXIT:
  219.    DestroyWindow(hWnd);
  220.    break;
  221. default:
  222.    return DefWindowProc(hWnd, message, wParam, lParam);
  223. }
  224. break;
  226. case WM_DESTROY:
  227. PostQuitMessage(0);
  228. break;
  230. case WM_TRAY_NOTIFY_MSG:
  231. {
  232. UINT uID = (UINT)wParam;
  233. UINT uMsg = (UINT)lParam;
  235. POINT pt = { 0 };
  237. if ( g_unTrayIconID == uID )
  238. {
  239. switch ( uMsg )
  240. {
  241. case WM_LBUTTONDOWN:
  242. case WM_RBUTTONDOWN:
  243. case WM_CONTEXTMENU:
  244. {
  245. ::GetCursorPos( &pt );
  247. HMENU hMenu = ::GetSubMenu( ::LoadMenu( g_hInst,
  248. MAKEINTRESOURCE( IDC_ROBOT ) ), 
  249. 0 );
  251. ::SetForegroundWindow( hWnd );
  253. ::TrackPopupMenu( hMenu, 
  254. TPM_LEFTALIGN | TPM_BOTTOMALIGN | TPM_LEFTBUTTON | TPM_RIGHTBUTTON,
  255. pt.x,
  256. pt.y,
  257. 0,
  258. hWnd,
  259. NULL );
  261. ::PostMessage( hWnd, WM_NULL, 0, 0 );
  262. }
  263. break;
  264. }
  265. }
  266. }
  267. break;
  269. default:
  270. return DefWindowProc(hWnd, message, wParam, lParam);
  271.    }
  273.    return 0;
  274. }
  276. // Mesage handler for about box.
  277. LRESULT CALLBACK About(HWND hDlg, UINT message, WPARAM wParam, LPARAM lParam)
  278. {
  279. switch (message)
  280. {
  281. case WM_INITDIALOG:
  282. return TRUE;
  284. case WM_COMMAND:
  285. if (LOWORD(wParam) == IDOK || LOWORD(wParam) == IDCANCEL) 
  286. {
  287. EndDialog(hDlg, LOWORD(wParam));
  288. return TRUE;
  289. }
  290. break;
  291. }
  292.     return FALSE;
  293. }
  295. //******************************************************************************
  296. /*! fn     bool StartupNetwork()
  297. *   brief   启动与RobotManager的连接，robot是RobotManager的客户，RobotManager向每个Robot
  298. 分配帐号,密码和角色的名字
  299. *******************************************************************************/
  300. bool StartupNetwork()
  301. {
  302. // 启动与RobotManager的连接
  303. pfnCreateClientInterface pClientFactroyFun = ( pfnCreateClientInterface )( g_theRainbowLib.GetProcAddress( _T( "CreateInterface" ) ) );
  305. IClientFactory *pClientFactory = NULL;
  307. if ( pClientFactroyFun && SUCCEEDED( pClientFactroyFun( IID_IClientFactory, reinterpret_cast< void ** >( &pClientFactory ) ) ) )
  308. {
  309. pClientFactory->SetEnvironment( 50, 1024 );
  311. pClientFactory->CreateClientInterface( IID_IESClient, reinterpret_cast< void ** >( &g_pClientToManager ) );
  313. SAFE_RELEASE( pClientFactory );
  314. }
  316. if ( g_pClientToManager )
  317. {
  318. g_pClientToManager->Startup();
  320. g_pClientToManager->RegisterMsgFilter( 0, NULL );
  322. if ( FAILED( g_pClientToManager->ConnectTo( g_pAddressToManager.c_str(), g_usPortToManager ) ) )
  323. {
  324. g_pClientToManager->Cleanup();
  326. SAFE_RELEASE( g_pClientToManager );
  328. return false;
  329. }
  330. }
  332. // 启动工作线程
  333. IClient *pCloneClient = NULL;
  334. g_pClientToManager->QueryInterface( IID_IESClient, reinterpret_cast< void ** >( &pCloneClient ) );
  336. unsigned int threadID = 0;
  338. g_hWorkThread = (HANDLE)::_beginthreadex(0, 
  339. 0, 
  340. HelperThread,
  341. ( void * )pCloneClient, 
  342. 0, 
  343. &threadID );
  345. if ( g_hWorkThread == INVALID_HANDLE_VALUE )
  346. {
  347. return false;
  348. }
  350. // 向RobotManager发送消息，请求登陆帐号，和服务器地址
  351. tagReqT_CMD rt;
  353. rt.cProtocol = enumRequireTask;
  355. g_pClientToManager->SendPackToServer( &rt, sizeof( rt ) );
  357. return true;
  358. }
  360. void DestroyNetwork()
  361. {
  362. // 关闭网络连接
  363. if ( g_pClientToManager )
  364. {
  365. g_pClientToManager->Cleanup();
  367. SAFE_RELEASE( g_pClientToManager );
  368. }
  370. // 中止工作线程
  371. g_hQuitEvent.Set();
  373. if ( WAIT_TIMEOUT == ::WaitForSingleObject( g_hWorkThread, 2000 ) )
  374. {
  375. ::TerminateThread( g_hWorkThread, 0 );
  376. }
  378. if ( INVALID_HANDLE_VALUE != g_hWorkThread )
  379. {
  380. SAFE_CLOSEHANDLE( g_hWorkThread );
  381. }
  382. }
  384. // Robot 与 RobotManager 通讯的线程
  385. unsigned int __stdcall HelperThread( void *pParam )
  386. {
  387. IClient *pCloneClient = ( IClient * )pParam;
  389. ASSERT( pCloneClient );
  391. while ( !g_hQuitEvent.Wait( 0 ) )
  392. {
  393. size_t datalength = 0;
  394. const void *pData = pCloneClient->GetPackFromServer( datalength );
  396. if ( pData && datalength )
  397. {
  398. BYTE cProtocol = CPackager::Peek( pData );
  400. switch ( cProtocol )
  401. {
  402. case enumDispatchTask:
  403. OnDispatchTask(pData);
  404. break;
  406. default:
  407. break;
  408. }
  409. }
  411. ::Sleep( 40 );
  412. }
  414. SAFE_RELEASE( pCloneClient );
  416. return 0L;
  417. }
  419. //******************************************************************************
  420. /*! fn     void OnDispatchTask(const void* pData)
  421. *   brief  从RobotManager接受任务
  422. *******************************************************************************/
  423. void OnDispatchTask(const void* pData)
  424. {
  425. tagDspT_INFO *pDTI = ( tagDspT_INFO * )pData;
  427. if ( pDTI->dwVersion != 1 )
  428. {
  429. ::MessageBox( NULL, "Version is old, Please update this application", "Info", MB_ICONEXCLAMATION );
  430. return;
  431. }
  433. size_t nAccCount = pDTI->nAccCount;
  434. size_t nNameLen = pDTI->nNameLen;
  435. char* pAccName = pDTI->szAccName; 
  437. for ( int i = 0; i < nAccCount; i ++ )
  438. {
  439. memcpy( g_szBuffer, pAccName + i*nNameLen, nNameLen );
  441. IPlayer *pPlayer = new CPlayer( pDTI->theGameSvrInfo.szIP, 
  442. pDTI->theGameSvrInfo.nPort,
  443. g_szBuffer );
  445. pPlayer->ConnectToGateway();
  446. g_thePlayers.push_back( pPlayer );
  447. }
  448. }
  450. //******************************************************************************
  451. /*! fn     void FreePlayerList()
  452. *   brief  释放所有的Player
  453. *******************************************************************************/
  454. void FreePlayerList()
  455. {
  456. CCriticalSection::Owner locker( g_csPlayerList);
  458. PLAYER_LIST::iterator it;
  459. for ( it = g_thePlayers.begin(); it != g_thePlayers.end(); it ++ )
  460. {
  461. IPlayer *pPlayer = ( *it );
  463. if ( pPlayer )
  464. {
  465. delete pPlayer;
  466. }
  467. }
  468. }