Skip to content
Connect to mqtt through websocket, implementation for Vuejs 2
JavaScript
Branch: master
Clone or download
Fetching latest commit…
Cannot retrieve the latest commit at this time.
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
dist
src
.gitignore
README.md
package-lock.json
package.json
webpack.config.js

README.md

Vue-Mqtt

Connect to mqtt through websocket, implementation for Vuejs 2

Example

Example Vue-Mqtt-Example

Install

npm install vue-mqtt --save

Usage

Configuration

import VueMqtt from 'vue-mqtt';
Vue.use(VueMqtt, 'ws://iot.eclipse.org/ws', options);

options: https://github.com/mqttjs/MQTT.js#client

Subscribe

this.$mqtt.subscribe('param/param/param/test', options)

options: https://github.com/mqttjs/MQTT.js#subscribe

On Vuejs instance usage

The last parameter for reading is used

var vm = new Vue({
  mqtt: {
    'param/+/+/test': function(val) {
      console.log('param/+/+/test')
    },
    'param/#': function(val) {
      console.log('param/#')
    },
    'param/param/param/test': function(val) {
      console.log('param/param/param/test')
    },
    'template/+' (data, topic) {
      if (topic.split('/').pop() === '12345') {
        console.log('topic:', 'template/12345')
      }
    },
    'template/+/param/param' (data, topic) {
      if (topic.split('/')[1] === '12345') {
        console.log('topic:', 'template/12345/param/param')
      }
    }
  },
  methods: {
    clickSub: function(val) {
        this.$mqtt.subscribe('param/param/param/test')
    },
    clickPub: function(val) {
        this.$mqtt.publish('param/param/param/test', 'message')
    }
  }
})
You can’t perform that action at this time.