基本信息

---

下载

   友情提示：（无需注册或充值，赞助后即可获取资源下载链接）

---

     嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：813200300

本次赞助数额为： 5 元　

支付宝支付

微信支付

   源码介绍

---

数据上传至mqtt服务器，或订阅mqtt 服务器消息来消费

mqtt 订阅消息和消费消息类实例运用

bool mqtt::initMQTTconnect()
{
MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;
int rc;

MQTTClient_create(&g_client, "tcp://192.168.206.21:1883"/*g_stConfigInfo.strMQTTServer.c_str()*/, "test"/*g_stConfigInfo.strClientID.c_str()*/, MQTTCLIENT_PERSISTENCE_NONE, NULL);
conn_opts.keepAliveInterval = 20;//86400;
conn_opts.cleansession = 1;
conn_opts.connectTimeout = 5;
conn_opts.retryInterval = 1;
conn_opts.MQTTVersion = 4;
//conn_opts.password = g_stConfigInfo.strMqttPasswd.c_str();
//conn_opts.username = g_stConfigInfo.strMqttUserName.c_str();

MQTTClient_setCallbacks(g_client, NULL, connlost, msgarrvd, delivered);

if ((rc = MQTTClient_connect(g_client, &conn_opts)) != MQTTCLIENT_SUCCESS)
{
//CLog::WriteLogFormat("Failed to connect, return code %d\n", rc);
g_bcontent = false;
return false;
}
g_bcontent = true;
rc = MQTTClient_subscribe(g_client, "pub_1/"/*g_stConfigInfo..c_str()*/, QOS );
if (!rc)
{
printf("===Subscribing to topic success!\n");
}
else
{
printf("===Subscribing to topic failed!\n");
}
//CLog::WriteLogFormat( "===Subscribing to topic %s\nfor client %s using QoS%d\n\n", g_stConfigInfo.strDeviceStatusTOPIC.c_str(), CLIENTID, QOS );
return true;
}