我要评论使用uniapp封装websocket请求
大同小异，vue封装也差不多
request.js文件
const socketbaseurl = 'wss://test.com/xxxxxdfjksdjfl' //后端给你的socket接口
export function websocket(url, data, readcb, messagecb, finishedcb) {
//开始连接websocket
const sockettask = uni.connectsocket({
url: socketbaseurl + url + data.id //socket接口和地址和后端需要你传的内容
success: res => console.log(res), //请求成功
fail: e => console.log(e) //请求失败
})
//websocket 连接打开事件
sockettask.onopen(res => {
//连接后发送数据
sockettask.send({
data: data.datastr
})
//返回
readcb(res, sockettask)
})
//websocket 接收到服务器的消息事件
sockettask.onmessage(res => {
//返回
messagecb(res, sockettask)
})
//websocket 错误事件
sockettask.onerror(e => {
console.log('socket error: ', e)
})
}
//导出接口
export const sendapi = (data, readcb , messagecb ,finishedcb) => websocket('/message/', data, readcb, messagecb, finishedcb)
使用：
例：test.js
import { sendapi } from '@/request.js';
export default{
data(){
return{
sockettask:'',
}
},
methods:{
handle(){
//传给后端的数据
let info = {id:5,datastr:'test'}
//调接口
sendapi(
info,
(_, sockettask) => {
//调取赋值socket,用于后面关闭连接
this.sockettask = sockettask;
},
(res) => {
try {
//解析返回数据
const socketres = json.parse(res.data)
//打印返回数据
console.log(socketres)
//接收返回的数据后，关闭socket
this.sockettask.close();
} catch (e) {
// 返回异常，关闭socket
this.sockettask.close();
}
}
)
};
}
}
发表评论