modify:example

Author: xengine-qyt

XEngine_Apps/MQCore_HTTPApp/MQCore_HTTPApp.cpp

@@ -22,6 +22,53 @@
 //VS2022 Debug x86 Compile
 //g++ -std=c++17 -Wall -g MQCore_HTTPApp.cpp -o MQCore_HTTPApp.exe -lXEngine_BaseLib -lXClient_APIHelp
 __int64x xhToken = 0;
+
+//获取未读消息
+void MQ_GetUNRead()
+{
+	LPCXSTR lpszPostUrl = _X("http://127.0.0.1:5202/api?function=unreadmsg");
+
+	Json::Value st_JsonRoot;
+	Json::Value st_JsonObject;
+
+	st_JsonObject["tszMQUsr"] = "123123aa";
+	st_JsonObject["tszMQKey"] = "XEngine_MSGKeyName";
+	st_JsonRoot["xhToken"] = xhToken;
+	st_JsonRoot["Object"] = st_JsonObject; 
+
+	int nLen = 0;
+	XCHAR* ptszMsgBody = NULL;
+	if (!APIClient_Http_Request(_X("POST"), lpszPostUrl, st_JsonRoot.toStyledString().c_str(), NULL, &ptszMsgBody, &nLen))
+	{
+		_xtprintf("发送投递失败！\n");
+		return;
+	}
+	_xtprintf("MQ_GetUNRead:%s\n", ptszMsgBody);
+	BaseLib_Memory_FreeCStyle((XPPMEM)&ptszMsgBody);
+}
+void MQ_DelMsg()
+{
+	LPCXSTR lpszPostUrl = _X("http://127.0.0.1:5202/api?function=deletemsg");
+
+	Json::Value st_JsonRoot;
+	Json::Value st_JsonObject;
+
+	st_JsonObject["nSerial"] = 1;
+	st_JsonObject["tszMQKey"] = "XEngine_MSGKeyName";
+	st_JsonRoot["xhToken"] = xhToken;
+	st_JsonRoot["Object"] = st_JsonObject;
+
+	int nLen = 0;
+	XCHAR* ptszMsgBody = NULL;
+	if (!APIClient_Http_Request(_X("POST"), lpszPostUrl, st_JsonRoot.toStyledString().c_str(), NULL, &ptszMsgBody, &nLen))
+	{
+		_xtprintf("发送投递失败！\n");
+		return;
+	}
+	_xtprintf("MQ_DelMsg:%s\n", ptszMsgBody);
+	BaseLib_Memory_FreeCStyle((XPPMEM)&ptszMsgBody);
+}
+
 void MQ_UserRegister()
 {
 	LPCXSTR lpszPostUrl = _X("http://127.0.0.1:5202/api?function=register");
@@ -71,7 +118,7 @@ void MQ_UserLogin()
 }
 void MQ_UserDelete()
 {
-	LPCXSTR lpszPostUrl = _X("http://127.0.0.1:5202/api?function=deluser");
+	LPCXSTR lpszPostUrl = _X("http://127.0.0.1:5202/api?function=deleteuser");
 
 	Json::Value st_JsonRoot;
 	Json::Value st_JsonUser;
@@ -132,7 +179,32 @@ void MQ_TopicCreate()
 	Json::Value st_JsonRoot;
 	Json::Value st_JsonObject;
 
-	st_JsonObject["name"] = "topictest";
+	st_JsonObject["tszMQUsr"] = "123123aa";
+	st_JsonObject["tszMQKey"] = "topictest";
+
+	st_JsonRoot["xhToken"] = xhToken;
+	st_JsonRoot["Object"] = st_JsonObject;
+
+	int nLen = 0;
+	XCHAR* ptszMsgBody = NULL;
+	if (!APIClient_Http_Request(_X("POST"), lpszPostUrl, st_JsonRoot.toStyledString().c_str(), NULL, &ptszMsgBody, &nLen))
+	{
+		_xtprintf("发送投递失败！\n");
+		return;
+	}
+	_xtprintf("MQ_TopicCreate:%s\n", ptszMsgBody);
+	BaseLib_Memory_FreeCStyle((XPPMEM)&ptszMsgBody);
+}
+void MQ_TopicModify()
+{
+	LPCXSTR lpszPostUrl = _X("http://127.0.0.1:5202/api?function=modifytopic");
+
+	Json::Value st_JsonRoot;
+	Json::Value st_JsonObject;
+
+	st_JsonObject["tszMQUsr"] = "123123aa";
+	st_JsonObject["tszSrcTopic"] = "topictest";
+	st_JsonObject["tszDstTopic"] = "topic2test";
 
 	st_JsonRoot["xhToken"] = xhToken;
 	st_JsonRoot["Object"] = st_JsonObject;
@@ -147,14 +219,16 @@ void MQ_TopicCreate()
 	_xtprintf("MQ_TopicCreate:%s\n", ptszMsgBody);
 	BaseLib_Memory_FreeCStyle((XPPMEM)&ptszMsgBody);
 }
+
 void MQ_TopicDelete()
 {
 	LPCXSTR lpszPostUrl = _X("http://127.0.0.1:5202/api?function=deletetopic");
 
 	Json::Value st_JsonRoot;
 	Json::Value st_JsonObject;
 
-	st_JsonObject["name"] = "topictest";
+	st_JsonObject["tszMQUsr"] = "123123aa";
+	st_JsonObject["tszMQKey"] = "topic2test";
 
 	st_JsonRoot["xhToken"] = xhToken;
 	st_JsonRoot["Object"] = st_JsonObject;
@@ -169,6 +243,49 @@ void MQ_TopicDelete()
 	_xtprintf("MQ_TopicDelete:%s\n", ptszMsgBody);
 	BaseLib_Memory_FreeCStyle((XPPMEM)&ptszMsgBody);
 }
+void MQ_GetTopic()
+{
+	LPCXSTR lpszPostUrl = _X("http://127.0.0.1:5202/api?function=gettopic");
+
+	Json::Value st_JsonRoot;
+	Json::Value st_JsonObject;
+
+	st_JsonRoot["xhToken"] = xhToken;
+	st_JsonObject["tszMQKey"] = "topictest";
+	st_JsonRoot["Object"] = st_JsonObject;
+
+	int nLen = 0;
+	XCHAR* ptszMsgBody = NULL;
+	if (!APIClient_Http_Request(_X("POST"), lpszPostUrl, st_JsonRoot.toStyledString().c_str(), NULL, &ptszMsgBody, &nLen))
+	{
+		_xtprintf("发送投递失败！\n");
+		return;
+	}
+	_xtprintf("MQ_GetTopic:%s\n", ptszMsgBody);
+	BaseLib_Memory_FreeCStyle((XPPMEM)&ptszMsgBody);
+}
+void MQ_GetNumber()
+{
+	LPCXSTR lpszPostUrl = _X("http://127.0.0.1:5202/api?function=getnumber");
+
+	Json::Value st_JsonRoot;
+	Json::Value st_JsonObject;
+
+	st_JsonObject["nKeepTime"] = 1;
+	st_JsonObject["tszMQKey"] = "XEngine_CommKey";
+	st_JsonRoot["xhToken"] = xhToken;
+	st_JsonRoot["Object"] = st_JsonObject;
+
+	int nLen = 0;
+	XCHAR* ptszMsgBody = NULL;
+	if (!APIClient_Http_Request(_X("POST"), lpszPostUrl, st_JsonRoot.toStyledString().c_str(), NULL, &ptszMsgBody, &nLen))
+	{
+		_xtprintf("发送投递失败！\n");
+		return;
+	}
+	_xtprintf("MQ_GetNumber:%s\n", ptszMsgBody);
+	BaseLib_Memory_FreeCStyle((XPPMEM)&ptszMsgBody);
+}
 void MQ_GetTopicList()
 {
 	LPCXSTR lpszPostUrl = _X("http://127.0.0.1:5202/api?function=getlist");
@@ -196,12 +313,17 @@ int main()
 
 	MQ_UserRegister();
 	MQ_UserLogin();
+	MQ_GetUNRead();
 	MQ_GetUserList();
 	MQ_GetOnlineList();
 	MQ_TopicCreate();
+	MQ_GetTopic();
+	MQ_GetNumber();
 	MQ_GetTopicList();
+	MQ_TopicModify();
 	MQ_TopicDelete();
 	MQ_UserDelete();
+
 #ifdef _MSC_BUILD
 	WSACleanup();
 #endif