Mqtt发布与订阅功能

包启Mqtt发布与订阅两个VS2010工程，实现了Mqtt的发布与订阅功能

#include 
#include “MQTTClient.h“
#include “stdio.h“
#include “stdlib.h“
#include “string.h“
#include 

#define ADDRESS     “tcp://168.1.3.10:1883“
#define CLIENTID    “ckPub“
#define TOPIC       “track“
#define PAYLOAD     “hello“
#define QOS         0
#define TIMEOUT     10000L

int main（int argc char *argv[]）
{
	QCoreApplication a（argc argv）;

	MQTTClient client;
	MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;
	MQTTClient_message pubmsg = MQTTClient_message_initializer;
	MQTTClient_deliveryToken token;
	int rc;

	MQTTClient_create（&client ADDRESS CLIENTID
		MQTTCLIENT_PERSISTENCE_NONE NULL）;
	conn_opts.keepAliveInterval = 20;
	conn_opts.cleansession = 1;

	if （（rc = MQTTClient_connect（client &conn_opts）） != MQTTCLIENT_SUCCESS）
	{
		printf（“Failed to connect return code %d\n“ rc）;
		exit（EXIT_FAILURE）;
	}

	
	
	int ch;
	int i = 0;
	do 
	{
		ch = getchar（）;
	} while （ch!=‘S‘ && ch != ‘s‘）;

	struct timeb tStart;
	ftime（&tStart）;
	long long iStart = 1000*tStart.time+tStart.millitm;
	
	while（i<100）
	{
		struct timeb tMsg;
		ftime（&tMsg）;
		long long iMsg = 1000*tMsg.time+tMsg.millitm;
		int m = i+1;
		char payload[100]={0};
		memcpy（payload&msizeof（int））;
		memcpy（payload+sizeof（int）&iMsgsizeof（long long））;
		pubmsg.payload = payload;
		pubmsg.payloadlen = 100;
		pubmsg.qos = QOS;
		pubmsg.retained = 0;

		MQTTClient_publishMessage（client TOPIC &pubmsg &token）;
		/*
		printf（“Waiting for up to %d seconds for publication of %s\n“
			“on topic %s for client with ClientID: %s\n“
			（int）（TIMEOUT/1000） PAYLOAD TOPIC CLIENTID）;
		*/	
		rc = MQTTClient_waitForCompletion（client token TIMEOUT）;
		//printf（“Message with delivery token %d delivered\n“ token）;
		i++;
	}
	struct timeb tEnd;
	ftime（&tEnd）;
	long long iEnd = 1000*tEnd.time+tEnd.millitm;
	printf（“Start:%lld msEnd:%lld msSpend:%lld ms\n“iStartiEndiEnd-iStart）;

	//MQTTClient_disconnect（client 10000）;
	//MQTTClient_destroy（&client）;

	return a.exec（）;
}

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----

     文件   32636928  2018-06-09 17:00  MqttPubTest\ipch\mqttpubtest-d1494133\mqttpubtest-4d420859.ipch

     文件          2  2018-06-09 17:02  MqttPubTest\MqttPubTest\Debug\cl.command.1.tlog

     文件          2  2018-06-09 17:02  MqttPubTest\MqttPubTest\Debug\cl.read.1.tlog

     文件          2  2018-06-09 17:02  MqttPubTest\MqttPubTest\Debug\cl.write.1.tlog

     文件       1059  2018-06-09 17:02  MqttPubTest\MqttPubTest\Debug\MqttPubTest.Build.CppClean.log

     文件         42  2018-06-09 17:02  MqttPubTest\MqttPubTest\Debug\MqttPubTest.lastbuildstate

     文件       1155  2018-06-09 17:02  MqttPubTest\MqttPubTest\Debug\MqttPubTest.log

     文件          0  2018-06-09 17:02  MqttPubTest\MqttPubTest\Debug\MqttPubTest.unsuccessfulbuild

     文件       2117  2018-06-09 17:00  MqttPubTest\MqttPubTest\main.cpp

     文件      59522  2017-03-28 15:22  MqttPubTest\MqttPubTest\MQTTClient.h

     文件      10437  2017-03-28 15:22  MqttPubTest\MqttPubTest\MQTTClientPersistence.h

     文件       5706  2017-08-05 11:43  MqttPubTest\MqttPubTest\MqttPubTest.vcxproj

     文件       1325  2017-08-05 11:43  MqttPubTest\MqttPubTest\MqttPubTest.vcxproj.filters

     文件        504  2017-08-05 11:42  MqttPubTest\MqttPubTest\MqttPubTest.vcxproj.user

     文件     118807  2017-08-04 15:17  MqttPubTest\MqttPubTest\paho-mqtt3c.dll

     文件       7258  2017-07-20 17:37  MqttPubTest\MqttPubTest\paho-mqtt3c.lib

     文件       8500  2017-03-28 15:22  MqttPubTest\MqttPubTest\paho_c_pub.c

     文件       7701  2017-03-28 15:22  MqttPubTest\MqttPubTest\paho_c_sub.c

     文件   14635008  2018-06-09 17:02  MqttPubTest\MqttPubTest.sdf

     文件        900  2017-08-05 11:37  MqttPubTest\MqttPubTest.sln

    ..A..H.     13824  2018-06-09 17:02  MqttPubTest\MqttPubTest.suo

     文件   30146560  2018-06-09 17:19  MqttSubTest\ipch\mqttsubtest-3b69d27c\mqttsubtest-18dfb116.ipch

     文件   32636928  2018-06-09 17:17  MqttSubTest\ipch\mqttsubtest-3b69d27c\mqttsubtest-dd58281c.ipch

     文件          2  2018-06-09 17:18  MqttSubTest\MqttSubTest\Debug\cl.command.1.tlog

     文件          2  2018-06-09 17:18  MqttSubTest\MqttSubTest\Debug\cl.read.1.tlog

     文件          2  2018-06-09 17:18  MqttSubTest\MqttSubTest\Debug\cl.write.1.tlog

     文件        151  2018-06-09 17:18  MqttSubTest\MqttSubTest\Debug\MqttSubTest.Build.CppClean.log

     文件         42  2018-06-09 17:18  MqttSubTest\MqttSubTest\Debug\MqttSubTest.lastbuildstate

     文件       1035  2018-06-09 17:18  MqttSubTest\MqttSubTest\Debug\MqttSubTest.log

     文件          0  2018-06-09 17:18  MqttSubTest\MqttSubTest\Debug\MqttSubTest.unsuccessfulbuild

............此处省略39个文件信息