Module permettant gérer la connexion MQTT
Permet une seule connexion mqtt pour tous les composants de l'app
This commit is contained in:
parent
8367f5ac5e
commit
77f76ecc64
17
src/services/mqttService.js
Normal file
17
src/services/mqttService.js
Normal file
@ -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());
|
||||
});
|
||||
}
|
Loading…
Reference in New Issue
Block a user