linux下用c++向mosuitto发布json数据

您可以使用以下步骤在Linux下使用C++向Mosquitto发布JSON数据：

1. 安装Mosquitto

首先，您需要安装Mosquitto MQTT Broker。您可以使用以下命令在Ubuntu上安装Mosquitto：

sudo apt-get install mosquitto

2. 安装MQTT C++库

接下来，您需要安装MQTT C++库。您可以使用以下命令在Ubuntu上安装Paho MQTT C++库：

sudo apt-get install libpaho-mqtt-dev

3. 编写C++程序

接下来，您可以编写一个简单的C++程序来发布JSON数据。以下是一个示例程序：

#include <iostream>
#include <cstring>
#include <cstdlib>
#include <cstdio>
#include "mqtt/async_client.h"
#include "json/json.h"

using namespace std;

const string ADDRESS("tcp://localhost:1883");
const string CLIENTID("SamplePublisher");
const string TOPIC("testtopic");
const int QOS = 1;
const int TIMEOUT = 10000L;

class SamplePublisher : public virtual mqtt::callback,
                        public virtual mqtt::iaction_listener {
    mqtt::async_client* client;
    mqtt::connect_options connOpts;
    mqtt::message_ptr pubmsg;

public:
    SamplePublisher(const std::string& address, const std::string& client_id) :
        connOpts(), client(nullptr), pubmsg(nullptr) {
        connOpts.set_keep_alive_interval(20);
        connOpts.set_clean_session(true);
        client = new mqtt::async_client(address, client_id);
        client->set_callback(*this);
    }

    ~SamplePublisher() {
        delete client;
    }

    void start() {
        try {
            client->connect(connOpts, nullptr, *this)->wait();
        }
        catch (const mqtt::exception& exc) {
            cerr << "Error: " << exc.what() << endl;
        }
    }

    void stop() {
        try {
            client->disconnect()->wait();
        }
        catch (const mqtt::exception& exc) {
            cerr << "Error: " << exc.what() << endl;
        }
    }

    void send_message(const std::string& message) {
        pubmsg = mqtt::make_message(TOPIC, message);
        pubmsg->set_qos(QOS);
        client->publish(pubmsg)->wait_for(TIMEOUT);
    }

    void connection_lost(const std::string& cause) override {
        cerr << "Connection lost: " << cause << endl;
        if (!cause.empty()) {
            start();
        }
    }

    void delivery_complete(mqtt::delivery_token_ptr tok) override {
        cerr << "Delivery complete for token: " << (tok ? tok->get_message_id() : -1) << endl;
    }

    void connected(const std::string& cause) override {
        cout << "Connected successfully" << endl;
    }
};

int main(int argc, char* argv[]) {
    SamplePublisher publisher(ADDRESS, CLIENTID);
    publisher.start();

    // Create JSON object
    Json::Value root;
    root["name"] = "John";
    root["age"] = 30;
    root["city"] = "New York";

    // Convert JSON object to string
    Json::FastWriter writer;
    std::string message = writer.write(root);

    // Publish message
    publisher.send_message(message);

    publisher.stop();
    return 0;
}

在此示例程序中，我们使用了Paho MQTT C++库来建立与Mosquitto的连接。我们创建了一个名为SamplePublisher的类，它实现了mqtt::callback和mqtt::iaction_listener接口。在start()方法中，我们使用connect()方法连接到Mosquitto。在send_message()方法中，我们使用publish()方法发布JSON消息。在main()函数中，我们创建了一个JSON对象，并将其转换为字符串，然后使用SamplePublisher类的send_message()方法将其发布到Mosquitto。

4. 编译程序

最后，您可以使用以下命令编译程序：

g++ -std=c++11 -I/usr/include/jsoncpp main.cpp -lpaho-mqtt3a -lpaho-mqtt3as -o mqtt_publisher

在此命令中，我们使用了-I选项来指定JSON C++库的头文件路径，-lpaho-mqtt3a和-lpaho-mqtt3as选项来指定Paho MQTT C++库的链接库。

5. 运行程序

运行编译后的程序：

./mqtt_publisher

现在，您已经成功地使用C++向Mosquitto发布JSON数据。