代码

	import mqtt from '../../utils/mqtt.min.js'    //引入mqtt

	data(){
			return{
				options:{
					  clean: true, // 保留回话
					  connectTimeout: 4000, // 超时时间
					  clientId:'mqtt_mini'+Math.random().toString(16).substr(2, 6),
					  username: 'test1',
					  password: 'test1',
				},
			}
	},

mounted() {
			let client = mqtt.connect("wss://xx.xx.com/mqtt",this.options);
			    client.on("connect", e =>{
			        console.log("连接成功");
			        client.subscribe('/demo', (err)=> {
			            if (!err) {
			            console.log("订阅成功:" + 'divide');
			            }
			        });
			    });
			    client.on('error', (error) => {
			        console.log('连接失败:', error)
			    })
			    client.on("message", (topic, message) => {
			      console.log(JSON.parse(message))
			      
			    })
		},
	
解决

//mqtt.connect(‘wx://xxxxxxxxxx’, options);

//wx:// xx.xx.xxxxxxx

//协议版本 链接地址

//微信小程序这个版本 作者自己封装了一层 wx表示普通的ws协议连接 wxs表示加密之后的wss协议连接。

*将wss改成了wxs,这个问题就解决了

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐