18 lines
535 B
JavaScript
18 lines
535 B
JavaScript
|
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());
|
||
|
|
});
|
||
|
|
}
|