fixed:Doesn't handle whether the client is online or not when a message notification is made

Author: xengine-qyt

XEngine_Source/MQCore_SessionModule/MQCore_SessionModule.def

@@ -12,4 +12,5 @@ EXPORTS
 	SessionModule_Client_GetAddr
 	SessionModule_Client_GetInfoByUser
 	SessionModule_Client_GetType
+	SessionModule_Client_GetExist
 	SessionModule_Client_GetListAddr

XEngine_Source/MQCore_SessionModule/SessionModule_Client/SessionModule_Client.cpp

@@ -341,6 +341,70 @@ bool CSessionModule_Client::SessionModule_Client_GetType(LPCXSTR lpszSessionStr,
 	return true;
 }
 /********************************************************************
+函数名称：SessionModule_Client_GetExist
+函数功能：指定客户端是否存在
+ 参数.一：lpszClientAddr
+  In/Out：In
+  类型：常量字符指针
+  可空：Y
+  意思：输入客户端地址
+ 参数.二：lpszClientUser
+  In/Out：In
+  类型：常量字符指针
+  可空：Y
+  意思：输入客户端用户
+返回值
+  类型：逻辑型
+  意思：是否成功
+备注：不能同时为NULL,可以使用一个参数
+*********************************************************************/
+bool CSessionModule_Client::SessionModule_Client_GetExist(LPCXSTR lpszClientAddr, LPCXSTR lpszClientUser)
+{
+	Session_IsErrorOccur = false;
+
+	if (NULL == lpszClientUser && NULL == lpszClientAddr)
+	{
+		Session_IsErrorOccur = true;
+		Session_dwErrorCode = ERROR_MQ_MODULE_SESSION_PARAMENT;
+		return false;
+	}
+
+	st_Locker.lock_shared();
+	if (NULL == lpszClientAddr)
+	{
+		bool bFound = false;
+		unordered_map<tstring, XENGINE_SESSIONINFO>::iterator stl_MapIterator = stl_MapSession.begin();
+		for (int i = 0; stl_MapIterator != stl_MapSession.end(); stl_MapIterator++, i++)
+		{
+			if (0 == _tcsxnicmp(lpszClientUser, stl_MapIterator->second.st_UserInfo.tszUserName, _tcsxlen(stl_MapIterator->second.st_UserInfo.tszUserName)))
+			{
+				bFound = true;
+				break;
+			}
+		}
+		if (!bFound)
+		{
+			Session_IsErrorOccur = true;
+			Session_dwErrorCode = ERROR_MQ_MODULE_SESSION_NOTFOUND;
+			st_Locker.unlock_shared();
+			return false;
+		}
+	}
+	else
+	{
+		unordered_map<tstring, XENGINE_SESSIONINFO>::iterator stl_MapIterator = stl_MapSession.find(lpszClientAddr);
+		if (stl_MapIterator == stl_MapSession.end())
+		{
+			Session_IsErrorOccur = true;
+			Session_dwErrorCode = ERROR_MQ_MODULE_SESSION_NOTFOUND;
+			st_Locker.unlock_shared();
+			return false;
+		}
+	}
+	st_Locker.unlock_shared();
+	return true;
+}
+/********************************************************************
 函数名称：SessionModule_Client_GetList
 函数功能：获取客户端地址列表
  参数.一：ppptszClientList

XEngine_Source/MQCore_SessionModule/SessionModule_Client/SessionModule_Client.h

@@ -33,6 +33,7 @@ class CSessionModule_Client
     bool SessionModule_Client_GetAddr(LPCXSTR lpszUserName, XCHAR* ptszUserAddr = NULL);
     bool SessionModule_Client_GetInfoByUser(LPCXSTR lpszUserName, XENGINE_PROTOCOL_USERINFO* pSt_UserInfo);
     bool SessionModule_Client_GetType(LPCXSTR lpszSessionStr, int* pInt_NetType);
+    bool SessionModule_Client_GetExist(LPCXSTR lpszClientAddr = NULL, LPCXSTR lpszClientUser = NULL);
     bool SessionModule_Client_GetListAddr(XCHAR*** ppptszClientList, int* pInt_ListCount);
 private:
     shared_mutex st_Locker;

XEngine_Source/MQCore_SessionModule/Session_Define.h

@@ -174,6 +174,25 @@ extern "C" bool SessionModule_Client_GetInfoByUser(LPCXSTR lpszUserName, XENGINE
 *********************************************************************/
 extern "C" bool SessionModule_Client_GetType(LPCXSTR lpszSessionStr, int* pInt_NetType);
 /********************************************************************
+函数名称：SessionModule_Client_GetExist
+函数功能：指定客户端是否存在
+ 参数.一：lpszClientAddr
+  In/Out：In
+  类型：常量字符指针
+  可空：Y
+  意思：输入客户端地址
+ 参数.二：lpszClientUser
+  In/Out：In
+  类型：常量字符指针
+  可空：Y
+  意思：输入客户端用户
+返回值
+  类型：逻辑型
+  意思：是否成功
+备注：不能同时为NULL,可以使用一个参数
+*********************************************************************/
+extern "C" bool SessionModule_Client_GetExist(LPCXSTR lpszClientAddr = NULL, LPCXSTR lpszClientUser = NULL);
+/********************************************************************
 函数名称：SessionModule_Client_GetList
 函数功能：获取客户端地址列表
  参数.一：ppptszClientList

XEngine_Source/MQCore_SessionModule/pch.cpp

@@ -65,6 +65,10 @@ extern "C" bool SessionModule_Client_GetType(LPCXSTR lpszSessionStr, int* pInt_N
 {
 	return m_SessionClient.SessionModule_Client_GetType(lpszSessionStr, pInt_NetType);
 }
+extern "C" bool SessionModule_Client_GetExist(LPCXSTR lpszClientAddr, LPCXSTR lpszClientUser)
+{
+	return m_SessionClient.SessionModule_Client_GetExist(lpszClientAddr, lpszClientUser);
+}
 extern "C" bool SessionModule_Client_GetListAddr(XCHAR * **ppptszClientList, int* pInt_ListCount)
 {
 	return m_SessionClient.SessionModule_Client_GetListAddr(ppptszClientList, pInt_ListCount);

XEngine_Source/XEngine_MQServiceApp/MQService_TCPTask.cpp

@@ -463,11 +463,14 @@ bool MessageQueue_TCP_Handle(XENGINE_PROTOCOLHDR* pSt_ProtocolHdr, LPCXSTR lpszC
 						memset(tszSDBuffer, '\0', sizeof(tszSDBuffer));
 
 						pSt_ProtocolHdr->unOperatorCode = XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_MQ_MSGNOTIFY;
-
-						SessionModule_Client_GetAddr(ppSt_ListUser[i]->tszUserName, tszUserAddr);
-						SessionModule_Client_GetType(tszUserAddr, &nClientType);
-						ProtocolModule_Packet_Common(nClientType, pSt_ProtocolHdr, &st_MQProtocol, tszSDBuffer, &nSDLen, lpszMsgBuffer + sizeof(XENGINE_PROTOCOL_XMQ), nMsgLen - sizeof(XENGINE_PROTOCOL_XMQ));
-						XEngine_MQXService_Send(tszUserAddr, tszSDBuffer, nSDLen, nClientType);
+						//只有在线用户才需要即时通知
+						if (SessionModule_Client_GetExist(NULL, tszUserName))
+						{
+							SessionModule_Client_GetAddr(ppSt_ListUser[i]->tszUserName, tszUserAddr);
+							SessionModule_Client_GetType(tszUserAddr, &nClientType);
+							ProtocolModule_Packet_Common(nClientType, pSt_ProtocolHdr, &st_MQProtocol, tszSDBuffer, &nSDLen, lpszMsgBuffer + sizeof(XENGINE_PROTOCOL_XMQ), nMsgLen - sizeof(XENGINE_PROTOCOL_XMQ));
+							XEngine_MQXService_Send(tszUserAddr, tszSDBuffer, nSDLen, nClientType);
+						}
 					}
 					BaseLib_OperatorMemory_Free((XPPPMEM)&ppSt_ListUser, nListCount);
 					XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _X("%s消息端:%s,主题:%s,序列:%lld,投递数据到消息队列成功,通知客户端个数:%d"), lpszClientType, lpszClientAddr, st_DBQueue.tszQueueName, st_DBQueue.nQueueSerial, nListCount);