diff --git a/src/services/mqttService.js b/src/services/mqttService.js
new file mode 100644
index 0000000..08389f3
--- /dev/null
+++ b/src/services/mqttService.js
@@ -0,0 +1,17 @@
+import mqtt from 'mqtt';
+
+// Créer une instance de client MQTT
+const client = mqtt.connect('ws://localhost:9001');
+
+// Fonction pour publier un message sur un topic MQTT
+export function publishMessage(topic, message) {
+  client.publish(topic, message);
+}
+
+// Fonction pour s'abonner à un topic MQTT et écouter les messages entrants
+export function subscribeToTopic(topic, callback) {
+  client.subscribe(topic);
+  client.on('message', (receivedTopic, message) => {
+    callback(receivedTopic.toString(), message.toString());
+  });
+}