Skip to content

Commit 29cdf83

Browse files
committed
modify:create token of http when tcp login
1 parent a0f6cf8 commit 29cdf83

2 files changed

Lines changed: 11 additions & 0 deletions

File tree

XEngine_Source/XEngine_MQServiceApp/MQService_Net.cpp

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -161,6 +161,13 @@ void XEngine_MQXService_Close(LPCXSTR lpszClientAddr, int nIPProto, bool bHeart)
161161
}
162162
}
163163
DBModule_MQUser_UserUPDate(&st_UserInfo);
164+
//释放token
165+
XNETHANDLE xhToken = 0;
166+
SessionModule_Client_GetInfoByUser(st_UserInfo.tszUserName, &st_UserInfo);
167+
if (Session_Token_GetUser(st_UserInfo.tszUserName, st_UserInfo.tszUserPass, &xhToken))
168+
{
169+
Session_Token_Delete(xhToken);
170+
}
164171
}
165172
SessionModule_Client_Delete(lpszClientAddr);
166173
}

XEngine_Source/XEngine_MQServiceApp/MQService_TCPTask.cpp

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -153,6 +153,10 @@ bool MessageQueue_TCP_Handle(XENGINE_PROTOCOLHDR* pSt_ProtocolHdr, LPCXSTR lpszC
153153
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _X("%s客户端:%s,用户名:%s,登录失败,客户端权限不足够"), lpszClientAddr, st_UserInfo.tszUserName);
154154
return false;
155155
}
156+
//创建TOKEN
157+
BaseLib_Handle_Create(&pSt_ProtocolHdr->xhToken);
158+
Session_Token_Insert(pSt_ProtocolHdr->xhToken, &st_UserInfo);
159+
156160
pSt_ProtocolHdr->wReserve = 0;
157161
SessionModule_Client_Create(lpszClientAddr, &st_UserInfo, nNetType);
158162
ProtocolModule_Packet_Common(nNetType, pSt_ProtocolHdr, NULL, tszSDBuffer, &nSDLen);

0 commit comments

Comments
 (0)