Objets Connectes IoT

// Structure hierarchique des topics

maison/salon/temperature → 23.5

maison/salon/humidite → 45

maison/cuisine/temperature → 21.0

maison/jardin/arrosage → ON

// Wildcards pour s'abonner

maison/salon/+ → toutes les mesures du salon

maison/# → tout ce qui concerne la maison

+/+/temperature → toutes les temperatures

// ESP32 avec PubSubClient

#include <WiFi.h>

#include <PubSubClient.h>

const char* ssid = "MonWiFi";

const char* password = "********";

const char* mqtt_server = "broker.hivemq.com";

WiFiClient espClient;

PubSubClient client(espClient);

void callback(char* topic, byte* payload, unsigned int length) {

// Message recu sur un topic

Serial.print("Message [");

Serial.print(topic);

Serial.print("]: ");

for(int i = 0; i < length; i++) {

Serial.print((char)payload[i]);

}

}

void setup() {

WiFi.begin(ssid, password);

client.setServer(mqtt_server, 1883);

client.setCallback(callback);

client.connect("ESP32Client");

client.subscribe("maison/salon/commande");

}

void loop() {

client.loop();

// Publier temperature toutes les 10s

static unsigned long last = 0;

if(millis() - last > 10000) {

float temp = lireTemperature();

client.publish("maison/salon/temp", String(temp).c_str());

last = millis();

}

}

// Exemple : filtrage local avant envoi cloud

const float SEUIL_ALERTE = 30.0;

float dernierEnvoi = 0;

void loop() {

float temp = lireTemperature();

// Decision locale : alerte immediate

if(temp > SEUIL_ALERTE) {

activerVentilateur();

client.publish("alerte/temp", String(temp).c_str());

}

// Envoi cloud seulement si variation > 0.5°C

if(abs(temp - dernierEnvoi) > 0.5) {

client.publish("telemetrie/temp", String(temp).c_str());

dernierEnvoi = temp;

}

delay(1000);

}