// 进入这个页面的时候创建websocket连接[整个页面随时使用]
connectSocketInit(){
let that = this;
uni.closeSocket();
//创建一个this.socketTask对象[发送、接收、关闭都由这个对象操作]
that.socketTask = uni.connectSocket({
// [非常重要]必须确保你的服务器是成功的,如果是手机测试千万别使用ws://127.0.0.1:9099[特别容易犯的错误]
url:"ws://61.163.210.21:8005/api-admin/device/websocket/"+(that.projectName+that.terminalName),
// url:"ws://192.168.3.139:8005/api-admin/device/websocket/"+(that.projectName+that.terminalName),
success(data){
console.log("websocket连接成功");
}
});
// 消息的发送和接收必须在正常连接打开中,才能发送或接收[否则会失败]
that.socketTask.onOpen((res)=>{
console.log("WebSocket连接正常打开中...！");
that.is_open_socket = true;
// 注：只有连接正常打开中 ，才能正常成功发送消息
that.socketTask.send({
data: "uni-app发送一条消息",
async success() {
console.log("消息发送成功");
},
});
// 注：只有连接正常打开中 ，才能正常收到消息
that.socketTask.onMessage((res) => {
// console.log("收到服务器内容：" + res.data);
let zhuqisheng = JSON.parse(res.data);
that.zhuqisheng = zhuqisheng;
});
})
// 这里仅是事件监听【如果socket关闭了会执行】
that.socketTask.onClose(() => {
console.log("已经被关闭了")
})
},
// 关闭websocket【离开这个页面的时候执行关闭】
closeSocket() {
this.socketTask.close({
success(res) {
this.is_open_socket = false;
console.log("关闭成功", res)
},
fail(err) {
console.log("关闭失败", err)
}
})
},
// 关闭websocket[必须在实例销毁之前关闭,否则会是underfined错误]
beforeDestroy() {
this.closeSocket();
},
