How to use mqtt in uniapp project

npm install [email protected]

npm install uuid 

{
  "name": "",
  "version": "1.0.0",
  "description": "",
  "author": "",
  "license": "MIT",
  "dependencies": {
    "mqtt": "^3.0.0",
    "uuid": "^8.3.0"
  },
  "devDependencies": {},
  "scripts": {}
}

export const MQTT_IP = '192.168.9.128:8083/mqtt' //mqtt address port const MQTT_USERNAME = 'public' //mqtt username const MQTT_PASSWORD = 'public' //password export const MQTT_OPTIONS = {
    connectTimeout: 5000,
    clientId: '',
    username: MQTT_USERNAME,
    password: MQTT_PASSWORD,
    clean: false
}

<script>
    import { v4 } from 'uuid';
    import {
        MQTT_IP,
        MQTT_OPTIONS
    } from '@/utils/mqtt.js';
    var mqtt = require('mqtt/dist/mqtt.js')
    var client
    export default {
        data() {
            return {
                topic: '' // Topic to subscribe to}
        },
        mounted() {this.connect() //connect},
        methods: {
            connect() {
                MQTT_OPTIONS.clientId = v4()
                var that = this
                // #ifdef H5
                client = mqtt.connect('ws://' + MQTT_IP, MQTT_OPTIONS)
                // #endif
                // #ifdef MP-WEIXIN||APP-PLUS
                client = mqtt.connect('wx://' + MQTT_IP, MQTT_OPTIONS)
                // #endif
                client.on('connect', function() {
                    console.log('Connection successful')
                    client.subscribe(that.topic, function(err) {
                        if (!err) {
                            console.log('Subscription successful')
                        }
                    })
                }).on('reconnect', function(error) {
                    console.log('Reconnecting...', that.topic)
                }).on('error', function(error) {
                    console.log('Connection failed...', error)
                }).on('end', function() {
                    console.log('Connection disconnected')
                }).on('message', function(topic, message) {
                    console.log('Receive push information:', message.toString())
                })
            }
        }
    }
</script>