45 lines
712 B
JavaScript
45 lines
712 B
JavaScript
|
|
import config from '@/config'
|
|
export function startMsgSocket(userId) {
|
|
return msgSocketConnect(userId);
|
|
}
|
|
|
|
export function msgSocketConnect(userId) {
|
|
console.log("通知socket链接");
|
|
var socketTask = uni.connectSocket({
|
|
url: config.wsUrl + '/websocket/chat/' + userId,
|
|
success(res) {
|
|
|
|
},
|
|
fail(err) {
|
|
|
|
}
|
|
}
|
|
|
|
);
|
|
return socketTask;
|
|
}
|
|
|
|
|
|
export function sendMsg(SocketTask,msg) {
|
|
if (SocketTask) {
|
|
SocketTask.send({
|
|
data: msg,
|
|
success: res => {
|
|
console.log('消息链接正常')
|
|
},
|
|
fail: err => {
|
|
console.log('消息链接异常 重新链接' + err, uni.getStorageSync('userId'));
|
|
|
|
}
|
|
});
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
export function closeMsgSocket(SocketTask) {
|
|
SocketTask.close()
|
|
}
|