c++ mosquitto 发布订阅 类封装

在 C++ 中，Mosquitto 是一个轻量级的 MQTT（Message Queuing Telemetry Transport，消息队列遥测传输协议）客户端库，常用于物联网(IoT)和实时数据推送的应用中。如果你想将 Mosquitto 的发布/订阅功能封装成一个类，你可以这样做：

首先，你需要包含必要的头文件并初始化 Mosquitto 库：

#include "mosquittopp.h"

然后创建一个名为 `MqttPublisher` 或 `MqttSubscriber` 的类，它会包含订阅者或发布者的功能：

**发布者（Publisher）示例：**

class MqttPublisher {
public:
    MqttPublisher(const std::string& broker_address, int port)
        : client_(new Mosquitto("publisher")) {
        connect_to_broker(broker_address, port);
    }

    ~MqttPublisher() {
        if (client_->is_connected()) {
            client_->disconnect();
        }
        delete client_;
    }

private:
    void on_connect(int rc) {
        if (rc == MOSQ_ERR_SUCCESS) {
            client_->subscribe("$SYS/#"); // 订阅主题前缀
        } else {
            handle_connection_error(rc);
        }
    }

    void publish_message(const std::string& topic, const std::string& message) {
        client_->publish(topic, message.c_str(), QoS::AtLeastOnce);
    }

private:
    Mosquitto* client_ = nullptr;
    // 其他辅助函数...
};

**订阅者（Subscriber）示例：**

class MqttSubscriber {
public:
    MqttSubscriber(const std::string& broker_address, int port, const std::string& subscription_topic)
        : client_(new Mosquitto("subscriber")) {
        connect_to_broker(broker_address, port);
        subscribe(subscription_topic);
    }

    ~MqttSubscriber() {
        if (client_->is_connected()) {
            client_->unsubscribe(subscription_topic); // 取消订阅
            client_->disconnect();
        }
        delete client_;
    }

private:
    void on_message(const std::string& topic, const std::string& message) {
        process_received_message(topic, message);
    }

private:
    void subscribe(const std::string& topic) {
        client_->subscribe(topic);
    }

private:
    Mosquitto* client_ = nullptr;
    // 其他辅助函数...
};

记得处理连接错误、消息接收等事件，并提供相应的回调函数。