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里面有初始化。