#include?“mqtt.h“
#include?“global.h“
MQTTClient?g_client;
volatile?MQTTClient_deliveryToken?deliveredtoken;
bool?g_bcontent?=?true;

?//mutexQueue?g_OperationInfoque;

void?G2U（const?char*?gb2312?string?&strContent）
{
	int?len?=?MultiByteToWideChar（CP_ACP?0?gb2312?-1?NULL?0）;
	wchar_t*?wstr?=?new?wchar_t[len?+?1];
	memset（wstr?0?len?+?1）;
	MultiByteToWideChar（CP_ACP?0?gb2312?-1?wstr?len）;
	len?=?WideCharToMultiByte（CP_UTF8?0?wstr?-1?NULL?0?NULL?NULL）;
	char*?str?=?new?char[len?+?1];
	memset（str?0?len?+?1）;
	WideCharToMultiByte（CP_UTF8?0?wstr?-1?str?len?NULL?NULL）;
	if?（wstr）?delete[]?wstr;
	strContent?=?str;
	if?（str）?delete[]?str;
}

void?delivered（void?*context?MQTTClient_deliveryToken?dt）
{
	printf（?“Message?with?token?value?%d?delivery?confirmed\n“?dt?）;
	deliveredtoken?=?dt;
}

int?msgarrvd（void?*context?char?*topicName?int?topicLen?MQTTClient_message?*message）
{
	int?i;
	char*?payloadptr;
	//CLog::WriteLogFormat（“Message?arrived\n?topic:?%s\n“?topicName）;

	payloadptr?=?（char*）message->payload;
	if?（strcmp（payloadptr?DISCONNECT）?==?0）?{
		printf（“?\n?out!!“）;
		g_bcontent?=?false;
	}

	string?strTmpMsg?=?““;
	payloadptr?=?（char*）message->payload;
	for?（i?=?0;?i?payloadlen;?i++）
	{
		strTmpMsg?+=?（*payloadptr++）;
	}

	//string?strResult?=?““;
	//U2G（?strTmpMsg.c_str（）?strResult?）;
	//判斷處理topic

	MQTTClient_freeMessage（&message）;
	MQTTClient_free（topicName）;

	return?1;
}

void?connlost（void?*context?char?*cause）
{
	//CLog::WriteLogFormat（“Connection?lost!!?cause:?[%s]\n“?cause）;
	printf（“Connection?lost!!cause:?[%s]\n“?cause）;
	g_bcontent?=?false;
}

//*********************************************?線程?******************************************************
DWORD?WINAPI?doHandMessage（PVOID?lpParam）
{
	mqtt?*q?=?（mqtt*）lpParam;
	while?（true）
	{
		if?（g_OperationInfoque.size（）?>?0?&&?g_bcontent）
		{
			OPERATIONINFO?stOperationInfo;
			if?（!g_OperationInfoque.top（stOperationInfo））
			{
				//CLog::WriteLogFormat（“隊列取出失敗！\n“）;
				printf（“隊列取出失??！\n“）;
				break;
			}
			string?strJson?=?stOperationInfo.strJson;
			string?strTOPIC?=?stOperationInfo.strTOPIC;
			if?（q->publishMessage（strTOPIC?strJson.c_str（）））
			{
				g_OperationInfoque.pop（）;
			}
			else
			{
				g_bcontent?=?false;
			}
			Sleep（200）;
		}

	}
	return?0;
}

DWORD?WINAPI?MQTT_ReConnect（PVOID?lpParam）
{
	mqtt?*q?=?（mqtt*）lpParam;
	
	while?（true）
	{
		if?（!g_bcontent）
		{
			MQTTClient_destroy（&g_client）;
			if?（q->initMQTTconnect（））
			{
				g_bcontent?=?true;
			}
		}
		Sleep（1000）;
	}
	return?0;
}

mqtt::mqtt（）
{
	//----------------------------------------處理MQTT斷線重連------------------------------------------------------------
	HANDLE?hDoHandThread?=?CreateThread（NULL?0?doHandMessage?this?0?NULL）;
	Sleep（1000）;

	HANDLE?hMQTTReConnectThread?=?CreateThread（NULL?0?MQTT_ReConnect?this?0?N

?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----

?????文件?????274026??2021-06-24?17:04??MqttClass\Debug\mqtt.obj

?????文件?????????80??2021-06-24?17:04??MqttClass\Debug\MqttClass.log

?????文件?????289938??2021-06-24?16:33??MqttClass\Debug\MqttClass.obj

?????文件???????1398??2021-06-24?17:04??MqttClass\Debug\MqttClass.tlog\CL.command.1.tlog

?????文件??????90104??2021-06-24?17:04??MqttClass\Debug\MqttClass.tlog\CL.read.1.tlog

?????文件???????1126??2021-06-24?17:04??MqttClass\Debug\MqttClass.tlog\CL.write.1.tlog

?????文件???????1200??2021-06-24?17:04??MqttClass\Debug\MqttClass.tlog\link.command.1.tlog

?????文件???????3776??2021-06-24?17:04??MqttClass\Debug\MqttClass.tlog\link.read.1.tlog

?????文件????????452??2021-06-24?17:04??MqttClass\Debug\MqttClass.tlog\link.write.1.tlog

?????文件????????196??2021-06-24?17:04??MqttClass\Debug\MqttClass.tlog\MqttClass.lastbuildstate

?????文件?????551936??2021-06-24?17:04??MqttClass\Debug\vc141.idb

?????文件?????585728??2021-06-24?17:04??MqttClass\Debug\vc141.pdb

?????文件????????267??2021-06-24?16:28??MqttClass\global.h

?????文件??????89088??2019-05-29?16:47??MqttClass\lib\paho-mqtt3a.dll

?????文件???????9824??2020-06-01?16:53??MqttClass\lib\paho-mqtt3a.lib

?????文件??????77312??2018-02-21?05:11??MqttClass\lib\paho-mqtt3c.dll

?????文件??????11252??2020-06-01?16:55??MqttClass\lib\paho-mqtt3c.lib

?????文件??????15872??2019-05-29?16:47??MqttClass\lib\paho-mqttpp3.dll

?????文件????1080688??2019-05-29?16:47??MqttClass\lib\paho-mqttpp3.lib

?????文件???????5240??2021-06-24?17:03??MqttClass\mqtt.cpp

?????文件????????399??2021-06-24?16:00??MqttClass\mqtt.h

?????文件???????1118??2021-06-24?16:33??MqttClass\MqttClass.cpp

?????文件???????7982??2021-06-24?16:01??MqttClass\MqttClass.vcxproj

?????文件???????1529??2021-06-24?16:01??MqttClass\MqttClass.vcxproj.filters

?????文件????????165??2021-06-24?14:37??MqttClass\MqttClass.vcxproj.user

?????文件??????61062??2018-02-21?05:11??MqttClass\MQTTClient.h

?????文件??????10437??2018-02-21?05:11??MqttClass\MQTTClientPersistence.h

?????文件????????949??2020-09-28?10:16??MqttClass\queue.h

?????文件???????1441??2021-06-24?14:38??MqttClass.sln

?????目錄??????????0??2021-06-24?17:04??MqttClass\Debug\MqttClass.tlog

............此處省略6個文件信息