modify:after login in,get message through get method of http

Author: xengine-qyt

XEngine_Source/VSCopy_Debug.bat

@@ -11,5 +11,5 @@ copy /y "D:\XEngine\XEngine_SourceCode\Debug\HelpComponents_Packets.dll" "./"
 copy /y "D:\XEngine\XEngine_SourceCode\Debug\HelpComponents_XLog.dll" "./"
 copy /y "D:\XEngine\XEngine_SourceCode\Debug\HelpComponents_DataBase.dll" "./"
 
-copy /y "D:\XEngine\XEngine_SourceCode\Debug\RfcComponents_HttpServer.dll" "./"
+copy /y "D:\XEngine\XEngine_SourceCode\Debug\RfcComponents_HttpProtocol.dll" "./"
 copy /y "D:\XEngine\XEngine_SourceCode\Debug\RfcComponents_WSProtocol.dll" "./"

XEngine_Source/XEngine_MQServiceApp/MQService_HttpTask.cpp

@@ -40,8 +40,9 @@ XHTHREAD CALLBACK MessageQueue_HttpThread(XPVOID lParam)
 }
 bool MessageQueue_Http_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, XCHAR** pptszListHdr, int nHdrCount)
 {
-	LPCXSTR lpszMethod = _X("POST");
-	if (0 == _tcsxnicmp(lpszMethod, pSt_HTTPParam->tszHttpMethod, _tcsxlen(lpszMethod)))
+	LPCXSTR lpszPostMethod = _X("POST");
+	LPCXSTR lpszGetMethod = _X("GET");
+	if (0 == _tcsxnicmp(lpszPostMethod, pSt_HTTPParam->tszHttpMethod, _tcsxlen(lpszPostMethod)))
 	{
 		int nPLen = 0;
 		XCHAR tszMsgBuffer[4096];
@@ -53,6 +54,51 @@ bool MessageQueue_Http_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCXST
 		ProtocolModule_Parse_Http(lpszMsgBuffer, nMsgLen, &st_ProtocolHdr, tszMsgBuffer, &nPLen);
 		MessageQueue_TCP_Handle(&st_ProtocolHdr, lpszClientAddr, tszMsgBuffer, nPLen, XENGINE_MQAPP_NETTYPE_HTTP);
 	}
+	else if (0 == _tcsxnicmp(lpszGetMethod, pSt_HTTPParam->tszHttpMethod, _tcsxlen(lpszGetMethod)))
+	{
+		//http://127.0.0.1:5201/api?function=get&token=112&key=xengine&serial=1
+		HttpProtocol_ServerHelp_GetParament(pSt_HTTPParam->tszHttpUri, &pptszListHdr, &nHdrCount);
+		if (4 != nHdrCount)
+		{
+			int nPKTLen = 8196;
+			XCHAR tszPKTBuffer[8196];
+			RFCCOMPONENTS_HTTP_HDRPARAM st_HTTPHdr;
+
+			memset(tszPKTBuffer, '\0', sizeof(tszPKTBuffer));
+			memset(&st_HTTPHdr, '\0', sizeof(RFCCOMPONENTS_HTTP_HDRPARAM));
+
+			st_HTTPHdr.nHttpCode = 400;
+			st_HTTPHdr.bIsClose = true;
+
+			HttpProtocol_Server_SendMsgEx(xhHTTPPacket, tszPKTBuffer, &nPKTLen, &st_HTTPHdr);
+			NetCore_TCPXCore_SendEx(xhHTTPSocket, lpszClientAddr, tszPKTBuffer, nPKTLen);
+			return false;
+		}
+		XCHAR tszKey[128];
+		XCHAR tszValue[128];
+		XENGINE_PROTOCOLHDR st_ProtocolHdr;
+		XENGINE_PROTOCOL_XMQ st_MQProtocol;
+
+		memset(tszKey, '\0', sizeof(tszKey));
+		memset(tszValue, '\0', sizeof(tszValue));
+		memset(&st_ProtocolHdr, '\0', sizeof(XENGINE_PROTOCOLHDR));
+		memset(&st_MQProtocol, '\0', sizeof(XENGINE_PROTOCOL_XMQ));
+
+		BaseLib_OperatorString_GetKeyValue(pptszListHdr[1], "=", tszKey, tszValue);
+
+		st_ProtocolHdr.xhToken = _ttxoll(tszValue);
+		st_ProtocolHdr.wHeader = XENGIEN_COMMUNICATION_PACKET_PROTOCOL_HEADER;
+		st_ProtocolHdr.unOperatorType = ENUM_XENGINE_COMMUNICATION_PROTOCOL_TYPE_XMQ;
+		st_ProtocolHdr.unOperatorCode = XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_MQ_REQGET;
+		st_ProtocolHdr.xhToken = sizeof(XENGINE_PROTOCOL_XMQ);
+		st_ProtocolHdr.wTail = XENGIEN_COMMUNICATION_PACKET_PROTOCOL_TAIL;
+
+		BaseLib_OperatorString_GetKeyValue(pptszListHdr[2], "=", tszKey, st_MQProtocol.tszMQKey);
+		BaseLib_OperatorString_GetKeyValue(pptszListHdr[3], "=", tszKey, tszValue);
+		st_MQProtocol.nSerial = _ttxoll(tszValue);
+
+		MessageQueue_TCP_Handle(&st_ProtocolHdr, lpszClientAddr, (LPCXSTR)&st_MQProtocol, sizeof(XENGINE_PROTOCOL_XMQ), XENGINE_MQAPP_NETTYPE_HTTP);
+	}
 	else
 	{
 		XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_WARN, _X("HTTP消息端:%s,协议错误"), lpszClientAddr);

XEngine_Source/XEngine_MQServiceApp/MQService_Net.cpp

@@ -145,18 +145,18 @@ bool XEngine_MQXService_Send(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int
     }
     else if (XENGINE_MQAPP_NETTYPE_HTTP == nIPProto)
     {
-        int nPKTLen = 8196;
-        XCHAR tszPKTBuffer[8196];
-        RFCCOMPONENTS_HTTP_HDRPARAM st_HTTPHdr;
+		int nPKTLen = 8196;
+		XCHAR tszPKTBuffer[8196];
+		RFCCOMPONENTS_HTTP_HDRPARAM st_HTTPHdr;
 
-        memset(tszPKTBuffer, '\0', sizeof(tszPKTBuffer));
-        memset(&st_HTTPHdr, '\0', sizeof(RFCCOMPONENTS_HTTP_HDRPARAM));
+		memset(tszPKTBuffer, '\0', sizeof(tszPKTBuffer));
+		memset(&st_HTTPHdr, '\0', sizeof(RFCCOMPONENTS_HTTP_HDRPARAM));
 
-        st_HTTPHdr.nHttpCode = 200;
-        st_HTTPHdr.bIsClose = true;
-        _tcsxcpy(st_HTTPHdr.tszMimeType, _X("json"));
+		st_HTTPHdr.nHttpCode = 200;
+		st_HTTPHdr.bIsClose = true;
+		_tcsxcpy(st_HTTPHdr.tszMimeType, _X("json"));
 
-        HttpProtocol_Server_SendMsgEx(xhHTTPPacket, tszPKTBuffer, &nPKTLen, &st_HTTPHdr, lpszMsgBuffer, nMsgLen);
+		HttpProtocol_Server_SendMsgEx(xhHTTPPacket, tszPKTBuffer, &nPKTLen, &st_HTTPHdr, lpszMsgBuffer, nMsgLen);
 		if (!NetCore_TCPXCore_SendEx(xhHTTPSocket, lpszClientAddr, tszPKTBuffer, nPKTLen))
 		{
 			XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _X("发送数据给HTTP客户端：%s，失败，错误：%lX"), lpszClientAddr, NetCore_GetLastError());