1. 首页
2. uni-app
3. 本页

uniapp websocket使用方式

// 进入这个页面的时候创建websocket连接【整个页面随时使用】
connectSocketInit() {
// 创建一个this.socketTask对象【发送、接收、关闭socket都由这个对象操作】
const url = “ws://192.168.1.103:8092/wx/websocket/” + uni.getStorageSync(‘user_info’).id
console.log(url)
this.socketTask = uni.connectSocket({
// 【非常重要】必须确保你的服务器是成功的,如果是手机测试千万别使用ws://127.0.0.1:9099【特别容易犯的错误】
url: url,
success(data) {
console.log(“websocket连接成功”);
},
});

// 消息的发送和接收必须在正常连接打开中,才能发送或接收【否则会失败】
this.socketTask.onOpen((res) => {
console.log(“WebSocket连接正常打开中…！”);
this.is_open_socket = true;
// 注：只有连接正常打开中 ，才能正常成功发送消息
// this.socketTask.send({
// data: “uni-app发送一条消息”,
// async success() {
// console.log(“消息发送成功”);
// },
// });
// 注：只有连接正常打开中 ，才能正常收到消息
this.socketTask.onMessage((res) => {
console.log(“收到服务器内容：” + res.data);
let patient = JSON.parse(res.data)
//医生发送
if(this.sendMsg.messageSend === data.messageSend && this.sendMsg.messageAccept === data.messageAccept){
this.chatRoomList.push({doctor:data.messageDatail})
//患者发送
}else if(this.sendMsg.messageAccept === data.messageSend && this.sendMsg.messageAccept === data.messageSend){
this.chatRoomList.push({patient:data.messageDatail})
}
});
})
// 这里仅是事件监听【如果socket关闭了会执行】
this.socketTask.onClose(() => {
console.log(“已经被关闭了”)
})
},
// 关闭websocket【离开这个页面的时候执行关闭】
closeSocket() {
this.socketTask.close({
success(res) {
this.is_open_socket = false;
console.log(“关闭成功”, res)
},
fail(err) {
console.log(“关闭失败”, err)
}
})
},
clickRequest() {
if (this.is_open_socket) {
// websocket的服务器的原理是:发送一次消息,同时返回一组数据【否则服务器会进去死循环崩溃】
if(this.sendMsg.messageDatail.length != 0){
let i = JSON.stringify(this.sendMsg)
const vm = this
this.socketTask.send({
//发送消息
data: i,
async success() {
console.log(“消息发送成功”);
vm.sendMsg.messageDatail = ”
console.log(‘清空输入栏的内容’)
},
});
}
}
},
leave() {
this.$uniReLaunch(“/pages/tabbar/wallet/wallet”)
},