홈 탐색 도움말
가입하기 로그인
LYFZ
/
lyfz_repos
2
0
포크 0
파일 이슈 0 풀 리퀘스트 0 위키
트리: 8b4791aa7f
브랜치 태그
lyfz_repos
/
经典版源码
/
kernelcode
/
lyfzWeiXin
/
NetWork
/
ClientProcess.h

ClientProcess.h 2.9 KB
히스토리 Raw

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101 
  1. /*************************************************************
    2. 

  2. /* Copyright (C), 2014-2020, lyfz. Co., Ltd.
    3. 

  3. /* 文件名:		CClientProcess.h  
    4. 

  4. /* 作者:		Jeff.w			 
    5. 

  5. /* 创建日期:	2014-08-07
    6. 

  6. /* 版本号:		V1.0
    7. 

  7. /* 描述:		核心层底,客户端与服务端通信接口
    8. 

  8. /* 其它:  
    9. 

  9. /* 主要类模块: 
    10. 

  10. /* 历史修改记录: 
    11. 

  11. /*		作者           时间              版本           描述
    12. 

  12. /*	    Jeff.w         14/08/07          1.0	      创建这个模块
    13. 

  13. ***************************************************************/
    14. 

  14. #ifndef __ICLIENT_IMPL_HEADER__
    15. 

  15. #define __ICLIENT_IMPL_HEADER__
    16. 

  16. #pragma once
    17. 

  17. 

  18. #include <afxwin.h>
    19. 

  19. #include <atlbase.h>
    20. 

  20. 

  21. #include "Client2SrvType.h"
    22. 

  22. #include "CritSection.h"
    23. 

  23. #include "SocketHandle.h"
    24. 

  24. #include "SocketClientImpl.h"
    25. 

  25. 

  26. 

  27. class CClientProcess :	public ISocketClientHandler
    28. 

  28. {
    29. 

  29. 	typedef SocketClientImpl<ISocketClientHandler> CSocketClient;
    30. 

  30. 	friend CSocketClient;
    31. 

  31. public:
    32. 

  32. 	CClientProcess();
    33. 

  33. 	virtual ~CClientProcess();
    34. 

  34. 	
    35. 

  35. 	void StartReConnectSrvThread();
    36. 

  36. 	static DWORD WINAPI ReConnectSrvThread(LPVOID pInstance);
    37. 

  37. 

  38. protected:
    39. 

  39. 	virtual void OnThreadBegin(CSocketHandle* pSH);
    40. 

  40. 	virtual void OnThreadExit(CSocketHandle* pSH);
    41. 

  41. 	virtual void OnDataReceived(CSocketHandle* pSH, const BYTE* pbData, DWORD dwCount, const SockAddrIn& addr);
    42. 

  42. 	virtual void OnConnectionDropped(CSocketHandle* pSH);
    43. 

  43. 	virtual void OnConnectionError(CSocketHandle* pSH, DWORD dwError);
    44. 

  44. 

  45. protected:
    46. 

  46. 	int m_nMode;		// IPV4 或 IPV6
    47. 

  47. 	int m_nSockType;	// UDP 或 TCP
    48. 

  48. 

  49. 	// 连接的服务器地址;
    50. 

  50. 	TCHAR m_SvrAddr[MAX_PATH];
    51. 

  51. 	// 连接的服务器端口;
    52. 

  52. 	TCHAR m_SvrPort[MAX_PATH];
    53. 

  53. 

  54. 	// 线程句柄;
    55. 

  55. 	HANDLE m_hReConnectSrvThreadHandle;
    56. 

  56. 

  57. 	// 线程退出句柄;
    58. 

  58. 	HANDLE m_hRunObject;
    59. 

  59. 

  60. 	void _cdecl AppendText(LPCTSTR lpszFormat, ...);
    61. 

  61. 	void GetAddress(const SockAddrIn& addrIn, CString& rString) const;
    62. 

  62. 	bool GetDestination(SockAddrIn& addrIn) const;
    63. 

  63. 	bool SetupMCAST();
    64. 

  64. public:
    65. 

  65. 	BOOL m_bRecevie;	// 是否已接收服务器的返回;	
    66. 

  66. 	BOOL m_bStopbeat;	// 是否心跳包;
    67. 

  67. 	BOOL m_bSocket;		// 套接字是否打开;
    68. 

  68. 	CSocketClient m_SocketClient;
    69. 

  69. 	BOOL Initialize();
    70. 

  70. 	BOOL ConnectServer(LPCTSTR strAddr, LPCTSTR strPort);
    71. 

  71. 	void net_CloseSocket();
    72. 

  72. 	void SendMsg(void *pMsg,const int nLen);
    73. 

  73. 	INT Send(IN TheProbody& tpbody, IN const int& nTimeout);
    74. 

  74. 

  75. 	BOOL SolveError();
    76. 

  76. public:
    77. 

  77. 	// .用户登陆服务器请求;
    78. 

  78. 	BOOL LoginRemoteSvrRequest();
    79. 

  79. 	BOOL LoginLocalSvrRequest();
    80. 

  80. 

  81. 	// .用户登陆服务请求,服务器的响应返回;
    82. 

  82. 	void LoginRemoteSvrResponse(void *pLoginResult);
    83. 

  83. 	void LoginLocalSvrResponse(void *pLoginResult);
    84. 

  84. 

  85. 	// .客户端登陆后,聊天数据请求;
    86. 

  86. 	BOOL ChatRemoteSvrMessageRequest(void *szDataBuf, int nDataLen);
    87. 

  87. 	BOOL ChatLocalSvrMessageRequest(void *szDataBuf, int nDataLen);//ChatLocalSvrMessageRequest
    88. 

  88. 

  89. 	// .客户端登陆后,聊天数据请求,服务端的响应返回;
    90. 

  90. 	void ChatRemoteSvrMessageResponse(void *pResponse);
    91. 

  91. 	void ChatLocalSvrMessageResponse(void *pResponse);
    92. 

  92. 

  93. public:
    94. 

  94. 	DWORD m_dwCurRecive;		// 当前接收的字节;
    95. 

  95. 	DWORD m_dwSumRecive;		// 总接收的字节;
    96. 

  96. 	BYTE *m_pPendingbuf;		// 接收的缓存;	
    97. 

  97. 	DWORD m_dwPendingSize;
    98. 

  98. 	BYTE  m_byPendingbuf[2];
    99. 

  99. };
    100. 

  100. 

  101. #endif
    102.