91av视频/亚洲h视频/操亚洲美女/外国一级黄色毛片 - 国产三级三级三级三级

  • 大小: 19.97MB
    文件類型: .rar
    金幣: 1
    下載: 0 次
    發布日期: 2023-06-16
  • 語言: 其他
  • 標簽: 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個文件信息

評論

共有 條評論