mosquitto简单封装

#include "MqttProxy.h" #include <IceUtil/Time.h> #include <stdio.h> MqttProxy::MqttProxy(const char* clientID) : mosqpp::mosquittopp(clientID, false), firstConn_(false) { } MqttProxy::~MqttProxy() { } void MqttProxy::init(const char *host, int port, int keepalive, const char* title) { brokerHost_ = host; brokerPort_ = port; brokerKeepalive_ = keepalive; title_ = title; } bool MqttProxy::start() { if (firstConn_) { reconnect(); return true; } int ret = connect(brokerHost_.c_str(), brokerPort_, brokerKeepalive_); if (ret != 0) { printf("MqttProxy::start-->connect(%s:%d) error:%s", mosqpp::strerror(ret)); return false; } firstConn_ = true; return true; } void MqttProxy::stop() { //disconnect(); } std::string MqttProxy::get_error(int ret) { return mosqpp::strerror(ret); } void MqttProxy::on_connect(int rc) { printf("MqttProxy::on_connect:%s", get_error(rc).c_str()); subscribe(NULL, title_.c_str(), 2); } void MqttProxy::on_disconnect(int rc) { LOG_ERROR("MqttProxy::on_disconnect:%s", get_error(rc).c_str()); unsubscribe(NULL, title_.c_str()); } void MqttProxy::on_publish(int mid) { printf("MqttProxy::on_publish-->mid:%d", mid); } void MqttProxy::on_message(const struct mosquitto_message *message) { if (message == NULL || message->payloadlen <= 0) { printf("MqttProxy::on_message:len is null\n"); return; } LOG_DEBUG("MqttProxy::on_message-->mid[%d], topic[%s], payload[%d]", message->mid, message->topic, message->payloadlen); } void MqttProxy::on_subscribe(int mid, int qos_count, const int *granted_qos) { LOG_DEBUG("MqttProxy::on_subscribe-->mid[%d], qos[%d], granted_qos[%d]", mid, qos_count, granted_qos); } void MqttProxy::on_unsubscribe(int mid) { printf("MqttProxy::on_unsubscribe-->mid[%d]\n", mid); } void MqttProxy::on_log(int level, const char *str) { printf("MqttProxy::on_log-->mid[%d], [%s]\n", level, str); } void MqttProxy::on_error() { }