基于MQTT协议进行应用开发
来自:http://www.cnblogs.com/secondtononewe/p/6073089.html
官方协议有句如下的话来形容MQTT的设计思想:
“It is designed for connections with remote locations where a "small code footprint" is required or the network bandwidth is limited.”
- 可靠传输。MQTT可以保证消息可靠安全的传输,并可以与企业应用简易集成。
- 消息推送。支持消息实时通知、丰富的推送内容、灵活的Pub-Sub以及消息存储和过滤。
- 低带宽、低耗能、低成本。占用移动应用程序带宽小,并且带宽利用率高,耗电量较少。
因此MQTT被广泛应用于物联网。
源码位置,可下载时间最新的CODE:http://mosquitto.org/files/source/
mosquitto-1.4.9.tar.gz
mosquitto_connect_callback_set(mosq, my_connect_callback);
mosquitto_message_callback_set(mosq, my_message_callback);
其中my_connect_callback是mosquitto_loop_forever这个一直存在的循环函数在收到服务器传递回来CONNACK信息(见_mosquitto_handle_connack),则会被触发,用来呼叫mosquitto_subscribe完成订阅。
其中my_message_callback则是用于音箱端应用程序的开发,用来接收手机微信端传递过来的内容。与手机客户端定义交互的协议,用于控制音箱的推歌、上下首切换、音源切换、网络模式的切换、音量大小的改变等等。
交互的内容采用json包,因此需要进行json包的解析和封装。
正确完成音箱端的订阅,
注意设定好:
cfg.port = 1883;
cfg.topics[cfg.topic_count-1] = strdup(deviceName);
cfg.host = strdup(serverIp); //服务器地址
这里初始化了一个属于音箱端全局的mosq,可用它关联pub和sub;(pub和sub共用一个全局mosq即可,并不需要分别申请一个mosq)
音箱端部分,需要pub消息给手机微信端。采用mosquitto_pub_start发送消息。这个不同于sub是一个一直存在的线程,pub属于一次性,消息传递完毕即结束。
mosquitto_pub_start 中 全局变量pub_topic ,在mosquitto_sub_start里面有初始化。