Skip to content

Commit 2fa9754

Browse files
committed
modify:verification method and register not ver
1 parent 261feed commit 2fa9754

File tree

2 files changed

+16
-15
lines changed

2 files changed

+16
-15
lines changed

XEngine_Source/XEngine_MQServiceApp/MQService_HTTPTask/MQService_HTTPPost.cpp

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,22 @@ bool MessageQueue_HttpTask_Post(LPCXSTR lpszClientAddr, LPCXSTR lpszFuncName, LP
2323
LPCXSTR lpszAPIGetOnline = _X("getonline");
2424
LPCXSTR lpszAPIDelTopic = _X("deltopic");
2525
LPCXSTR lpszAPIDelUser = _X("deluser");
26+
27+
//判断是否需要验证,不是注册协议
28+
if (st_ServiceCfg.st_XAuthorize.bHTTPAuth && (0 != _tcsxnicmp(lpszAPIRegister, lpszFuncName, _tcsxlen(lpszAPIRegister))))
29+
{
30+
XNETHANDLE xhToken = 0;
31+
if (ProtocolModule_Parse_Token(lpszMsgBuffer, nMsgLen, &xhToken))
32+
{
33+
if (!Session_Token_Get(xhToken))
34+
{
35+
ProtocolModule_Packet_Http(tszSDBuffer, &nSDLen, ERROR_XENGINE_MESSAGE_HTTP_AUTHORIZE, "not authorize");
36+
XEngine_MQXService_Send(lpszClientAddr, tszSDBuffer, nSDLen, XENGINE_MQAPP_NETTYPE_HTTP);
37+
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _X("HTTP客户端:%s,请求的API:%s 失败,因为没有经过验证"), lpszClientAddr, lpszFuncName);
38+
return false;
39+
}
40+
}
41+
}
2642
//判断请求
2743
if (0 == _tcsxnicmp(lpszAPIRegister, lpszFuncName, _tcsxlen(lpszAPIRegister)))
2844
{

XEngine_Source/XEngine_MQServiceApp/MQService_HttpTask.cpp

Lines changed: 0 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -61,21 +61,6 @@ bool MessageQueue_Http_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCXST
6161
//判断请求
6262
if (0 == _tcsxnicmp(lpszPostMethod, pSt_HTTPParam->tszHttpMethod, _tcsxlen(lpszPostMethod)))
6363
{
64-
//判断是否需要验证
65-
if (st_ServiceCfg.st_XAuthorize.bHTTPAuth)
66-
{
67-
XNETHANDLE xhToken = 0;
68-
if (ProtocolModule_Parse_Token(lpszMsgBuffer, nMsgLen, &xhToken))
69-
{
70-
if (!Session_Token_Get(xhToken))
71-
{
72-
ProtocolModule_Packet_Http(tszPKTBuffer, &nPKTLen, ERROR_XENGINE_MESSAGE_HTTP_AUTHORIZE, "not authorize");
73-
XEngine_MQXService_Send(lpszClientAddr, tszPKTBuffer, nPKTLen, XENGINE_MQAPP_NETTYPE_HTTP);
74-
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _X("HTTP客户端:%s,请求的API:%s 失败,因为没有经过验证"), lpszClientAddr, pSt_HTTPParam->tszHttpUri);
75-
return false;
76-
}
77-
}
78-
}
7964
BaseLib_String_GetKeyValue(ppSt_ListUrl[0], _X("="), tszKey, tszValue);
8065
MessageQueue_HttpTask_Post(lpszClientAddr, tszValue, lpszMsgBuffer, nMsgLen);
8166
}

0 commit comments

Comments
 (0)