PHP 및 MQTT를 사용하여 원격 온도 모니터링 및 제어를 구현하는 단계

#include  #include  const char* ssid = "your_SSID"; const char* password = "your_PASSWORD"; const char* mqtt_server = "MQTT_SERVER_IP"; const char* topic = "temperature"; WiFiClient espClient; phpMQTT mqtt; float temperature = 0; void setup_wifi() { delay(10); // We start by connecting to a WiFi network Serial.println(); Serial.print("Connecting to "); Serial.println(ssid); WiFi.begin(ssid, password); while (WiFi.status() != WL_CONNECTED) { delay(500); Serial.print("."); } Serial.println(""); Serial.println("WiFi connected"); Serial.println("IP address: "); Serial.println(WiFi.localIP()); } void callback(char* topic, byte* payload, unsigned int length) { // handle incoming MQTT messages here } void reconnect() { // Loop until we're reconnected while (!mqtt.connected()) { Serial.print("Attempting MQTT connection..."); // Attempt to connect if (mqtt.connect("ESP8266Client")) { Serial.println("connected"); mqtt.subscribe(topic); } else { Serial.print("failed, rc="); Serial.print(mqtt.state()); Serial.println(" try again in 5 seconds"); // Wait 5 seconds before retrying delay(5000); } } } void setup() { Serial.begin(115200); setup_wifi(); mqtt.begin(mqtt_server, 1883, espClient); mqtt.onMessage(callback); } void loop() { if (!mqtt.connected()) { reconnect(); } mqtt.loop(); // simulate reading temperature from sensor temperature = random(20, 40); // convert temperature to string for MQTT publishing char tmp[10]; sprintf(tmp, "%.2f", temperature); // publish temperature to MQTT topic mqtt.publish(topic, tmp); delay(2000); }

connect(true, NULL, $mqtt_user, $mqtt_password)){ exit(1); } $topics[$mqtt_topic] = array("qos"=>0, "function"=>"receiveTemperature"); $mqtt->subscribe($topics, 0); while($mqtt->proc()){ } $mqtt->close(); function receiveTemperature($topic, $payload){ // handle incoming temperature data here $temperature = floatval($payload); // do something with the temperature data, such as storing it in a database or triggering a notification } ?>