1.解决微信小程序真机MQTT无法连接问题

zhuguifei

2025-08-22 8304eac2a45a32b00563c03a2f3fd303ecd5872a

 mqtt/MqttView.vue

@@ -41,10 +41,13 @@
            }

            let opts = {

               // #ifdef H5

               url: 'ws://' + this.$api.mqttBaseUrl + ':8083/mqtt',

               url: 'wss://' + this.$api.mqttBaseUrl + ':8084/mqtt',

               // #endif

               // #ifdef APP-PLUS

               url: 'wx://' + this.$api.mqttBaseUrl + ':8083/mqtt',

               // #ifdef MP-WEIXIN
               url: 'wxs://' + this.$api.mqttBaseUrl + ':8084/mqtt',// 微信小程序强制 WSS
               // #endif
               // #ifdef APP-PLUS
               url: 'wxs://' + this.$api.mqttBaseUrl + ':8084/mqtt',  // Android/iOS 用普通 WebSocket
               // #endif

               clientId: deviceid,

               username: account.username,

@@ -76,6 +79,29 @@
            }).then(res => {
               console.error(res)
            })
				
            //订阅干燥设备连接断开状态更新-租户内所有设备
            this.$mqttTool.subscribe({
               topic: this.$constant.SERVICE_BROADCAST_TENANT_UPDATE_EQU_STATU.replace('%s', this.tenantId),
               qos: 0
            }).then(res => {
               console.error(res)
            })
            //订阅查询干燥设备连接状态-单个设备
            this.$mqttTool.subscribe({
               topic: this.$constant.SERVICE_RES_EQU_STATU.replace('%s', deviceid),
               qos: 0
            }).then(res => {
               console.error(res)
            })
				
            //订阅干燥设备实时数据
            this.$mqttTool.subscribe({
               topic: this.$constant.SERVICE_BROADCAST_TENANT_REAL_DATA.replace('%s', this.tenantId),
               qos: 0
            }).then(res => {
               console.error(res)
            })
             

            //订阅发送指令返回结果

            // this.$mqttTool.subscribe({

@@ -91,17 +117,21 @@
            let client = this.$mqttTool.client



            client.on('connect', function(res) {

               console.error('连接成功')

               console.error('连接成功')
               console.error(res)

            })

            client.on('reconnect', function(res) {

               console.error('重新连接')

               console.error('重新连接')
               console.error(res)

            })

            client.on('error', function(res) {

               console.info('连接错误')

               console.info('连接错误')
               console.error(res)

            })

            client.on('close', function(res) {



               console.error('关闭成功')

               console.error('关闭成功')
               console.error(res)



            })

            client.on('message', function(topic, message, buffer) {