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

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

模拟服务器

开发平台：

C/C++

Goddess2Dlg.cpp：源码内容
  1. // Goddess2Dlg.cpp : implementation file
  2. //
  4. #include "stdafx.h"
  5. #include "Goddess2.h"
  6. #include "Goddess2Dlg.h"
  7. #include "winsock2.h"
  8. #include <string>
  9. #include "tstring.h"
  10. #include "IniFile.h"
  11. #include "Utils.h"
  13. #include "src/IDBRoleServer.h"
  14. #include "src/KSG_RoleProcess.h"
  16. using namespace std;
  17. using namespace OnlineGameLib::Win32;
  19. #ifdef _DEBUG
  20. #define new DEBUG_NEW
  21. #undef THIS_FILE
  22. static char THIS_FILE[] = __FILE__;
  23. #endif
  25. bool CreateDatabaseEngine(HWND hwnd);
  26. void DestroyDatabaseEngine();
  28. void LoadSetting();
  29. void SaveSetting();
  31. static size_t g_nMaxRoleCount = 3;
  33. static unsigned short g_uServerPort = 5001;
  35. static size_t g_BackupSleepTime = 1;  //备份线程自动挂起时间
  36. static bool g_IsBackupSuspend = false;  //备份线程是否手工挂起
  39. int g_nKSG_RoleProcess_InitFlag = false;
  42. /////////////////////////////////////////////////////////////////////////////
  43. // CAboutDlg dialog used for App About
  45. class CAboutDlg : public CDialog
  46. {
  47. public:
  48. CAboutDlg();
  50. // Dialog Data
  51. //{{AFX_DATA(CAboutDlg)
  52. enum { IDD = IDD_ABOUTBOX };
  53. //}}AFX_DATA
  55. // ClassWizard generated virtual function overrides
  56. //{{AFX_VIRTUAL(CAboutDlg)
  57. protected:
  58. virtual void DoDataExchange(CDataExchange* pDX);    // DDX/DDV support
  59. //}}AFX_VIRTUAL
  61. // Implementation
  62. protected:
  63. //{{AFX_MSG(CAboutDlg)
  64. //}}AFX_MSG
  65. DECLARE_MESSAGE_MAP()
  66. };
  68. CAboutDlg::CAboutDlg() : CDialog(CAboutDlg::IDD)
  69. {
  70. //{{AFX_DATA_INIT(CAboutDlg)
  71. //}}AFX_DATA_INIT
  72. }
  74. void CAboutDlg::DoDataExchange(CDataExchange* pDX)
  75. {
  76. CDialog::DoDataExchange(pDX);
  77. //{{AFX_DATA_MAP(CAboutDlg)
  78. //}}AFX_DATA_MAP
  79. }
  81. BEGIN_MESSAGE_MAP(CAboutDlg, CDialog)
  82. //{{AFX_MSG_MAP(CAboutDlg)
  83. // No message handlers
  84. //}}AFX_MSG_MAP
  85. END_MESSAGE_MAP()
  87. /////////////////////////////////////////////////////////////////////////////
  88. // CGoddess2Dlg dialog
  90. CGoddess2Dlg::CGoddess2Dlg(CWnd* pParent /*=NULL*/)
  91. : CDialog(CGoddess2Dlg::IDD, pParent)
  92. {
  93. //{{AFX_DATA_INIT(CGoddess2Dlg)
  94. m_OpenPort = 0;
  95. //}}AFX_DATA_INIT
  96. // Note that LoadIcon does not require a subsequent DestroyIcon in Win32
  97. m_hIcon = AfxGetApp()->LoadIcon(IDI_GIDDESS2);
  98. }
  100. void CGoddess2Dlg::DoDataExchange(CDataExchange* pDX)
  101. {
  102. CDialog::DoDataExchange(pDX);
  103. //{{AFX_DATA_MAP(CGoddess2Dlg)
  104. DDX_Control(pDX, IDC_EDIT_OPEN_PORT, m_OpenPortCtl);
  105. DDX_Control(pDX, IDC_BUTTON_START_DB_SERVICE, m_StartDBService);
  106. DDX_Control(pDX, IDC_LIST_CLIENT, m_ClientList);
  107. DDX_Text(pDX, IDC_EDIT_OPEN_PORT, m_OpenPort);
  108. DDV_MinMaxUInt(pDX, m_OpenPort, 0, 65535);
  109. //}}AFX_DATA_MAP
  110. }
  112. BEGIN_MESSAGE_MAP(CGoddess2Dlg, CDialog)
  113. //{{AFX_MSG_MAP(CGoddess2Dlg)
  114. ON_WM_SYSCOMMAND()
  115. ON_WM_PAINT()
  116. ON_WM_QUERYDRAGICON()
  117. ON_BN_CLICKED(IDOK, OnOk)
  118. ON_WM_CLOSE()
  119.     ON_MESSAGE(WM_ADD_CLIENT, OnAddClient) 
  120.     ON_MESSAGE(WM_DEL_CLIENT, OnDelClient) 
  121. ON_BN_CLICKED(IDC_BUTTON_START_DB_SERVICE, OnButtonStartDbService)
  122. //}}AFX_MSG_MAP
  123. END_MESSAGE_MAP()
  125. /////////////////////////////////////////////////////////////////////////////
  126. // CGoddess2Dlg message handlers
  128. BOOL CGoddess2Dlg::OnInitDialog()
  129. {
  130. CDialog::OnInitDialog();
  132. // Add "About..." menu item to system menu.
  134. // IDM_ABOUTBOX must be in the system command range.
  135. ASSERT((IDM_ABOUTBOX & 0xFFF0) == IDM_ABOUTBOX);
  136. ASSERT(IDM_ABOUTBOX < 0xF000);
  138. CMenu* pSysMenu = GetSystemMenu(FALSE);
  139. if (pSysMenu != NULL)
  140. {
  141. CString strAboutMenu;
  142. strAboutMenu.LoadString(IDS_ABOUTBOX);
  143. if (!strAboutMenu.IsEmpty())
  144. {
  145. pSysMenu->AppendMenu(MF_SEPARATOR);
  146. pSysMenu->AppendMenu(MF_STRING, IDM_ABOUTBOX, strAboutMenu);
  147. }
  148. }
  150. // Set the icon for this dialog.  The framework does this automatically
  151. //  when the application's main window is not a dialog
  152. SetIcon(m_hIcon, TRUE); // Set big icon
  153. SetIcon(m_hIcon, FALSE); // Set small icon
  155. // TODO: Add extra initialization here
  157.     LoadSetting();
  159. m_OpenPort = g_uServerPort;
  160.     UpdateData(FALSE);
  162. return TRUE;  // return TRUE  unless you set the focus to a control
  163. }
  165. void CGoddess2Dlg::OnSysCommand(UINT nID, LPARAM lParam)
  166. {
  167. if ((nID & 0xFFF0) == IDM_ABOUTBOX)
  168. {
  169. CAboutDlg dlgAbout;
  170. dlgAbout.DoModal();
  171. }
  172. else
  173. {
  174. CDialog::OnSysCommand(nID, lParam);
  175. }
  176. }
  178. // If you add a minimize button to your dialog, you will need the code below
  179. //  to draw the icon.  For MFC applications using the document/view model,
  180. //  this is automatically done for you by the framework.
  182. void CGoddess2Dlg::OnPaint() 
  183. {
  184. if (IsIconic())
  185. {
  186. CPaintDC dc(this); // device context for painting
  188. SendMessage(WM_ICONERASEBKGND, (WPARAM) dc.GetSafeHdc(), 0);
  190. // Center icon in client rectangle
  191. int cxIcon = GetSystemMetrics(SM_CXICON);
  192. int cyIcon = GetSystemMetrics(SM_CYICON);
  193. CRect rect;
  194. GetClientRect(&rect);
  195. int x = (rect.Width() - cxIcon + 1) / 2;
  196. int y = (rect.Height() - cyIcon + 1) / 2;
  198. // Draw the icon
  199. dc.DrawIcon(x, y, m_hIcon);
  200. }
  201. else
  202. {
  203. CDialog::OnPaint();
  204. }
  205. }
  207. // The system calls this to obtain the cursor to display while the user drags
  208. //  the minimized window.
  209. HCURSOR CGoddess2Dlg::OnQueryDragIcon()
  210. {
  211. return (HCURSOR) m_hIcon;
  212. }
  214. void CGoddess2Dlg::OnOk() 
  215. {
  216.     SendMessage(WM_CLOSE, 0, 0);
  217. }
  219. void CGoddess2Dlg::OnClose() 
  220. {
  221.     UpdateData(TRUE);
  223. // TODO: Add your message handler code here and/or call default
  224.     int nRetCode = ::MessageBox(
  225.         GetSafeHwnd(), 
  226.         "Are you sure quit?", 
  227.         "Info", 
  228.         MB_YESNO | MB_ICONQUESTION
  229.     ); 
  230.     if (IDYES == nRetCode)
  231.     {
  232.         if (g_nKSG_RoleProcess_InitFlag)
  233.         {
  234.             KSG_RoleProcess_UnInit();
  235.             g_nKSG_RoleProcess_InitFlag = false;
  236.         }
  238.         DestroyDatabaseEngine();
  240.         SaveSetting();
  242.      CDialog::OnClose();
  243.     }
  244. }
  246. void CGoddess2Dlg::OnButtonStartDbService() 
  247. {
  248.     int nResult = false;
  250.     int nRetCode = false;
  251. // TODO: Add your control notification handler code here
  252.     UpdateData(TRUE);
  254.     nRetCode = CreateDatabaseEngine(m_hWnd);
  255.     if (!nRetCode)
  256.         goto Exit0;
  258.     nRetCode = KSG_RoleProcess_Init(m_OpenPort, m_hWnd);  // will call in OnStartDBService
  259.     if (!nRetCode)
  260.     {
  261. ::MessageBox(m_hWnd, "Role Process Init Failed!", "Error", MB_OK | MB_ICONERROR);
  263.         goto Exit0;
  264.     }
  265.     g_nKSG_RoleProcess_InitFlag = true;
  267.     nRetCode = KSG_RoleProcess_Start();
  268.     if (!nRetCode)
  269.     {   
  270. ::MessageBox(m_hWnd, "Role Process Start Fail!", "Error", MB_OK | MB_ICONERROR);
  272.         goto Exit0;
  273.     }
  275.     ::EnableWindow(m_StartDBService.m_hWnd, false);
  276.     ::EnableWindow(m_OpenPortCtl.m_hWnd, false);
  279.     SetWindowText("Goddess2 [Enable]");
  281.     nResult = true;
  282. Exit0:
  283.     if (!nResult)
  284.     {
  285.         if (g_nKSG_RoleProcess_InitFlag)
  286.         {
  287.             KSG_RoleProcess_UnInit();
  288.             g_nKSG_RoleProcess_InitFlag = false;
  289.         }
  291.     }
  292.     
  293. }
  296. LRESULT CGoddess2Dlg::OnAddClient(WPARAM wParam, LPARAM lParam)
  297. {
  298.     int addr_from_len = wParam;
  299.     struct sockaddr_in *paddr_from = (struct sockaddr_in *)lParam;
  301.     char szClientInfo[256];
  303.     char *pszRetAddress = NULL;
  304.     char szAddress[256];
  306.     if (!addr_from_len)
  307.         return 0;
  309.     if (!paddr_from)
  310.         return 0;
  312.     pszRetAddress = inet_ntoa(paddr_from->sin_addr);
  313.     if (!pszRetAddress)
  314.         return 0;
  316.     strncpy(szAddress, pszRetAddress, 256);
  317.     szAddress[256 - 1] = '';
  319.     sprintf(szClientInfo, "%s:%u", szAddress, (unsigned)ntohs(paddr_from->sin_port));
  320.     
  321.     m_ClientList.AddString(szClientInfo);
  322.     
  323.     return 0;
  324. }
  326. LRESULT CGoddess2Dlg::OnDelClient(WPARAM wParam, LPARAM lParam)
  327. {
  328.     int addr_from_len = wParam;
  329.     struct sockaddr_in *paddr_from = (struct sockaddr_in *)lParam;
  331.     char szClientInfo[256];
  333.     char *pszRetAddress = NULL;
  334.     char szAddress[256];
  336.     if (!addr_from_len)
  337.         return 0;
  339.     if (!paddr_from)
  340.         return 0;
  342.     pszRetAddress = inet_ntoa(paddr_from->sin_addr);
  343.     if (!pszRetAddress)
  344.         return 0;
  346.     strncpy(szAddress, pszRetAddress, 256);
  347.     szAddress[256 - 1] = '';
  349.     sprintf(szClientInfo, "%s:%u", szAddress, (unsigned)ntohs(paddr_from->sin_port));
  351.     int nRetIdx = m_ClientList.FindStringExact(-1, szClientInfo);
  352.     if (nRetIdx == LB_ERR)
  353.        return 0;
  354.     
  355.     m_ClientList.DeleteString(nRetIdx);
  356.     
  357.     return 0;
  358. }
  360. bool CreateDatabaseEngine( HWND hwnd )
  361. {
  362. if ( !InitDBInterface( g_nMaxRoleCount ) )
  363. {
  364. ::MessageBox( NULL, "Setup dbserver is failed!", "Warning", MB_OK | MB_ICONSTOP );
  366. return false;
  367. }
  369. // StartBackupTimer(g_BackupSleepTime); //开始运行备份线程
  370. // ::SetWindowText(GetDlgItem( hwnd, IDC_LAB_BACKUP_STATUS ),
  371. // "Backup thread status: Running");
  372. // /*
  373. //  * Open this server to client
  374. //  */
  375. // pfnCreateServerInterface pFactroyFun = ( pfnCreateServerInterface )( g_theHeavenLibrary.GetProcAddress( "CreateInterface" ) );
  376. //
  377. // IServerFactory *pServerFactory = NULL;
  378. //
  379. // if ( pFactroyFun && SUCCEEDED( pFactroyFun( IID_IServerFactory, reinterpret_cast< void ** >( &pServerFactory ) ) ) )
  380. // {
  381. // pServerFactory->SetEnvironment( 10, 10, 20, 1024 * 1024 );
  382. //
  383. // pServerFactory->CreateServerInterface( IID_IIOCPServer, reinterpret_cast< void ** >( &g_pServer ) );
  384. //
  385. // pServerFactory->Release();
  386. // }
  387. //
  388. // if ( !g_pServer )
  389. // {
  390. // ::MessageBox( NULL, "Initialization failed! Don't find a correct heaven.dll", "Warning", MB_OK | MB_ICONSTOP );
  391. //
  392. // return false;
  393. // }
  394. //
  395. // g_pServer->Startup();
  396. //
  397. // g_pServer->RegisterMsgFilter( ( void * )hwnd, ServerEventNotify );
  398. //
  399. // if ( FAILED( g_pServer->OpenService( INADDR_ANY, g_nServerPort ) ) )
  400. // {
  401. // return false;
  402. // }
  403. //
  404. // DWORD dwThreadID = 0L;
  405. //
  406. // IServer *pCloneServer = NULL;
  407. // g_pServer->QueryInterface( IID_IIOCPServer, ( void ** )&pCloneServer );
  408. //
  409. // g_hThread = ::CreateThread( NULL, 0, ThreadProcess, ( void * )pCloneServer, 0, &dwThreadID );
  410. //
  411. // if ( !g_hThread )
  412. // {
  413. // return false;
  414. // }
  415. //
  416. // CClientNode::Start( g_pServer );
  417. //
  418. // g_hStartWorkEvent.Set();
  420. return true;
  421. }
  423. void DestroyDatabaseEngine()
  424. {
  425. // CClientNode::End();
  426. //
  427. // g_hQuitEvent.Set();
  428. //
  429. // DWORD result = ::WaitForSingleObject( g_hThread, 50000 );
  430. //
  431. // if ( result == WAIT_TIMEOUT )
  432. // {
  433. // ::TerminateThread( g_hThread, ( DWORD )( -1 ) );
  434. // }
  435. //
  436. // SAFE_CLOSEHANDLE( g_hThread );
  437. //
  438. // if ( g_pServer )
  439. // {
  440. // g_pServer->CloseService();
  441. // g_pServer = NULL;
  442. // }
  443. //
  444. // SAFE_RELEASE( g_pServer );
  446. ReleaseDBInterface();
  447. }
  451. void LoadSetting()
  452. {
  453. CIniFile theConfigFile;
  455. _tstring sAppPath = GetAppFullPath( NULL );
  457. _tstring sConfigFile;
  459. sConfigFile = sAppPath + "Goddess.cfg";
  461. theConfigFile.SetFile( sConfigFile.c_str() );
  463. g_uServerPort = theConfigFile.ReadInteger( "Setting", "Port", 5001 );
  465. g_nMaxRoleCount = theConfigFile.ReadInteger( "Setting", "MaxRoleCount", 3 );
  467. g_BackupSleepTime = theConfigFile.ReadInteger( "Setting", "BackupSleepTime", 3 );
  468. }
  470. void SaveSetting()
  471. {
  472. CIniFile theConfigFile;
  474. _tstring sAppPath = GetAppFullPath( NULL );
  476. _tstring sConfigFile;
  478. sConfigFile = sAppPath + "Goddess.cfg";
  480. theConfigFile.SetFile( sConfigFile.c_str() );
  482. theConfigFile.WriteInteger( "Setting", "Port", g_uServerPort );
  484. theConfigFile.WriteInteger(  "Setting", "MaxRoleCount", g_nMaxRoleCount );
  486. theConfigFile.WriteInteger(  "Setting", "BackupSleepTime", g_BackupSleepTime );
  487. }