mqtt 通信封装 可以直接处理订阅和发布的例子 大家下载学习啊 0积分

//mqtt主通信线程 class CThreadMqtt : public XOSThread { static int WolfMqtt_EventCB(void* cb_key, int event_type); static int WolfMqtt_DataCB(void* cb_key, char* topic, char* data, int size); public: CThreadMqtt(void); ~CThreadMqtt(void); void loadconfig(MQTT_PARAMS& config); int Start(void); int Stop(void); public: virtual int ThreadRun(int thread_idx);