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