paho.mqtt.embedded-c c++实现mqtt客户端

paho.mqtt.embedded-c是一个C语言实现的MQTT客户端库，它提供了MQTT协议的完整实现，可以运行在嵌入式系统中。如果你需要在C++项目中使用MQTT客户端，可以使用paho.mqtt.embedded-c库的C++封装，也就是paho.mqtt.cpp库。

paho.mqtt.cpp库是一个基于paho.mqtt.embedded-c库的C++封装，它提供了更加易用的C++ API，使得在C++项目中使用MQTT更加方便。

下面是一个使用paho.mqtt.cpp库实现MQTT客户端的示例代码：

#include <cstdlib>
#include <iostream>
#include <cstring>
#include <chrono>
#include <thread>
#include "mqtt/async_client.h"

const std::string SERVER_ADDRESS("tcp://localhost:1883");
const std::string CLIENT_ID("paho_cpp_async_subcribe");
const std::string TOPIC("hello");

class callback : public virtual mqtt::callback
{
public:
    virtual void connection_lost(const std::string& cause) override
    {
        std::cout << "Connection lost: " << cause << std::endl;
    }

    virtual void message_arrived(mqtt::const_message_ptr msg) override
    {
        std::cout << "Message arrived" << std::endl;
        std::cout << "Topic: " << msg->get_topic() << std::endl;
        std::cout << "Payload: " << msg->to_string() << std::endl;
    }

    virtual void delivery_complete(mqtt::delivery_token_ptr token) override
    {
        std::cout << "Delivery complete" << std::endl;
    }
};

int main(int argc, char* argv[])
{
    mqtt::async_client client(SERVER_ADDRESS, CLIENT_ID);

    callback cb;
    client.set_callback(cb);

    mqtt::connect_options conn_opts;
    conn_opts.set_keep_alive_interval(20);
    conn_opts.set_clean_session(true);

    std::cout << "Connecting to the MQTT server..." << std::flush;
    try {
        mqtt::token_ptr conntok = client.connect(conn_opts);
        conntok->wait();
        std::cout << "OK" << std::endl;
    }
    catch (const mqtt::exception& exc) {
        std::cerr << "\nERROR: Unable to connect to MQTT server: " << exc.what() << std::endl;
        return 1;
    }

    mqtt::token_ptr subtok = client.subscribe(TOPIC, 0);
    subtok->wait();

    std::cout << "Subscribed to topic: " << TOPIC << std::endl;

    while (true) {
        std::this_thread::sleep_for(std::chrono::seconds(1));
    }

    client.unsubscribe(TOPIC)->wait();
    client.disconnect()->wait();

    return 0;
}

在这个示例代码中，我们使用了paho.mqtt.cpp库来连接到MQTT服务器，订阅一个主题，然后等待消息的到来。当消息到来时，我们会打印出来消息的主题和内容。

如果你需要在C++项目中使用MQTT客户端，paho.mqtt.cpp库会是一个不错的选择。