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

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

模拟服务器

开发平台：

C/C++

ClientClone.cpp：源码内容
  1. // ClientClone.cpp : Defines the entry point for the console application.
  2. //
  3. #include "stdafx.h"
  4. #include <objbase.h>
  5. #include <initguid.h>
  7. #include "....Sword3PaySysS3AccServerAccountLoginDef.h"
  8. #include "....s3clientloginLoginDef.h"
  10. #include "....RoleDBManagerkroledbheader.h"
  11. #include "S3DBInterface.h"
  12. #include "KProtocolDef.h"
  13. #include "KProtocol.h"
  15. #include "IClient.h"
  16. #include "RainbowInterface.h"
  18. #include "Macro.h"
  19. #include "Inifile.h"
  20. #include "Utils.h"
  21. #include "tstring.h"
  22. #include "Library.h"
  23. #include "Console.h"
  25. using OnlineGameLib::Win32::CIniFile;
  26. using OnlineGameLib::Win32::GetAppFullPath;
  27. using OnlineGameLib::Win32::_tstring;
  28. using OnlineGameLib::Win32::CLibrary;
  29. using OnlineGameLib::Win32::ToString;
  30. using OnlineGameLib::Win32::Console::setcolor;
  31. using OnlineGameLib::Win32::Console::gotoxy;
  32. using OnlineGameLib::Win32::Console::getxy;
  34. const size_t g_nTitleSpace = 3;
  35. const size_t g_nBufferSize = 256;
  36. _tstring g_sServerIPAddress;
  37. unsigned short g_nServerPort = 5622;
  39. _tstring g_sAccount, g_sPassword, g_sRoleName;
  41. CLibrary g_theRainbowLibrary( "rainbow.dll" );
  43. IClient *pClient = NULL;
  44. IClient *pGameSvrClient = NULL;
  46. #define CONFIG_FILENAME _T( "config.ini" )
  47. #define SVR_SETTING_FILENAME _T( "settings\ServerList.ini" )
  49. #include <iostream>
  50. #include <strstream>
  52. using namespace std;
  54. /*
  55.  * Using directives
  56.  */
  57. using std::auto_ptr;
  58. using std::endl;
  60. typedef HRESULT ( __stdcall * pfnCreateClientInterface )(
  61. REFIID riid,
  62. void **ppv
  63. );
  65. void __stdcall ClientEventNotify(
  66. LPVOID lpParam,
  67. const unsigned long &ulnEventType )
  68. {
  69. switch( ulnEventType )
  70. {
  71. case enumServerConnectCreate:
  73. cout << "Connection was created!" << endl;
  74. break;
  76. case enumServerConnectClose:
  78. cout << "Connection was destroy!" << endl;
  79. break;
  80. }
  81. }
  83. /*
  84.  * Global variable
  85.  */
  86. _tstring g_sAppFullPath;
  88. /*
  89.  * Helper function
  90.  */
  91. void ShowTitle( const char *pTile );
  93. void SelectServerList();
  94. void InputAccountAndPassword();
  95. UINT Login();
  96. int SelectRoleList();
  97. void WaitForEnterGameServer();
  98. void ConnectToGameSvr( const char *pIPAddr, unsigned short nPort, GUID &guid );
  100. void PlayGame();
  101. void InitGameWorld();
  102. void ConnectServer();
  103. void DisconnectServer();
  105. int g_nProtocolSize[MAX_PROTOCOL_NUM] = 
  106. {
  107. -1, // s2c_login,
  108. -1, // s2c_logout,
  109. sizeof(BYTE), // s2c_syncend,
  110. sizeof(CURPLAYER_SYNC), // s2c_synccurplayer,
  111. -1, // s2c_synccurplayerskill
  112. sizeof(CURPLAYER_NORMAL_SYNC),// s2c_synccurplayernormal
  113. -1, // s2c_newplayer,
  114. -1, // s2c_removeplayer,
  115. sizeof(WORLD_SYNC), // s2c_syncworld,
  116. sizeof(PLAYER_SYNC), // s2c_syncplayer,
  117. sizeof(PLAYER_NORMAL_SYNC), // s2c_syncplayermin,
  118. -1, //sizeof(NPC_SYNC), // s2c_syncnpc,
  119. sizeof(NPC_NORMAL_SYNC), // s2c_syncnpcmin,
  120. sizeof(NPC_PLAYER_TYPE_NORMAL_SYNC), // s2c_syncnpcminplayer,
  122. sizeof(OBJ_SYNC_ADD), // s2c_objadd,
  123. sizeof(OBJ_SYNC_STATE), // s2c_syncobjstate,
  124. sizeof(OBJ_SYNC_DIR), // s2c_syncobjdir,
  125. sizeof(OBJ_SYNC_REMOVE), // s2c_objremove,
  126. sizeof(OBJ_SYNC_TRAP_ACT), // s2c_objTrapAct,
  128. sizeof(NPC_REMOVE_SYNC), // s2c_npcremove,
  129. sizeof(NPC_WALK_SYNC), // s2c_npcwalk,
  130. sizeof(NPC_RUN_SYNC), // s2c_npcrun,
  131. -1, // s2c_npcattack,
  132. -1, // s2c_npcmagic,
  133. sizeof(NPC_JUMP_SYNC), // s2c_npcjump,
  134. -1, // s2c_npctalk,
  135. sizeof(NPC_HURT_SYNC), // s2c_npchurt,
  136. sizeof(NPC_DEATH_SYNC), // s2c_npcdeath,
  137. sizeof(NPC_CHGCURCAMP_SYNC),// s2c_npcchgcurcamp,
  138. sizeof(NPC_CHGCAMP_SYNC), // s2c_npcchgcamp,
  139. sizeof(NPC_SKILL_SYNC), // s2c_skillcast,
  140. -1, // s2c_playertalk,
  141. sizeof(PLAYER_EXP_SYNC), // s2c_playerexp,
  143. sizeof(PLAYER_SEND_TEAM_INFO), // s2c_teaminfo,
  144. sizeof(PLAYER_SEND_SELF_TEAM_INFO), // s2c_teamselfinfo,
  145. sizeof(PLAYER_APPLY_TEAM_INFO_FALSE), // s2c_teamapplyinfofalse,
  146. sizeof(PLAYER_SEND_CREATE_TEAM_SUCCESS),// s2c_teamcreatesuccess,
  147. sizeof(PLAYER_SEND_CREATE_TEAM_FALSE), // s2c_teamcreatefalse,
  148. sizeof(PLAYER_TEAM_OPEN_CLOSE), // s2c_teamopenclose,
  149. sizeof(PLAYER_APPLY_ADD_TEAM), // s2c_teamgetapply,
  150. sizeof(PLAYER_TEAM_ADD_MEMBER), // s2c_teamaddmember,
  151. sizeof(PLAYER_LEAVE_TEAM), // s2c_teamleave,
  152. sizeof(PLAYER_TEAM_CHANGE_CAPTAIN), // s2c_teamchangecaptain,
  153. sizeof(PLAYER_FACTION_DATA), // s2c_playerfactiondata,
  154. sizeof(PLAYER_LEAVE_FACTION), // s2c_playerleavefaction,
  155. sizeof(PLAYER_FACTION_SKILL_LEVEL), // s2c_playerfactionskilllevel,
  156. -1,//sizeof(PLAYER_SEND_CHAT_SYNC), // s2c_playersendchat,
  157. sizeof(PLAYER_LEAD_EXP_SYNC), // s2c_playersyncleadexp
  158. sizeof(PLAYER_LEVEL_UP_SYNC), // s2c_playerlevelup
  159. sizeof(PLAYER_TEAMMATE_LEVEL_SYNC), // s2c_teammatelevel
  160. sizeof(PLAYER_ATTRIBUTE_SYNC), // s2c_playersyncattribute
  161. sizeof(PLAYER_SKILL_LEVEL_SYNC), // s2c_playerskilllevel
  162. sizeof(ITEM_SYNC), // s2c_syncitem
  163. sizeof(ITEM_REMOVE_SYNC), // s2c_removeitem
  164. sizeof(PLAYER_MONEY_SYNC), // s2c_syncmoney
  165. sizeof(PLAYER_MOVE_ITEM_SYNC), // s2c_playermoveitem
  166. -1, // s2c_playershowui
  167. sizeof(CHAT_APPLY_ADD_FRIEND_SYNC), // s2c_chatapplyaddfriend
  168. sizeof(CHAT_ADD_FRIEND_SYNC), // s2c_chataddfriend
  169. -1,//sizeof(CHAT_REFUSE_FRIEND_SYNC), // s2c_chatrefusefriend
  170. sizeof(CHAT_ADD_FRIEND_FAIL_SYNC), // s2c_chataddfriendfail
  171. sizeof(CHAT_LOGIN_FRIEND_NONAME_SYNC), // s2c_chatloginfriendnoname
  172. -1,//sizeof(CHAT_LOGIN_FRIEND_NAME_SYNC), // s2c_chatloginfriendname
  173. sizeof(CHAT_ONE_FRIEND_DATA_SYNC), // s2c_chatonefrienddata
  174. sizeof(CHAT_FRIEND_ONLINE_SYNC), // s2c_chatfriendinline
  175. sizeof(CHAT_DELETE_FRIEND_SYNC), // s2c_chatdeletefriend
  176. sizeof(CHAT_FRIEND_OFFLINE_SYNC), // s2c_chatfriendoffline
  177. sizeof(ROLE_LIST_SYNC), // s2c_syncrolelist
  178. sizeof(TRADE_CHANGE_STATE_SYNC), // s2c_tradechangestate
  179. -1, // NPC_SET_MENU_STATE_SYNC    s2c_npcsetmenustate
  180. sizeof(TRADE_MONEY_SYNC), // s2c_trademoneysync
  181. sizeof(TRADE_DECISION_SYNC), // s2c_tradedecision
  182. -1, // sizeof(CHAT_SCREENSINGLE_ERROR_SYNC)s2c_chatscreensingleerror
  183. sizeof(NPC_SYNC_STATEINFO), // s2c_syncnpcstate,
  184. -1, // sizeof(TEAM_INVITE_ADD_SYNC)    s2c_teaminviteadd
  185. sizeof(TRADE_STATE_SYNC), // s2c_tradepressoksync
  186. sizeof(PING_COMMAND), // s2c_ping
  187. sizeof(NPC_SIT_SYNC), // s2c_npcsit
  188. sizeof(SALE_BOX_SYNC), // s2c_opensalebox
  189. sizeof(NPC_SKILL_SYNC), // s2cDirectlyCastSkill
  190. -1, // s2c_msgshow
  191. -1, // s2c_syncstateeffect
  192. sizeof(BYTE), // s2c_openstorebox
  193. sizeof(NPC_REVIVE_SYNC), // s2c_playerrevive
  194. sizeof(NPC_REQUEST_FAIL), // s2c_requestnpcfail
  195. sizeof(TRADE_APPLY_START_SYNC), // s2c_tradeapplystart
  196. sizeof(tagNewDelRoleResponse), // s3c_rolenewdelresponse
  197. };
  199. int main(int argc, char* argv[])
  200. {
  201. ShowTitle( "Welcome to JX.MMOG client" );
  203. g_sAppFullPath = GetAppFullPath( NULL );
  205. cout << "The current directory : " 
  206. << endl 
  207. << _strlwr( const_cast< char * >( g_sAppFullPath.c_str() ) )
  208. << endl;
  210. SelectServerList();
  212. ConnectServer();
  214. _LOGIN_ROUTE:
  216. InputAccountAndPassword();
  218. switch ( Login() )
  219. {
  220. case LOGIN_R_ACCOUNT_OR_PASSWORD_ERROR:
  221. case LOGIN_R_TIMEOUT:
  222. case LOGIN_R_ACCOUNT_EXIST:
  223. case LOGIN_R_FAILED:
  225. goto _LOGIN_ROUTE;
  227. break;
  229. case LOGIN_R_SUCCESS:
  230. break;
  231. }
  233. int nRoleIndex = SelectRoleList();
  235. WaitForEnterGameServer();
  237. InitGameWorld();
  239. PlayGame();
  241. DisconnectServer();
  243. return 0;
  244. }
  246. void PlayGame()
  247. {
  248. ShowTitle( "Enter the game" );
  250. cout << "Input 'Exit' or 'exit' to quit." << endl;
  252. _tstring sCmd;
  254. while ( sCmd.compare( "exit" ) && sCmd.compare( "Exit" ) )
  255. {
  256. cin >> sCmd;
  257. }
  258. }
  260. void InitGameWorld()
  261. {
  262. bool ok = false;
  264. while ( !ok )
  265. {
  266. size_t datalength = 0;
  267. const char *pData = ( const char * )pGameSvrClient->GetPackFromServer( datalength );
  269. const char *pMsg = pData;
  271. while ( pMsg < ( pData + datalength ) )
  272. {
  273. BYTE cProtocol = *( BYTE * )pMsg;
  275. ASSERT( cProtocol > s2c_clientbegin && cProtocol < s2c_end );
  277. int nProtocolSize = g_nProtocolSize[ cProtocol - s2c_clientbegin - 1 ];
  279. cout << nProtocolSize << "; ";
  281. switch ( cProtocol )
  282. {
  283. case s2c_syncend:
  284. {
  285. BYTE cData = c2s_syncend;
  286. pGameSvrClient->SendPackToServer( ( const void * )&cData, sizeof( BYTE ) );
  288. cout << endl << "Init game finish!" << endl;
  290. ok = true;
  291. }
  292. break;
  293. }
  295. if ( ok )
  296. {
  297. break;
  298. }
  300. /*
  301.  * Get next protocol
  302.  */
  303. if ( nProtocolSize >= 0 )
  304. {
  305. pMsg += nProtocolSize;
  306. }
  307. else
  308. {
  309. unsigned short usMsgSize = *( unsigned short * )( pMsg + sizeof( BYTE ) );
  311. pMsg += sizeof( BYTE ) + usMsgSize;
  312. }
  313. }
  315. ::Sleep( 1 );
  316. }
  317. }
  319. void ShowTitle( const char *pTile )
  320. {
  321. ASSERT( pTile );
  323. setcolor( enumBlackonGray );
  325. int count = strlen( pTile );
  326. int size = 1;
  328. _tstring sLine;
  330. sLine = '+';
  332. sLine.resize( g_nTitleSpace * 2 + count + size, '-' );
  333. sLine += '+';
  335. _tstring sTitle;
  336. sTitle = '|';
  337. sTitle.resize( g_nTitleSpace + size, ' ' );
  338. sTitle += pTile;
  339. size = sTitle.size();
  340. sTitle.resize( g_nTitleSpace + size, ' ' );
  341. sTitle += '|';
  343. /*
  344.  * Show some information for user
  345.  */
  346. cout << sLine << endl;
  347. cout << sTitle << endl;
  348. cout << sLine << endl;
  350. setcolor( enumDefault );
  351. }
  353. void SelectServerList()
  354. {
  356. _BEGIN_SELECT_SERVER_LIST:
  358. ShowTitle( "Select server" );
  360. /*
  361.  * Get setup infomation from ini-file
  362.  */
  363. _tstring sConfigFile, buffer, key, result;
  365. sConfigFile = g_sAppFullPath + SVR_SETTING_FILENAME;
  367. CIniFile iniFile( sConfigFile.c_str() );
  369. key.resize( g_nBufferSize );
  370. buffer.resize( g_nBufferSize );
  372. size_t nSvrCount = iniFile.ReadInteger( "List", "Count", 0 );
  374. setcolor( enumYellowonBlack );
  376. int i = 0;
  377. for ( ; i<nSvrCount; i++ )
  378. {
  379. sprintf( const_cast< char * >( key.c_str() ), "%d", i );
  381. iniFile.ReadString( key.c_str(), "Title", const_cast< char * >( buffer.c_str() ), g_nBufferSize, "" );
  383. result = buffer.c_str();
  384. result += _T(" [");
  386. iniFile.ReadString( key.c_str(), "Address", const_cast< char * >( buffer.c_str() ), g_nBufferSize, "" );
  388. result += buffer.c_str();
  389. result += "]";
  391. cout << i << ") " << result << endl;
  392. }
  394. cout << i << ") " << "Exit game" << endl;
  396. setcolor( enumDefault );
  398. cout << "What are you select? Press number to be continue!" << endl;
  400. int nSelRoleIndex = 0;
  402. while ( true )
  403. {
  404. cin >> buffer;
  406. nSelRoleIndex = atoi( buffer.c_str() );
  408. /*
  409.  * The last one is option that you can exit application
  410.  */
  411. if ( nSelRoleIndex >= 0 && nSelRoleIndex < nSvrCount + 1 )
  412. {
  413. break;
  414. }
  416. cout << "Input incorrect, please input again." << endl;
  417. }
  419. /*
  420.  * Exit game if you select the last option
  421.  */
  422. if ( nSelRoleIndex == nSvrCount )
  423. {
  424. cout << "Are you exit game? < Y : yes>";
  426. _tstring sInformation;
  428. cin >> sInformation;
  430. if ( 0 == sInformation.compare( "Y" ) || 0 == sInformation.compare( "y" ) )
  431. {
  432. exit( 0 );
  433. }
  435. /*
  436.  * Repeat this route
  437.  */
  438. goto _BEGIN_SELECT_SERVER_LIST;
  439. }
  441. /*
  442.  * Read information by you select
  443.  */
  444. sprintf( const_cast< char * >( key.c_str() ), "%d", nSelRoleIndex );
  446. iniFile.ReadString( key.c_str(), "Title", const_cast< char * >( buffer.c_str() ), g_nBufferSize, "" );
  448. result = buffer.c_str();
  449. result += _T(" [");
  451. iniFile.ReadString( key.c_str(), "Address", const_cast< char * >( buffer.c_str() ), g_nBufferSize, "" );
  453. g_sServerIPAddress = buffer.c_str();
  455. result += buffer.c_str();
  457. /* sConfigFile = g_sAppFullPath + CONFIG_FILENAME;
  459. iniFile.SetFile( sConfigFile.c_str() );
  461. g_nServerPort = iniFile.ReadInteger( "Server", "GameServPort", g_nServerPort );
  462. */
  463. result += _T( ":" ) + ToString(g_nServerPort) + _T( "]" );
  465. cout << "Your select " << result << endl;
  466. //cout << "Please wait for a moment..." << endl;
  468. }
  470. UINT Login()
  471. {
  472. _tstring buffer;
  474. UINT nRetValue = ( UINT )( -1 );
  476. /*
  477.  * Send login command to gateway
  478.  */
  479. KLoginAccountInfo lai;
  481. ZeroMemory( &lai, sizeof( KLoginAccountInfo ) );
  483. /*
  484.  * Account
  485.  */
  486. size_t used = sizeof( lai.Account );
  487. used = ( used > g_sAccount.length() ) ? g_sAccount.length() : used;
  489. memcpy( lai.Account, g_sAccount.c_str(), used );
  491. /*
  492.  * Password
  493.  */
  494. used = sizeof( lai.Password );
  495. used = ( used > g_sPassword.length() ) ? g_sPassword.length() : used;
  497. memcpy( lai.Password, g_sPassword.c_str(), used );
  499. /*
  500.  * The other info
  501.  */
  502. lai.Param = LOGIN_A_LOGIN | LOGIN_R_REQUEST;
  504. lai.Size = sizeof( lai );
  506. buffer.resize( lai.Size + 1/* protocol id */ );
  508. BYTE bProtocol = c2s_login;
  509. memcpy( const_cast< char * >( buffer.c_str() ), &bProtocol, sizeof( BYTE ) );
  510. memcpy( const_cast< char * >( buffer.c_str() + 1 ), &lai, sizeof( lai ) );
  512. pClient->SendPackToServer( buffer.c_str(), buffer.size() );
  514. /*
  515.  * Get verify info get from gateway
  516.  */
  517. bool ok = false;
  519. int xPos = 0;
  520. int yPos = 0;
  522. getxy( xPos, yPos );
  524. DWORD dwOlderTimer = GetTickCount();
  526. while ( true )
  527. {
  528. static int s_nPos = 0;
  530. DWORD dwNewTimer = GetTickCount();
  531. if ( dwNewTimer - dwOlderTimer > 300 )
  532. {
  533. dwOlderTimer = dwNewTimer;
  535. if ( s_nPos++ > 5 )
  536. {
  537. s_nPos = 0;
  538. }
  539. }
  541. _tstring info;
  542. strstream str;
  544. gotoxy( xPos, yPos );
  546. info.resize( s_nPos, '.' );
  547. cout << "Wait for purify your account" << info.c_str() << "      " << endl;
  548.  
  549. size_t datalength = 0;
  551. const void *pData = pClient->GetPackFromServer( datalength );
  553. while ( pData && datalength )
  554. {
  555. BYTE cProtocol = *( const BYTE * )pData;
  557. switch ( cProtocol )
  558. {
  559. case s2c_login:
  560. {
  561. KLoginAccountInfo *pLAI = ( KLoginAccountInfo * )( ( const BYTE * )pData + 1 );
  563. if ( ( pLAI->Param | LOGIN_A_LOGIN ) &&
  564.  0 == g_sAccount.compare( pLAI->Account ) &&
  565.  0 == g_sPassword.compare( pLAI->Password ) )
  566. {
  567. if ( ( pLAI->Param & 0xFFFF ) == LOGIN_R_ACCOUNT_OR_PASSWORD_ERROR )
  568. {
  569. nRetValue = LOGIN_R_ACCOUNT_OR_PASSWORD_ERROR;
  571. cout << "An incorrect account or password!" << endl;
  572. }
  573. else if ( ( pLAI->Param & 0xFFFF ) == LOGIN_R_FAILED )
  574. {
  575. nRetValue = LOGIN_R_FAILED;
  577. cout << "Login failed!" << endl;
  578. }
  579. else if ( ( pLAI->Param & 0xFFFF ) == LOGIN_R_SUCCESS )
  580. {
  581. nRetValue = LOGIN_R_SUCCESS;
  583. cout << "Login successful!" << endl;
  584. }
  585. else if ( ( pLAI->Param & 0xFFFF ) == LOGIN_R_ACCOUNT_EXIST )
  586. {
  587. nRetValue = LOGIN_R_ACCOUNT_EXIST;
  589. cout << "Login failed! your accout was existed!" << endl;
  590. }
  591. else if ( ( pLAI->Param & 0xFFFF ) == LOGIN_R_TIMEOUT )
  592. {
  593. nRetValue = LOGIN_R_TIMEOUT;
  595. cout << "Login failed! no money!" << endl;
  596. }
  598. ok = true;
  599. }
  600. }
  601. break;
  603. default:
  604. break;
  605. }
  607. pData = pClient->GetPackFromServer( datalength );
  608. }
  610. if ( ok )
  611. {
  612. break;
  613. }
  615. Sleep( 1 );
  616. }
  618. return nRetValue;
  619. }
  621. void InputAccountAndPassword()
  622. {
  623. ShowTitle( "Login" );
  625. /*
  626.  * Wait for a correct account and password
  627.  */
  628. _tstring sInformation;
  630. while ( true )
  631. {
  632. cout << "Please input your account : ";
  633. cin >> g_sAccount;
  635. cout << "please input your password for this account : ";
  636. cin >> g_sPassword;
  638. cout << endl;
  639. cout << "Account : [" << g_sAccount << "] Password : [" << g_sPassword << "]" << endl;
  641. cout << "Is it right? < Y : yes>";
  642. cin >> sInformation;
  644. if ( 0 == sInformation.compare( "Y" ) || 0 == sInformation.compare( "y" ) )
  645. {
  646. break;
  647. }
  648. }
  649. }
  651. int SelectRoleList()
  652. {
  653. int nRoleCount = 0;
  654. const S3DBI_RoleBaseInfo *pRoleList = NULL;
  656. size_t datalength = 0;
  658. const void *pData = pClient->GetPackFromServer( datalength );
  660. while ( true )
  661. {
  662. if ( pData && datalength )
  663. {
  664. BYTE cProtocol = *( BYTE * )pData;
  666. if ( s2c_roleserver_getrolelist_result == cProtocol )
  667. {
  668. TProcessData *pPA = ( TProcessData * )pData;
  670. nRoleCount = *( char * )( pPA->pDataBuffer );
  672. pRoleList = ( const S3DBI_RoleBaseInfo * )( ( const char * )( pPA->pDataBuffer ) + 1/* sizeof( char ) */ );
  673. const size_t datalength = sizeof( S3DBI_RoleBaseInfo ) * nRoleCount;
  675. break;
  676. }
  677. }
  679. pData = pClient->GetPackFromServer( datalength );
  681. ::Sleep( 1 );
  682. }
  684. ShowTitle( "Select role" );
  686. setcolor( enumYellowonBlack );
  688. int nIndex = 0;
  690. while ( nIndex < nRoleCount && pRoleList )
  691. {
  692. cout << nIndex << " ) " << pRoleList[nIndex].szRoleName << endl;
  694. nIndex ++;
  695. }
  697. setcolor( enumDefault );
  699. _tstring sRoleIndex;
  701. cout << "What are you select? Press number to be continue!" << endl;
  703. int nSelRoleIndex = -1;
  705. while ( true )
  706. {
  707. cin >> sRoleIndex;
  709. nSelRoleIndex = atoi( sRoleIndex.c_str() );
  711. /*
  712.  * The last one is option that you can exit application
  713.  */
  714. if ( nSelRoleIndex >= 0 && nSelRoleIndex < nRoleCount )
  715. {
  716. break;
  717. }
  719. cout << "Input incorrect, please input again." << endl;
  720. }
  722. /*
  723.  * Send this info to gateway
  724.  */
  725. tagDBSelPlayer tDBSP;
  727. tDBSP.cProtocol = c2s_dbplayerselect;
  729. /*
  730.  * nSelRoleIndex >= 0 && 
  731.  * nSelRoleIndex < nRoleCount && 
  732.  * sizeof( dpc.szRoleName ) >= strlen( pRoleList[nSelRoleIndex].szRoleName )
  733.  */
  734. size_t nRoleNameLen = strlen( pRoleList[nSelRoleIndex].szRoleName );
  735. memcpy( tDBSP.szRoleName, pRoleList[nSelRoleIndex].szRoleName, nRoleNameLen );
  736. tDBSP.szRoleName[nRoleNameLen] = '';
  738. pClient->SendPackToServer( &tDBSP, sizeof( tagDBSelPlayer ) );
  740. return nSelRoleIndex;
  741. }
  743. void WaitForEnterGameServer()
  744. {
  745. cout << endl << "Wait for a respond for log on to gameserver..." << endl;
  747. size_t datalength = 0;
  748. const void *pData = pClient->GetPackFromServer( datalength );
  750. while ( true )
  751. {
  752. if ( pData && datalength )
  753. {
  754. BYTE cProtocol = *( BYTE * )pData;
  756. if ( s2c_notifyplayerlogin == cProtocol )
  757. {
  758. tagNotifyPlayerLogin *pNPL = ( tagNotifyPlayerLogin * )pData;
  760. cout << "Find a valid game server and connect to it!" << endl;
  762. const char *pIPAddr = OnlineGameLib::Win32::net_ntoa( pNPL->nIPAddr );
  764. cout << "IP : " << pIPAddr << " PORT : " << pNPL->nPort << endl;
  766. g_sRoleName = ( const char * )pNPL->szRoleName;
  768. ConnectToGameSvr( pIPAddr, pNPL->nPort, pNPL->guid );
  770. break;
  771. }
  772. }
  774. pData = pClient->GetPackFromServer( datalength );
  776. ::Sleep( 1 );
  777. }
  778. }
  780. void ConnectToGameSvr( const char *pIPAddr, unsigned short nPort, GUID &guid )
  781. {
  782. /*
  783.  * Query network interface
  784.  */
  785. pfnCreateClientInterface pFactroyFun = ( pfnCreateClientInterface )( g_theRainbowLibrary.GetProcAddress( "CreateInterface" ) );
  787. IClientFactory *pClientFactory = NULL;
  789. if ( pFactroyFun && SUCCEEDED( pFactroyFun( IID_IClientFactory, reinterpret_cast< void ** >( &pClientFactory ) ) ) )
  790. {
  791. pClientFactory->SetEnvironment( 50, 1024 * 16 );
  793. pClientFactory->CreateClientInterface( IID_IESClient, reinterpret_cast< void ** >( &pGameSvrClient ) );
  795. pClientFactory->Release();
  796. }
  798. if ( !pGameSvrClient )
  799. {
  800. cout << "Initialization failed! Don't find a correct rainbow.dll" << endl;
  802. exit( -1 );
  803. }
  805. /*
  806.  * Create a connection
  807.  */
  808. pGameSvrClient->Startup();
  810. //pGameSvrClient->RegisterMsgFilter( reinterpret_cast< void * >( pClient ), NULL );
  812. if ( FAILED( pGameSvrClient->ConnectTo( pIPAddr, nPort ) ) )
  813. {
  814. cout << "Connection failed! Don't connect to game server." << endl;
  816. exit( -1 );
  817. }
  819. cout << "It's successful in connection! Prepare to enter this game..." << endl;
  821. tagLogicLogin ll;
  823. ll.cProtocol = c2s_logiclogin;
  824. memcpy( &ll.guid, &guid, sizeof( GUID ) );
  826. pGameSvrClient->SendPackToServer( &ll, sizeof( tagLogicLogin ) );
  827. }
  829. void ConnectServer()
  830. {
  831. /*
  832.  * Query network interface
  833.  */
  834. pfnCreateClientInterface pFactroyFun = ( pfnCreateClientInterface )( g_theRainbowLibrary.GetProcAddress( "CreateInterface" ) );
  836. IClientFactory *pClientFactory = NULL;
  838. if ( pFactroyFun && SUCCEEDED( pFactroyFun( IID_IClientFactory, reinterpret_cast< void ** >( &pClientFactory ) ) ) )
  839. {
  840. pClientFactory->SetEnvironment( 50, 1024 * 16 );
  842. pClientFactory->CreateClientInterface( IID_IESClient, reinterpret_cast< void ** >( &pClient ) );
  844. pClientFactory->Release();
  845. }
  847. if ( !pClient )
  848. {
  849. cout << "Initialization failed! Don't find a correct rainbow.dll" << endl;
  851. exit( -1 );
  852. }
  854. /*
  855.  * Create a connection
  856.  */
  857. pClient->Startup();
  859. pClient->RegisterMsgFilter( reinterpret_cast< void * >( pClient ), ClientEventNotify );
  861. if ( FAILED( pClient->ConnectTo( g_sServerIPAddress.c_str(), g_nServerPort ) ) )
  862. {
  863. cout << "Connection failed! Don't connect to server." << endl;
  865. exit( -1 );
  866. }
  868. cout << "It's successful in connection! Prepare to enter this game..." << endl;
  869. }
  871. void DisconnectServer()
  872. {
  873. /*
  874.  * Destroy the connection
  875.  */
  876. pGameSvrClient->Shutdown();
  878. pGameSvrClient->Cleanup();
  880. pGameSvrClient->Release();
  882. pClient->Shutdown();
  884. pClient->Cleanup();
  886. pClient->Release();
  887. }