C++实现MQTT服务端 代码

在C++中实现MQTT服务器通常需要使用第三方库，如`Paho MQTT C++ Client`或`RabbitMQ-CPP`等，因为C++标准库本身并不包含对MQTT协议的支持。下面是一个简单的基于`Paho MQTT`库的示例，展示了如何创建一个基本的MQTT服务器：

#include <mqtt/async_client.h>
#include <iostream>

class MqttServer {
public:
    MqttServer(const std::string& broker) : client_(broker) {}

    void start() {
        // 创建连接选项
        mqtt::connect_options connOpts;
        connOpts.set_clean_session(true); // 清除会话

        // 连接到MQTT broker
        client_.set_on_connect([](const mqtt::connect_result& result) {
            if (result.is_success()) {
                std::cout << "Connected to broker." << std::endl;
                // 开始接收消息
                client_.start_receiving();
            } else {
                std::cerr << "Failed to connect: " << result.error_code_str() << std::endl;
            }
        });

        client_.connect(connOpts);
    }

private:
    mqtt::async_client client_;
};

int main() {
    const std::string broker_address = "tcp://localhost:1883";
    MqttServer server(broker_address);
    server.start();

    try {
        // 等待事件循环结束
        mqtt::event_loop_instance()->run_forever();
    } catch (std::exception& e) {
        std::cerr << "Error occurred: " << e.what() << std::endl;
    }

    return 0;
}