added:heartbeat client module support

Author: xengine-qyt

XEngine_Source/AuthorizeModule_Client/AuthClient_Connector/AuthClient_Connector.cpp

@@ -86,6 +86,8 @@ bool CAuthClient_Connector::AuthClient_Connector_Close()
 		pSTDThread->join();
 	}
 	m_bLogin = false;
+	m_bAuth = false;
+	m_bHeart = false;
 	XClient_TCPSelect_Close(m_hSocket);
 #endif
 	return true;
@@ -246,13 +248,41 @@ bool CAuthClient_Connector::AuthClient_Connector_Login(LPCXSTR lpszUser, LPCXSTR
 #endif
 	return true;
 }
+/********************************************************************
+函数名称：AuthClient_Connector_Heart
+函数功能：启用禁用客户端心跳
+ 参数.一：bEnable
+  In/Out：In
+  类型：逻辑型
+  可空：Y
+  意思：是启用还是禁用
+返回值
+  类型：逻辑型
+  意思：是否成功
+备注：
+*********************************************************************/
+bool CAuthClient_Connector::AuthClient_Connector_Heart(bool bEnable /* = true */)
+{
+	AuthClient_IsErrorOccur = false;
+
+	if (!m_bAuth)
+	{
+		AuthClient_IsErrorOccur = true;
+		AuthClient_dwErrorCode = ERROR_AUTHORIZE_MODULE_CLIENT_NOTAUTH;
+		return false;
+	}
+	m_bHeart = bEnable;
+	return true;
+}
 //////////////////////////////////////////////////////////////////////////
 //                      保护函数
 //////////////////////////////////////////////////////////////////////////
 XHTHREAD CALLBACK CAuthClient_Connector::AuthClient_Connector_Thread(XPVOID lParam)
 {
 	CAuthClient_Connector* pClass_This = (CAuthClient_Connector*)lParam;
 
+	time_t nTimeStart = time(NULL);
+
 #if (1 == _XAUTH_BUILD_SWITCH_CLIENT_TCP)
 	while (pClass_This->m_bRun)
 	{
@@ -280,6 +310,22 @@ XHTHREAD CALLBACK CAuthClient_Connector::AuthClient_Connector_Thread(XPVOID lPar
 		{
 			pClass_This->m_bAuth = false;
 		}
+		//心跳支持
+		if (pClass_This->m_bHeart)
+		{
+			time_t nTimeEnd = time(NULL);
+			if ((nTimeEnd - nTimeStart) > 2)
+			{
+				XENGINE_PROTOCOLHDR st_ProtocolHdr = {};
+				st_ProtocolHdr.wHeader = XENGIEN_COMMUNICATION_PACKET_PROTOCOL_HEADER;
+				st_ProtocolHdr.unOperatorType = ENUM_XENGINE_COMMUNICATION_PROTOCOL_TYPE_HEARTBEAT;
+				st_ProtocolHdr.unOperatorCode = XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_HB_SYN;
+				st_ProtocolHdr.byVersion = 1;
+				st_ProtocolHdr.wTail = XENGIEN_COMMUNICATION_PACKET_PROTOCOL_TAIL;
+
+				XClient_TCPSelect_SendMsg(pClass_This->m_hSocket, (LPCXSTR)&st_ProtocolHdr, sizeof(XENGINE_PROTOCOLHDR));
+			}
+		}
 		std::this_thread::sleep_for(std::chrono::seconds(1));
 	}
 #endif

XEngine_Source/AuthorizeModule_Client/AuthClient_Connector/AuthClient_Connector.h

@@ -27,12 +27,14 @@ class CAuthClient_Connector
 	bool AuthClient_Connector_Close();
 	bool AuthClient_Connector_GetAuth(bool* pbAuth = NULL);
 	bool AuthClient_Connector_Login(LPCXSTR lpszUser, LPCXSTR lpszPass, int nDYCode = 0, XNETHANDLE xhToken = 0);
+	bool AuthClient_Connector_Heart(bool bEnable = true);
 protected:
 	static XHTHREAD CALLBACK AuthClient_Connector_Thread(XPVOID lParam);
 private:
 	bool m_bRun = false;
 	bool m_bLogin = false;
 	bool m_bAuth = false;
+	bool m_bHeart = false;
 	XSOCKET m_hSocket = 0;
 	XCHAR tszPassStr[128] = {};
 private:

XEngine_Source/AuthorizeModule_Client/AuthClient_Define.h

@@ -93,6 +93,20 @@ extern "C" bool AuthClient_Connector_GetAuth(bool* pbAuth = NULL);
 备注：
 *********************************************************************/
 extern "C" bool AuthClient_Connector_Login(LPCXSTR lpszUser, LPCXSTR lpszPass, int nDYCode = 0, XNETHANDLE xhToken = 0);
+/********************************************************************
+函数名称：AuthClient_Connector_Heart
+函数功能：启用禁用客户端心跳
+ 参数.一：bEnable
+  In/Out：In
+  类型：逻辑型
+  可空：Y
+  意思：是启用还是禁用
+返回值
+  类型：逻辑型
+  意思：是否成功
+备注：服务器开启了心跳,那么客户端也需要开启
+*********************************************************************/
+extern "C" bool AuthClient_Connector_Heart(bool bEnable = true);
 /************************************************************************/
 /*                         临时验证函数                                 */
 /************************************************************************/

XEngine_Source/AuthorizeModule_Client/AuthClient_Error.h

@@ -21,6 +21,7 @@
 #define ERROR_AUTHORIZE_MODULE_CLIENT_RECV 0x0060002                     //接受数据失败
 #define ERROR_AUTHORIZE_MODULE_CLIENT_LOGIN 0x0060003                    //登录失败，请查看错误码
 #define ERROR_AUTHORIZE_MODULE_CLIENT_THREAD 0x0060004                   //创建线程失败
+#define ERROR_AUTHORIZE_MODULE_CLIENT_NOTAUTH 0x0060005                  //没有验证无法启用心跳
 /************************************************************************/
 /*                          HTTP验证错误                                */
 /************************************************************************/

XEngine_Source/AuthorizeModule_Client/AuthorizeModule_Client.def

@@ -7,6 +7,7 @@ EXPORTS
 	AuthClient_Connector_Close
 	AuthClient_Connector_GetAuth
 	AuthClient_Connector_Login
+	AuthClient_Connector_Heart
 
 	AuthClient_HTTPVer_TryRequest
 	AuthClient_HTTPVer_GetDCode

XEngine_Source/AuthorizeModule_Client/pch.cpp

@@ -47,6 +47,10 @@ extern "C" bool AuthClient_Connector_Login(LPCXSTR lpszUser, LPCXSTR lpszPass, i
 {
 	return m_Connector.AuthClient_Connector_Login(lpszUser, lpszPass, nDYCode, xhToken);
 }
+extern "C" bool AuthClient_Connector_Heart(bool bEnable)
+{
+	return m_Connector.AuthClient_Connector_Heart(bEnable);
+}
 /************************************************************************/
 /*                         临时验证函数                                 */
 /************************************************************************/