added:readme for exmaple

update:tcp example support binary

Author: xengine-qyt

XEngine_Apps/MQCore_TCPApp/MQCore_TCPApp.cpp

@@ -216,7 +216,13 @@ void MQ_Create()
 	memcpy(&st_XMQProtocol, tszMsgBuffer + sizeof(XENGINE_PROTOCOLHDR), sizeof(XENGINE_PROTOCOL_XMQ));
 }
 
-void MQ_Post(LPCXSTR lpszMsgBuffer)
+typedef struct
+{
+	XCHAR tszMsgBuffer[128];
+	int a;
+	int b;
+}XENGINE_SQLBINARY;
+void MQ_Post(LPCXSTR lpszMsgBuffer, int nType = 0)
 {
 	int nLen = 0;
 	XENGINE_PROTOCOLHDR st_ProtocolHdr;
@@ -230,20 +236,40 @@ void MQ_Post(LPCXSTR lpszMsgBuffer)
 	st_ProtocolHdr.wHeader = XENGIEN_COMMUNICATION_PACKET_PROTOCOL_HEADER;
 	st_ProtocolHdr.unOperatorType = ENUM_XENGINE_COMMUNICATION_PROTOCOL_TYPE_XMQ;
 	st_ProtocolHdr.unOperatorCode = XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_MQ_REQPOST;
-	st_ProtocolHdr.byVersion = ENUM_XENGINE_PROTOCOLHDR_PAYLOAD_TYPE_STRING;
 	st_ProtocolHdr.byIsReply = true;           //获得处理返回结果
 	st_ProtocolHdr.wTail = XENGIEN_COMMUNICATION_PACKET_PROTOCOL_TAIL;
 
 	st_XMQProtocol.nSerial = 0;          //序列号,0服务会自动处理
 	st_XMQProtocol.nKeepTime = -1;        //保存时间，单位秒，如果为0，获取一次后被抛弃。-1 永久存在，PacketKey不能为空
 	strcpy(st_XMQProtocol.tszMQKey, lpszKey);
 
-	st_ProtocolHdr.unPacketSize = sizeof(XENGINE_PROTOCOL_XMQ) + strlen(lpszMsgBuffer);
+	if (ENUM_XENGINE_PROTOCOLHDR_PAYLOAD_TYPE_BIN == nType)
+	{
+		XENGINE_SQLBINARY st_SQLBinary;
+		memset(&st_SQLBinary, '\0', sizeof(XENGINE_SQLBINARY));
 
-	nLen = sizeof(XENGINE_PROTOCOLHDR) + st_ProtocolHdr.unPacketSize;
-	memcpy(tszMsgBuffer, &st_ProtocolHdr, sizeof(XENGINE_PROTOCOLHDR));
-	memcpy(tszMsgBuffer + sizeof(XENGINE_PROTOCOLHDR), &st_XMQProtocol, sizeof(XENGINE_PROTOCOL_XMQ));
-	memcpy(tszMsgBuffer + sizeof(XENGINE_PROTOCOLHDR) + sizeof(XENGINE_PROTOCOL_XMQ), lpszMsgBuffer, strlen(lpszMsgBuffer));
+		st_SQLBinary.a = 1;
+		st_SQLBinary.b = 2;
+		strcpy(st_SQLBinary.tszMsgBuffer, "wdawandono0012d02d01d0j1");
+
+		st_ProtocolHdr.byVersion = ENUM_XENGINE_PROTOCOLHDR_PAYLOAD_TYPE_BIN;
+
+		st_ProtocolHdr.unPacketSize = sizeof(XENGINE_PROTOCOL_XMQ) + sizeof(XENGINE_SQLBINARY);
+		nLen = sizeof(XENGINE_PROTOCOLHDR) + st_ProtocolHdr.unPacketSize;
+		memcpy(tszMsgBuffer, &st_ProtocolHdr, sizeof(XENGINE_PROTOCOLHDR));
+		memcpy(tszMsgBuffer + sizeof(XENGINE_PROTOCOLHDR), &st_XMQProtocol, sizeof(XENGINE_PROTOCOL_XMQ));
+		memcpy(tszMsgBuffer + sizeof(XENGINE_PROTOCOLHDR) + sizeof(XENGINE_PROTOCOL_XMQ), &st_SQLBinary, sizeof(XENGINE_SQLBINARY));
+	}
+	else
+	{
+		st_ProtocolHdr.byVersion = ENUM_XENGINE_PROTOCOLHDR_PAYLOAD_TYPE_STRING;
+
+		st_ProtocolHdr.unPacketSize = sizeof(XENGINE_PROTOCOL_XMQ) + strlen(lpszMsgBuffer);
+		nLen = sizeof(XENGINE_PROTOCOLHDR) + st_ProtocolHdr.unPacketSize;
+		memcpy(tszMsgBuffer, &st_ProtocolHdr, sizeof(XENGINE_PROTOCOLHDR));
+		memcpy(tszMsgBuffer + sizeof(XENGINE_PROTOCOLHDR), &st_XMQProtocol, sizeof(XENGINE_PROTOCOL_XMQ));
+		memcpy(tszMsgBuffer + sizeof(XENGINE_PROTOCOLHDR) + sizeof(XENGINE_PROTOCOL_XMQ), lpszMsgBuffer, strlen(lpszMsgBuffer));
+	}
 
 	if (!XClient_TCPSelect_SendMsg(m_Socket, tszMsgBuffer, nLen))
 	{
@@ -263,7 +289,7 @@ void MQ_Post(LPCXSTR lpszMsgBuffer)
 	memcpy(&st_XMQProtocol, ptszMsgBuffer, sizeof(XENGINE_PROTOCOL_XMQ));
 	BaseLib_OperatorMemory_FreeCStyle((XPPMEM)&ptszMsgBuffer);
 }
-void MQ_Get()
+void MQ_Get(int nType = 0)
 {
 	int nLen = 0;
 	XENGINE_PROTOCOLHDR st_ProtocolHdr;
@@ -297,19 +323,29 @@ void MQ_Get()
 
 	while (true)
 	{
-		nLen = 2048;
-		memset(tszMsgBuffer, '\0', sizeof(tszMsgBuffer));
-		if (XClient_TCPSelect_RecvMsg(m_Socket, tszMsgBuffer, &nLen))
-		{
-			memset(&st_ProtocolHdr, '\0', sizeof(XENGINE_PROTOCOLHDR));
-			memset(&st_XMQProtocol, '\0', sizeof(XENGINE_PROTOCOL_XMQ));
+		nLen = 0;
+		XCHAR* ptszMsgBuffer;
 
-			memcpy(&st_ProtocolHdr, tszMsgBuffer, sizeof(XENGINE_PROTOCOLHDR));
-			memcpy(&st_XMQProtocol, tszMsgBuffer + sizeof(XENGINE_PROTOCOLHDR), sizeof(XENGINE_PROTOCOL_XMQ));
+		memset(&st_ProtocolHdr, '\0', sizeof(XENGINE_PROTOCOLHDR));
+		memset(&st_XMQProtocol, '\0', sizeof(XENGINE_PROTOCOL_XMQ));
+		if (XClient_TCPSelect_RecvPkt(m_Socket, &ptszMsgBuffer, &nLen, &st_ProtocolHdr))
+		{
+			memcpy(&st_XMQProtocol, ptszMsgBuffer, sizeof(XENGINE_PROTOCOL_XMQ));
 
 			if (0 == st_ProtocolHdr.wReserve)
 			{
-				_xtprintf("接受到数据,主题:%s,序列:%lld,长度：%d，内容：%s\n", st_XMQProtocol.tszMQKey, st_XMQProtocol.nSerial, st_ProtocolHdr.unPacketSize - sizeof(XENGINE_PROTOCOL_XMQ), tszMsgBuffer + sizeof(XENGINE_PROTOCOLHDR) + sizeof(XENGINE_PROTOCOL_XMQ));
+				if (ENUM_XENGINE_PROTOCOLHDR_PAYLOAD_TYPE_STRING == nType)
+				{
+					_xtprintf("接受到数据,主题:%s,序列:%lld,长度：%d，内容：%s\n", st_XMQProtocol.tszMQKey, st_XMQProtocol.nSerial, st_ProtocolHdr.unPacketSize - sizeof(XENGINE_PROTOCOL_XMQ), ptszMsgBuffer + sizeof(XENGINE_PROTOCOL_XMQ));
+				}
+				else
+				{
+					XENGINE_SQLBINARY st_SQLBinary;
+					memset(&st_SQLBinary, '\0', sizeof(XENGINE_SQLBINARY));
+
+					memcpy(&st_SQLBinary, ptszMsgBuffer + sizeof(XENGINE_PROTOCOL_XMQ), sizeof(XENGINE_SQLBINARY));
+					break;
+				}
 			}
 			else
 			{
@@ -451,7 +487,7 @@ void MQ_BindTopic()
 
 	st_ProtocolHdr.unPacketSize = sizeof(XENGINE_PROTOCOL_XMQ);
 
-	st_XMQProtocol.nSerial = 5; //设置为5开始读取
+	st_XMQProtocol.nSerial = 1; //设置为1开始读取
 	strcpy(st_XMQProtocol.tszMQKey, lpszKey);
 
 	nLen = sizeof(XENGINE_PROTOCOLHDR) + st_ProtocolHdr.unPacketSize;
@@ -536,15 +572,18 @@ int main(int argc, char** argv)
 	MQ_Register();
 	MQ_Authorize();
 	MQ_Create();
+	MQ_Post(NULL, ENUM_XENGINE_PROTOCOLHDR_PAYLOAD_TYPE_BIN);
+	MQ_BindTopic();
+	MQ_Get(ENUM_XENGINE_PROTOCOLHDR_PAYLOAD_TYPE_BIN);
+
 	for (int i = 0; i < 10; i++)
 	{
-		MQ_Post(lpszMsgBuffer);
+		MQ_Post(lpszMsgBuffer, ENUM_XENGINE_PROTOCOLHDR_PAYLOAD_TYPE_STRING);
 	}
 	MQ_GetNumber();
-	MQ_BindTopic();
-	MQ_Get();
-	MQ_Get();
-	MQ_Get();
+	MQ_Get(ENUM_XENGINE_PROTOCOLHDR_PAYLOAD_TYPE_STRING);
+	MQ_Get(ENUM_XENGINE_PROTOCOLHDR_PAYLOAD_TYPE_STRING);
+	MQ_Get(ENUM_XENGINE_PROTOCOLHDR_PAYLOAD_TYPE_STRING);
 	MQ_TimePublish();
 	MQ_DeleteTopic();
 	MQ_DeleteUser();

XEngine_Apps/README.md

@@ -0,0 +1,2 @@
+windows:use x86 debug mode complie by vs2022
+linux or macos:g++ command