Merge pull request #18 from libxengine/develop

V3.10.0.1001 Merge

Author: xengine-qyt

CHANGELOG

@@ -1,3 +1,31 @@
+XEngine_MQService V3.10.0.1001
+
+增加:消息属性增加无限制消息获取
+增加:http的获取主题消息支持队列统计了
+更新:匹配XEngine V8.25版本API
+修改:退出协议不在需要验证用户和密码,因为只对自己做登出
+修改:用户删除需要身份ID了
+修改:消息队列支持默认主题名设置了
+修改:获取指定消息时会处理消息识别的一些问题
+修改:未读消息协议修改为统计剩余消息了
+修改:获取在线列表会验证url参数了
+修正:用户登出的http hook没有用户信息的问题
+修正:获取消息对于指定消息没有正确处理的问题
+删除:数据库模块的DBModule_MQData_List函数
+
+added:message attr add proactive message get.
+added:get topic of http restful support get message count
+update:match xengine v8.25
+modify:does not ver user pass and user name when user logout.just ver self
+modify:delete user need id number
+modify:support default topic name set for mq protocol
+modify:some issues with message identification will be handled when obtaining the specified message
+modify:unread message protocol is modify to left count
+modify:get online user list ver url parament now
+fixed:user logout httppass is not user info
+fixed:getting messages will process messages that are not sent to self
+delete:DBModule_MQData_List function for dbmoudle
+======================================================================================
 XEngine_MQService V3.9.0.1001
 
 增加:消息属性的通知所有和通知自身的支持

README.md

@@ -83,6 +83,9 @@ make FLAGS=CleanAll 清理编译
 如果是升级安装,下载新版本后修改配置文件就可以直接运行了
 数据库需要打开数据库匹配字段和表是否一致
 
+## 视频教程
+你也可以观看视频教程来了解我们的代码框架情况:https://www.bilibili.com/video/BV1uH4y1a7QV
+
 #### 使用说明
 
 1.  切换到MASTER分支

XEngine_Apps/MQCore_HTTPApp/MQCore_HTTPApp.cpp

@@ -4,7 +4,7 @@
 #include <json/json.h>
 #pragma comment(lib,"Ws2_32")
 #pragma comment(lib,"x86/XEngine_BaseLib/XEngine_BaseLib")
-#pragma comment(lib,"x86/XEngine_NetHelp/NetHelp_APIClient")
+#pragma comment(lib,"x86/XEngine_Client/XClient_APIHelp")
 #pragma comment(lib,"../../XEngine_Source/Debug/jsoncpp")
 #endif
 #include <stdio.h>
@@ -16,11 +16,12 @@
 #include <XEngine_Include/XEngine_ProtocolHdr.h>
 #include <XEngine_Include/XEngine_BaseLib/BaseLib_Define.h>
 #include <XEngine_Include/XEngine_BaseLib/BaseLib_Error.h>
-#include <XEngine_Include/XEngine_NetHelp/APIClient_Define.h>
-#include <XEngine_Include/XEngine_NetHelp/APIClient_Error.h>
+#include <XEngine_Include/XEngine_Client/APIClient_Define.h>
+#include <XEngine_Include/XEngine_Client/APIClient_Error.h>
 #include "../../XEngine_Source/XQueue_ProtocolHdr.h"
 
-//g++ -std=c++17 -Wall -g MQCore_HTTPApp.cpp -o MQCore_HTTPApp.exe -I ../../XEngine_Source/XEngine_ThirdPart/jsoncpp -L /usr/local/lib/XEngine_Release/XEngine_BaseLib -L /usr/local/lib/XEngine_Release/XEngine_NetHelp -L ../../XEngine_Source/XEngine_ThirdPart/jsoncpp -lXEngine_BaseLib -lNetHelp_APIClient -ljsoncpp
+//g++ -std=c++17 -Wall -g MQCore_HTTPApp.cpp -o MQCore_HTTPApp.exe -I ../../XEngine_Source/XEngine_ThirdPart/jsoncpp -L ../../XEngine_Source/XEngine_ThirdPart/jsoncpp -lXEngine_BaseLib -lXClient_APIHelp -ljsoncpp
+
 void MQ_GetUserList()
 {
 	LPCXSTR lpszPostUrl = _X("http://127.0.0.1:5202/api?function=get&method=user");

XEngine_Apps/MQCore_TCPApp/MQCore_TCPApp.cpp

@@ -18,7 +18,8 @@ using namespace std;
 #include <XEngine_Include/XEngine_Client/XClient_Define.h>
 #include <XEngine_Include/XEngine_Client/XClient_Error.h>
 #include "../../XEngine_Source/XQueue_ProtocolHdr.h"
-//g++ -std=c++17 -Wall -g MQCore_TCPApp.cpp -o MQCore_TCPApp.exe -I ../../XEngine_Source/XEngine_ThirdPart/jsoncpp -L /usr/local/lib/XEngine_Release/XEngine_BaseLib -L /usr/local/lib/XEngine_Release/XEngine_Client -L ../../XEngine_Source/XEngine_ThirdPart/jsoncpp -lXEngine_BaseLib -lXClient_Socket
+
+//g++ -std=c++17 -Wall -g MQCore_TCPApp.cpp -o MQCore_TCPApp.exe -I ../../XEngine_Source/XEngine_ThirdPart/jsoncpp -L ../../XEngine_Source/XEngine_ThirdPart/jsoncpp -lXEngine_BaseLib -lXClient_Socket
 
 XSOCKET m_Socket;
 __int64x nLastNumber = 0;

XEngine_Apps/VSCopy-x86.bat

@@ -3,5 +3,5 @@ copy /y "%XEngine_Lib32%\XEngine_BaseLib\XEngine_Algorithm.dll" "./"
 copy /y "%XEngine_Lib32%\XEngine_Core\XEngine_OPenSsl.dll" "./"
 copy /y "%XEngine_Lib32%\XEngine_Core\XEngine_ManagePool.dll" "./"
 copy /y "%XEngine_Lib32%\XEngine_RfcComponents\RfcComponents_WSProtocol.dll" "./"
-copy /y "%XEngine_Lib32%\XEngine_NetHelp\NetHelp_APIClient.dll" "./"
+copy /y "%XEngine_Lib32%\XEngine_Client\XClient_APIHelp.dll" "./"
 copy /y "%XEngine_Lib32%\XEngine_Client\XClient_Socket.dll" "./"

XEngine_Docment/Docment_en.docx

@@ -35,7 +35,8 @@
         "tszPassLogout":""
     },
     "XVer":[
-        "3.9.0.1001 Build20241227",
+        "3.10.0.1001 Build20240305",
+        "3.9.0.1001 Build20231227",
         "3.8.0.1001 Build20230816",
         "3.7.0.1001 Build20230426",
         "3.6.0.1001 Build20230222",

XEngine_Docment/Docment_zh.docx

@@ -129,35 +129,6 @@ extern "C" bool DBModule_MQData_Query(XENGINE_DBMESSAGEQUEUE* pSt_DBInfo);
 *********************************************************************/
 extern "C" bool DBModule_MQData_Modify(XENGINE_DBMESSAGEQUEUE* pSt_DBInfo);
 /********************************************************************
-函数名称：DBModule_MQData_List
-函数功能：枚举指定主题序列号后的数据
- 参数.一：lpszQueueName
-  In/Out：In
-  类型：常量字符指针
-  可空：N
-  意思：输入要处理的主题
- 参数.二：nSerial
-  In/Out：In
-  类型：整数型
-  可空：N
-  意思：输入主题序列号
- 参数.三：pppSt_DBMessage
-  In/Out：Out
-  类型：三级指针
-  可空：N
-  意思：输出数据队列信息
- 参数.四：pInt_ListCount
-  In/Out：Out
-  类型：整数型
-  可空：N
-  意思：输出数据队列大小
-返回值
-  类型：逻辑型
-  意思：是否成功
-备注：
-*********************************************************************/
-extern "C" bool DBModule_MQData_List(LPCXSTR lpszQueueName, __int64x nSerial, XENGINE_DBMESSAGEQUEUE*** pppSt_DBMessage, int* pInt_ListCount);
-/********************************************************************
 函数名称：DBModule_MQData_GetSerial
 函数功能：获取序列号
  参数.一：lpszName
@@ -252,6 +223,30 @@ extern "C" bool DBModule_MQData_ModifyTable(LPCXSTR lpszSrcTable, LPCXSTR lpszDs
 备注：
 *********************************************************************/
 extern "C" bool DBModule_MQData_ShowTable(XCHAR*** pppszTableName, int* pInt_ListCount);
+/********************************************************************
+函数名称：DBModule_MQData_GetLeftCount
+函数功能：获取剩余个数
+ 参数.一：lpszTableName
+  In/Out：In
+  类型：常量字符指针
+  可空：N
+  意思：输入表名称
+ 参数.二：nSerial
+  In/Out：In
+  类型：整数型
+  可空：N
+  意思：输入开始的序列号
+参数.三：pInt_Count
+  In/Out：Out
+  类型：整数型指针
+  可空：N
+  意思：输出统计信息
+返回值
+  类型：逻辑型
+  意思：是否成功
+备注：
+*********************************************************************/
+extern "C" bool DBModule_MQData_GetLeftCount(LPCXSTR lpszTableName, int nSerial, int* pInt_Count);
 /*************************************************************************
 						消息用户导出函数
 **************************************************************************/

XEngine_Release/XEngine_Config/XEngine_Config.json

@@ -273,122 +273,6 @@ bool CDBModule_MQData::DBModule_MQData_Modify(XENGINE_DBMESSAGEQUEUE* pSt_DBInfo
 	return true;
 }
 /********************************************************************
-函数名称：DBModule_MQData_List
-函数功能：枚举指定主题序列号后的数据
- 参数.一：lpszQueueName
-  In/Out：In
-  类型：常量字符指针
-  可空：N
-  意思：输入要处理的主题
- 参数.二：nSerial
-  In/Out：In
-  类型：整数型
-  可空：N
-  意思：输入主题序列号
- 参数.三：pppSt_DBMessage
-  In/Out：Out
-  类型：三级指针
-  可空：N
-  意思：输出数据队列信息
- 参数.四：pInt_ListCount
-  In/Out：Out
-  类型：整数型
-  可空：N
-  意思：输出数据队列大小
-返回值
-  类型：逻辑型
-  意思：是否成功
-备注：
-*********************************************************************/
-bool CDBModule_MQData::DBModule_MQData_List(LPCXSTR lpszQueueName, __int64x nSerial, XENGINE_DBMESSAGEQUEUE*** pppSt_DBMessage, int* pInt_ListCount)
-{
-	DBModule_IsErrorOccur = false;
-
-	if (NULL == lpszQueueName)
-	{
-		DBModule_IsErrorOccur = true;
-		DBModule_dwErrorCode = ERROR_XENGINE_MQCORE_DATABASE_PARAMENT;
-		return false;
-	}
-	//查询
-	XNETHANDLE xhTable = 0;
-	__int64u nllLine = 0;
-	__int64u nllRow = 0;
-
-	XCHAR tszSQLStatement[1024];
-	memset(tszSQLStatement, '\0', sizeof(tszSQLStatement));
-	//名称为,消息名为必填
-	_xstprintf(tszSQLStatement, _X("SELECT * FROM `%s` WHERE nQueueSerial >= %lld"), lpszQueueName, nSerial);
-	if (!DataBase_MySQL_ExecuteQuery(xhDBSQL, &xhTable, tszSQLStatement, &nllLine, &nllRow))
-	{
-		DBModule_IsErrorOccur = true;
-		DBModule_dwErrorCode = DataBase_GetLastError();
-		return false;
-	}
-	if (nllLine <= 0)
-	{
-		DBModule_IsErrorOccur = true;
-		DBModule_dwErrorCode = ERROR_XENGINE_MQCORE_DATABASE_EMPTY;
-		return false;
-	}
-	*pInt_ListCount = (int)nllLine;
-	BaseLib_OperatorMemory_Malloc((XPPPMEM)pppSt_DBMessage, (int)nllLine, sizeof(XENGINE_DBMESSAGEQUEUE));
-	for (__int64u i = 0; i < nllLine; i++)
-	{
-		XCHAR** pptszResult = DataBase_MySQL_GetResult(xhDBSQL, xhTable);
-		XLONG* pInt_Length = DataBase_MySQL_GetLength(xhDBSQL, xhTable);
-
-		int nPos = 1;
-		if (NULL != pptszResult[nPos])
-		{
-			_tcsxcpy((*pppSt_DBMessage)[i]->tszUserName, pptszResult[nPos]);
-		}
-		nPos++;
-		if (NULL != pptszResult[nPos])
-		{
-			_tcsxcpy((*pppSt_DBMessage)[i]->tszQueueName, pptszResult[nPos]);
-		}
-		nPos++;
-		if (NULL != pptszResult[nPos])
-		{
-			(*pppSt_DBMessage)[i]->nQueueSerial = _ttxoll(pptszResult[nPos]);
-		}
-		nPos++;
-		if (NULL != pptszResult[nPos])
-		{
-			_tcsxcpy((*pppSt_DBMessage)[i]->tszQueueLeftTime, pptszResult[nPos]);
-		}
-		nPos++;
-		if (NULL != pptszResult[nPos])
-		{
-			_tcsxcpy((*pppSt_DBMessage)[i]->tszQueuePublishTime, pptszResult[nPos]);
-		}
-		nPos++;
-		if (NULL != pptszResult[nPos])
-		{
-			(*pppSt_DBMessage)[i]->nMsgLen = pInt_Length[nPos];
-			memcpy((*pppSt_DBMessage)[i]->tszMsgBuffer, pptszResult[nPos], (*pppSt_DBMessage)[i]->nMsgLen);
-		}
-		nPos++;
-		if (NULL != pptszResult[nPos])
-		{
-			(*pppSt_DBMessage)[i]->byMsgType = _ttxoi(pptszResult[nPos]);
-		}
-		nPos++;
-		if (NULL != pptszResult[nPos])
-		{
-			(*pppSt_DBMessage)[i]->nMsgAttr = _ttxoi(pptszResult[nPos]);
-		}
-		nPos++;
-		if (NULL != pptszResult[nPos])
-		{
-			_tcsxcpy((*pppSt_DBMessage)[i]->tszQueueCreateTime, pptszResult[nPos]);
-		}
-	}
-	DataBase_MySQL_FreeResult(xhDBSQL, xhTable);
-	return true;
-}
-/********************************************************************
 函数名称：DBModule_MQData_GetSerial
 函数功能：获取序列号
  参数.一：lpszName
@@ -800,4 +684,67 @@ bool CDBModule_MQData::DBModule_MQData_ShowTable(XCHAR*** pppszTableName, int* p
 	}
 	DataBase_MySQL_FreeResult(xhDBSQL, xhTable);
 	return true;
+}
+/********************************************************************
+函数名称：DBModule_MQData_GetLeftCount
+函数功能：获取剩余个数
+ 参数.一：lpszTableName
+  In/Out：In
+  类型：常量字符指针
+  可空：N
+  意思：输入表名称
+ 参数.二：nSerial
+  In/Out：In
+  类型：整数型
+  可空：N
+  意思：输入开始的序列号
+参数.三：pInt_Count
+  In/Out：Out
+  类型：整数型指针
+  可空：N
+  意思：输出统计信息
+返回值
+  类型：逻辑型
+  意思：是否成功
+备注：
+*********************************************************************/
+bool CDBModule_MQData::DBModule_MQData_GetLeftCount(LPCXSTR lpszTableName, int nSerial, int* pInt_Count)
+{
+	DBModule_IsErrorOccur = false;
+
+	if (NULL == pInt_Count)
+	{
+		DBModule_IsErrorOccur = true;
+		DBModule_dwErrorCode = ERROR_XENGINE_MQCORE_DATABASE_PARAMENT;
+		return false;
+	}
+	//查询
+	XNETHANDLE xhTable = 0;
+	__int64u nllLine = 0;
+	__int64u nllRow = 0;
+
+	XCHAR tszSQLStatement[1024];
+	memset(tszSQLStatement, '\0', sizeof(tszSQLStatement));
+
+	_xstprintf(tszSQLStatement, _X("SELECT COUNT(*) FROM %s WHERE nQueueSerial > %d"), lpszTableName, nSerial);
+	if (!DataBase_MySQL_ExecuteQuery(xhDBSQL, &xhTable, tszSQLStatement, &nllLine, &nllRow))
+	{
+		DBModule_IsErrorOccur = true;
+		DBModule_dwErrorCode = DataBase_GetLastError();
+		return false;
+	}
+	if (nllLine <= 0)
+	{
+		DBModule_IsErrorOccur = true;
+		DBModule_dwErrorCode = ERROR_XENGINE_MQCORE_DATABASE_EMPTY;
+		return false;
+	}
+	XCHAR** pptszResult = DataBase_MySQL_GetResult(xhDBSQL, xhTable);
+
+	if (NULL != pptszResult[0])
+	{
+		*pInt_Count = _ttxoi(pptszResult[0]);
+	}
+	DataBase_MySQL_FreeResult(xhDBSQL, xhTable);
+	return true;
 }