connect_mqtt() {
                // var mqtt = require('mqtt')
                let clientId = "mqtt_client_" + Math.floor(Math.random() * 10000);
                const options = {
                    clean: true,
                    connectTimeout: 5000,
                    clientId: clientId,
                    keepalive: 0,
                    // path: '/ws',
                    username: '',
                    password: '',
                }

                var client = mqtt.connect(`ws://${this.server_ip}:15675/ws`, options)
                let topics = 'aa/003'
                client.subscribe(topics, function(err) {
                    console.log('connected to mq server')
                })

                client.on('connect', function() {
                    console.log('on connect')

                })
                client.on('message', (topic, message, buffer) => {
                    let msg = JSON.parse(message.toString())

                 })
            }

Logo

华为开发者空间,是为全球开发者打造的专属开发空间,汇聚了华为优质开发资源及工具,致力于让每一位开发者拥有一台云主机,基于华为根生态开发、创新。

更多推荐