modify:session time out supported

Author: xengine-qyt

XEngine_Source/XEngine_MQServiceApp/MQService_HttpTask.cpp

@@ -44,6 +44,17 @@ XHTHREAD CALLBACK MessageQueue_HttpThread(LPVOID lParam)
 	}
 	return 0;
 }
+void CALLBACK MessageQueue_HttpTime(LPCSTR lpszSessionStr, LPVOID lParam)
+{
+	XENGINE_PROTOCOL_USERINFO st_UserInfo;
+	memset(&st_UserInfo, '\0', sizeof(XENGINE_PROTOCOL_USERINFO));
+	if (SessionModule_Client_GetUser(lpszSessionStr, st_UserInfo.tszUserName))
+	{
+		DBModule_MQUser_UserUPDate(&st_UserInfo);
+	}
+	SessionModule_Client_Delete(lpszSessionStr);
+	XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("HTTP消息端:%s,会话ID:%s,用户会话超时!"), st_UserInfo.tszUserName, lpszSessionStr);
+}
 BOOL MessageQueue_Http_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCTSTR lpszClientAddr, LPCTSTR lpszMsgBuffer, int nMsgLen, TCHAR** pptszListHdr, int nHdrCount)
 {
 	LPCTSTR lpszMethod = _T("POST");

XEngine_Source/XEngine_MQServiceApp/MQService_HttpTask.h

@@ -1,4 +1,5 @@
 #pragma once
 
 XHTHREAD CALLBACK MessageQueue_HttpThread(LPVOID lParam);
+void CALLBACK MessageQueue_HttpTime(LPCSTR lpszSessionStr, LPVOID lParam);
 BOOL MessageQueue_Http_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCTSTR lpszClientAddr, LPCTSTR lpszMsgBuffer, int nMsgLen, TCHAR** pptszListHdr, int nHdrCount);

XEngine_Source/XEngine_MQServiceApp/XEngine_MQServiceApp.cpp

@@ -156,12 +156,12 @@ int main(int argc, char** argv)
 	}
 	XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("启动服务中，初始化数据库服务成功"));
 
-	if (!SessionModule_Client_Init())
+	if (!SessionModule_Client_Init(st_ServiceCfg.st_XTime.nSessionTime, MessageQueue_HttpTime))
 	{
 		XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("初始化客户端会话管理器失败，错误：%lX"), SessionModule_GetLastError());
 		goto NETSERVICEEXIT;
 	}
-	XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("启动服务中，初始化客户端会话管理器成功"));
+	XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("启动服务中，初始化客户端会话管理器成功,会话超时时间:%d 秒"), st_ServiceCfg.st_XTime.nSessionTime);
 
 	if (st_ServiceCfg.nTCPPort > 0)
 	{