Category

Development Platform
Home > SourceCode/Document > Game Program > Game Server Simulator > View Code
SocketClient.h
Package: SwordOnline.rar　[view]
Upload User: dzyhzl
Upload Date: 2019-04-29
Package Size: 56270k
Code Size: 3k
Category:

Game Server Simulator

Development Platform:

C/C++

SocketClient.h：Code Content
  1. /********************************************************************
  2. created: 2003/02/18
  3. file base: SocketClient
  4. file ext: h
  5. author: liupeng
  7. purpose:
  8. *********************************************************************/
  9. #ifndef __INCLUDE_SOCKETCLIENT_H__
  10. #define __INCLUDE_SOCKETCLIENT_H__
  12. #if defined (_MSC_VER) && (_MSC_VER >= 1020)
  13. #pragma once
  14. #endif
  16. #include "UsesWinsock.h"
  17. #include "Thread.h"
  18. #include "CriticalSection.h"
  19. #include "IOBuffer.h"
  20. #include "ManualResetEvent.h"
  21. #include "NodeList.h"
  22. #include "OpaqueUserData.h"
  23. #include "EventSelect.h"
  25. /*
  26.  * namespace OnlineGameLib::Win32
  27.  */
  29. namespace OnlineGameLib {
  30. namespace Win32 {
  32. class CSocketClient : protected CThread, private CUsesWinsock, private CIOBuffer::Allocator
  33. {
  34. public:
  36. virtual ~CSocketClient();
  38. using CThread::Start;
  40. void ConnectTo(
  41. const _tstring &addressToConnectServer,
  42. unsigned short portToConnectServer
  43. );
  45. void StartConnections();
  46. void StopConnections();
  48. void InitiateShutdown();
  49. void WaitForShutdownToComplete();
  51. void Write( const char *pData, size_t dataLength );
  53. protected:
  55. CSocketClient(
  56. const _tstring &addressToConnectServer,
  57. unsigned short portToConnectServer,
  58. size_t maxFreeBuffers,
  59. size_t bufferSize /* = 1024 */
  60. );
  62. CSocketClient(
  63. size_t maxFreeBuffers,
  64. size_t bufferSize /* = 1024 */
  65. );
  67. virtual void PreWrite( 
  68. CIOBuffer *pBuffer, 
  69. const char *pData, 
  70. size_t dataLength ) {};
  72. void ReleaseBuffers();
  74. /*
  75.  * Virtual function has different access specifier to base class
  76.  */
  77. virtual int Run();
  79. private:
  81. /*
  82.  * Override this to create the listening socket of your choice
  83.  */
  84. virtual SOCKET CreateConnectionSocket( 
  85. const _tstring &addressToConnectServer,
  86. unsigned short port) = 0;
  88. /*
  89.  * Interface for derived classes to receive state change notifications...
  90.  */
  91. virtual void OnStartConnections() {};
  92. virtual void OnStopConnections() {};
  93. virtual void OnShutdownInitiated() {};
  94. virtual void OnShutdownComplete() {};
  96. virtual void OnConnect() {};
  97. virtual void OnClose() {};
  99. void OnRead( CIOBuffer *pBuffer );
  100. virtual void ReadCompleted( CIOBuffer *pBuffer ) = 0;
  102. void OnWrite();
  104. virtual void OnError( const _tstring &message );
  106. SOCKET m_connectSocket;
  108. CEventSelect m_eventSelect;
  110. CManualResetEvent m_shutdownEvent;
  111. CManualResetEvent m_successConnectionsEvent;
  113. _tstring m_address;
  114. unsigned short m_port;
  116. };
  118. } // End of namespace OnlineGameLib
  119. } // End of namespace Win32
  121. #endif //__INCLUDE_SOCKETCLIENT_H__