added:logout http pass

Author: xengine-qyt

XEngine_Source/XEngine_MQServiceApp/MQService_Net.cpp

@@ -103,6 +103,31 @@ void XEngine_MQXService_Close(LPCTSTR lpszClientAddr, int nIPProto, BOOL bHeart)
 	memset(&st_UserInfo, '\0', sizeof(XENGINE_PROTOCOL_USERINFO));
     if (SessionModule_Client_GetUser(lpszClientAddr, st_UserInfo.tszUserName))
     {
+        if (_tcslen(st_ServiceCfg.st_XPass.tszPassLogout) > 0)
+        {
+            int nSDLen = 0;
+			int nHTTPCode = 0;
+			TCHAR tszSDBuffer[1024];
+			APIHELP_HTTPPARAMENT st_HTTPParament;
+			XENGINE_PROTOCOL_USERAUTH st_ProtocolAuth;
+
+            memset(tszSDBuffer, '\0', sizeof(tszSDBuffer));
+			memset(&st_HTTPParament, '\0', sizeof(APIHELP_HTTPPARAMENT));
+            memset(&st_ProtocolAuth, '\0', sizeof(XENGINE_PROTOCOL_USERAUTH));
+
+			st_HTTPParament.nTimeConnect = 2;
+
+			ProtocolModule_Packet_PassAuth(&st_ProtocolAuth, tszSDBuffer, &nSDLen, XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_MQ_REQUSEROUT);
+			APIHelp_HttpRequest_Custom(_T("POST"), st_ServiceCfg.st_XPass.tszPassLogout, tszSDBuffer, &nHTTPCode, NULL, NULL, NULL, NULL, &st_HTTPParament);
+			if (200 == nHTTPCode)
+			{
+                XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("%s客户端:%s,请求远程关闭连接失败,错误:%lX,HTTPCode:%d"), nIPProto, lpszClientAddr, APIHelp_GetLastError(), nHTTPCode);
+			}
+            else
+            {
+                XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("%s客户端:%s,请求远程关闭连接失败,错误:%lX,HTTPCode:%d"), nIPProto, lpszClientAddr, APIHelp_GetLastError(), nHTTPCode);
+            }
+        }
         DBModule_MQUser_UserUPDate(&st_UserInfo);
     }
     SessionModule_Notify_DelClient(lpszClientAddr);

XEngine_Source/XQueue_ProtocolHdr.h

@@ -40,6 +40,8 @@
 #define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_MQ_REPUSERREG 0x7023
 #define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_MQ_REQUSERDEL 0x7024
 #define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_MQ_REPUSERDEL 0x7025
+#define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_MQ_REQUSEROUT 0x7026       
+#define XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_MQ_REPUSEROUT 0x7027
 ///////////////////////////////////////////////////////////////////////////
 //                          导出的数据结构
 ///////////////////////////////////////////////////////////////////////////