C++开发MQTT实例代码分享

int main(int argc, char* argv[])
{
    sample_mem_persistence persist;
    mqtt::client cli(ADDRESS, CLIENT_ID, &persist);

    callback cb;
    cli.set_callback(cb);

    auto connOpts = mqtt::connect_options_builder()
        .keep_alive_interval(20);
        .clean_session()
        .finalize();

    try {
        cli.connect(connOpts);

        // First use a message pointer.

        mqtt::message_ptr pubmsg = mqtt::make_message(PAYLOAD1);
        pubmsg->set_qos(QOS);
        cli.publish(TOPIC, pubmsg);

        // Now try with itemized publish.

        cli.publish(TOPIC, PAYLOAD2, strlen(PAYLOAD2)+1, 0, false);

        // Disconnect

        cli.disconnect();
    }
    catch (const mqtt::persistence_exception& exc) {
        cerr << "Persistence Error: " << exc.what() << " ["
            << exc.get_reason_code() << "]" << endl;
        return 1;
    }
    catch (const mqtt::exception& exc) {
        cerr << "Error: " << exc.what() << " ["
            << exc.get_reason_code() << "]" << endl;
        return 1;
    }

    return 0;
}

#include <iostream>
#include <mosquittopp.h>

class MyMqttClient : public mosqpp::mosquittopp {
public:
    MyMqttClient(const char* id) : mosqpp::mosquittopp(id) {}

    void on_connect(int rc) override {
        if (rc == 0) {
            std::cout << "Connected to MQTT broker" << std::endl;
            subscribe(NULL, "test/topic", 1);
        } else {
            std::cerr << "Failed to connect to MQTT broker" << std::endl;
        }
    }

    void on_message(const struct mosquitto_message* message) override {
        std::cout << "Received message: " << message->payloadlen << " bytes" << std::endl;
        std::cout << "Payload: " << static_cast<char*>(message->payload) << std::endl;
    }
};

int main() {
    MyMqttClient client("cpp_client");
    client.connect("localhost", 1883, 60);
    client.loop_forever();
    return 0;
}

#include <boost/mqtt5/mqtt_client.hpp>
#include <boost/mqtt5/types.hpp>
#include <boost/asio/io_context.hpp>
#include <boost/asio/detached.hpp>
#include <boost/asio/ip/tcp.hpp>
#include <iostream>
int main() {
    boost::asio::io_context ioc;
    boost::mqtt5::mqtt_client<boost::asio::ip::tcp::socket> c(ioc);
    c.brokers("<your-mqtt-broker>", 1883)
        .credentials("<your-client-id>", "<client-username>", "<client-pwd>")
        .async_run(boost::asio::detached);
    c.async_publish<boost::mqtt5::qos_e::at_most_once>(
        "<topic>", "Hello world!",
        boost::mqtt5::retain_e::no, boost::mqtt5::publish_props {},
        [&c](boost::mqtt5::error_code ec) {
            std::cout << ec.message() << std::endl;
            c.async_disconnect(boost::asio::detached); // disconnect and close the Client
        }
    );
    ioc.run();
}