mqtt c++实现心跳

以下是MQTT C++实现心跳的示例代码：

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

class MyMqtt : public mosqpp::mosquittopp
{
public:
    MyMqtt(const char *id, const char *host, int port) : mosquittopp(id)
    {
        int keepalive = 60;
        connect(host, port, keepalive);
    }

    void on_connect(int rc) override
    {
        std::cout << "Connected with code " << rc << std::endl;
    }

    void on_disconnect(int rc) override
    {
        std::cout << "Disconnected with code " << rc << std::endl;
    }

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

    void on_publish(int mid) override
    {
        std::cout << "Message published with id " << mid << std::endl;
    }
};

int main()
{
    MyMqtt mqtt("client-id", "localhost", 1883);

    while (true)
    {
        mqtt.loop();
        mqtt.publish(nullptr, "heartbeat", 0, nullptr, 1, true);
        sleep(10);
    }

    return 0;
}

在这个示例中，我们使用了mosquittopp库来实现MQTT客户端。我们创建了一个名为MyMqtt的类，继承自mosquittopp类，并重写了on_connect、on_disconnect、on_message和on_publish方法。在构造函数中，我们连接到了MQTT服务器，并设置了心跳间隔为60秒。在主函数中，我们不断调用mqtt.loop()方法来处理MQTT消息，并使用mqtt.publish()方法发送心跳消息。我们设置了心跳间隔为10秒，可以根据需要进行调整。