在C++中使用MQTT是通過使用MQTT客戶端庫來實現的。這些庫提供了一組API以便連接到MQTT代理(broker)并與其通信。一些流行的MQTT客戶端庫包括Paho MQTT C++庫和Mosquitto MQTT C++庫。這些庫可以幫助您實現MQTT發布(publish)和訂閱(subscribe)功能,并與MQTT代理進行通信。
下面是一個簡單的使用Paho MQTT C++庫的示例代碼:
#include <iostream>
#include "mqtt/async_client.h"
int main() {
const std::string address = "tcp://iot.eclipse.org:1883";
const std::string client_id = "cpp_mqtt_client";
mqtt::async_client client(address, client_id);
mqtt::connect_options connOpts;
connOpts.set_keep_alive_interval(20);
connOpts.set_clean_session(true);
client.set_callback([](const mqtt::message_ptr msg) {
std::cout << "Received message: " << msg->get_payload_str() << std::endl;
});
try {
client.connect(connOpts)->wait();
client.subscribe("topic/test", 1)->wait();
client.publish("topic/test", "Hello, MQTT from C++")->wait();
} catch (const mqtt::exception& exc) {
std::cerr << "Error: " << exc.what() << std::endl;
}
client.disconnect()->wait();
return 0;
}
在這個示例中,我們使用Paho MQTT C++庫創建了一個MQTT客戶端,并連接到一個公共的MQTT代理(iot.eclipse.org)。然后我們訂閱了一個名為“topic/test”的主題,并發布了一條消息到這個主題。當收到來自代理的消息時,我們會在回調函數中打印出來。
您可以根據您的需求進一步定制和擴展這個示例代碼來實現更復雜的MQTT功能。