Notieren Sie die Schritte zur Verwendung des MQTT-Servers, um eine sofortige Kommunikation in Vue zu realisieren

npm installiere mqtt --save

importiere mqtt von „mqtt“

Kunde: {}

  //Mit dem Server verbinden connect() {
      let Optionen = {
        Benutzername: "xxx",
        Passwort: "xxxx",
        cleanSession : falsch,
        keepAlive:60,
        clientId: 'mqttjs_' + Math.random().toString(16).substr(2, 8),
        VerbindungsTimeout: 4000
      }
      this.client = mqtt.connect('ws://192.168.xxx.xx:8083/mqtt',Optionen);
      this.client.on("verbinden", (e)=>{
        console.log("Erfolgreich mit dem Server verbunden:",e);
        //Abonnieren Sie drei Themen mit den Namen „top/#“, „three/#“ und „#“ this.client.subscribe([„top/#“, „three/#“, „#“], { qos: 1 }, (err)=> {
          wenn (!err) {
            console.log("Abonnement erfolgreich");
            //Veröffentliche eine Nachricht mit dem Inhalt ‚Hallo, das ist ein schöner Tag!‘ zum Thema „pubtop“ this.publish(„pubtop“, ‚Hallo, das ist ein schöner Tag!‘)
          } anders {
            console.log('Nachrichtenabonnement fehlgeschlagen!')
          }
        });
      });
      //Verbinden Sie dies erneut.reconnect()
      //Wurde die Verbindung getrennt? this.mqttError()
      //Auf Informationen warten this.getMessage()
    }

    //Nachricht veröffentlichen @topic Betreff @message Inhalt veröffentlichen publish(topic,message) {
      wenn (!dieser.Client.verbunden) {
        console.log('Client nicht verbunden')
        zurückkehren
      }
      this.client.publish(Thema,Nachricht,{qos: 1},(err) => {
        wenn(!err) {
          console.log('Der Betreff ist' + topic + "Erfolgreich veröffentlicht")
        }
      })
    }

    //Auf empfangene Nachrichten warten getMessage() {
      this.client.on("Nachricht", (Thema, Nachricht) => {
        wenn(Nachricht) {
          console.log('Empfangen von', Thema, 'Information', Nachricht.toString())
          const res = JSON.parse(message.toString())
          //Konsole.log(res, 'res')
          Schalter(Thema) {
             Fall 'oben/#':
               diese.msg = res
               brechen;
             Fall 'drei/#':
               diese.msg = res
               brechen;
             Fall 'drei/#':
               diese.msg = res
               brechen;
             Standard:
               zurückkehren
               diese.msg = res
           }
           this.msg = Nachricht
        }
      });
    },

    //Überwachen, ob die Serververbindung fehlschlägt mqttError() {
      this.client.on('Fehler',(Fehler) => {
        console.log('Verbindung fehlgeschlagen:',Fehler)
        dieser.client.ende()
      })
    },

    //Abmelden unsubscribe() {
      this.client.unsubscribe(this.mtopic, (Fehler)=> {
        console.log('Thema ist' + this.mtopic + 'Abmeldung erfolgreich', Fehler)
      })
    },

    //trennen unconnect() {
      dieser.client.ende()
      this.client = null
      console.log('Die Verbindung zum Server wurde getrennt!')
    },

    //Auf erneute Serververbindung warten reconnect() {
      this.client.on('Wiederverbinden', (Fehler) => {
          console.log('Verbindung wird wiederhergestellt:', Fehler)
      });
    },