import {isEmptyValue} from '@/utils/StringUtils'
|
import store from "@/store";
|
|
/**
|
* 定义'Websocket'连接对象。
|
* @author 时克英
|
* @date 2023-04-17
|
*/
|
class WebConnection {
|
// static uid;
|
// static uri;
|
constructor(_uri, _uid) {
|
if(isEmptyValue(_uri)){
|
throw 'uri参数为空';
|
}
|
if(isEmptyValue(_uid)){
|
throw 'uid参数为空';
|
}
|
this.uri = _uri;
|
this.uid = _uid;
|
this.socket = null;
|
this._ws_timer = setInterval(this.timedCheckConnection, 120000); // 定时任务
|
}
|
|
shutdown(){
|
if(this.socket != null && this.socket != undefined){
|
this.socket.close();
|
}
|
}
|
|
startConnect(){
|
if('WebSocket' in window){
|
this.socket = new WebSocket(this.uri);
|
this.socket.onopen = this.wsOpen;
|
this.socket.onmessage = this.wsMessage;
|
this.socket.onerror = this.wsError;
|
this.socket.onclose = this.wsClose;
|
} else {
|
this.socket = null;
|
console.log('创建ws错误，可能当前浏览器不支持webSocket')
|
}
|
}
|
|
timedCheckConnection(){
|
let uri = store.state.user.uri;
|
let uid = store.state.user.uid;
|
if(!isEmptyValue(uri) && !isEmptyValue(uid)){
|
// 2023-04-18，这里也无法直接使用：this.socket，因为此时为空（undefined）
|
// console.log("是否连接 = " + this.socket);
|
// if(this.socket == null || this.socket == undefined || !this.connected()){
|
if(store.state.user.webConnection == null || !store.state.user.webConnection.connected()){
|
this.uri = uri;
|
this.uid = uid;
|
console.log("重新连接：" + this.uri);
|
store.state.user.webConnection.startConnect();
|
}
|
} else{
|
console.error("uri或uid为空," + this.uid + ", " + this.uri);
|
}
|
}
|
wsOpen(){
|
// 2023-04-18，注意：这里回调方法中无法直接获取：this.uid，猜测是因为上下文环境已经变化（类似于匿名类换成独立类的情况）
|
// 因此，经过长时间研究，决定需要放在全局store中。
|
let uid = store.state.user.uid;
|
console.log("--------> uid = " + uid);
|
this.send(JSON.stringify({"protocol":"login", "uid":uid}));
|
// console.log(this);
|
}
|
wsClose(){
|
this.uid = store.state.uid;
|
console.log("浏览器断开连接：" + this.uid);
|
}
|
wsError(err){
|
console.log('== websocket error ==', err);
|
}
|
wsMessage(event){
|
// console.log(event);
|
if(event.data == null || event.data == "" || event.data == "null"){
|
console.log("接收到服务端空数据\n");
|
return;
|
}
|
store.state.user.webConnection.processServerRequest(eval("("+ event.data +")"));
|
}
|
|
processServerRequest(data){
|
// console.log(data);
|
if(data == null){
|
return;
|
}
|
if(data.protocol == "heartbeat"){
|
return;
|
}
|
if(data.protocol == "login"){
|
if(data.status == 0){
|
// uid = data.uid;
|
//$("#showText").append("服务已连接，开始提问：" + data.uid + "\n");
|
console.log("浏览器连接成功:" + data.uid);
|
} else {
|
console.log("登录认证失败：" + data.status + "\n");
|
}
|
return;
|
}
|
|
if(data.protocol == "data" || data.protocol == "broadcast"){
|
console.log("接收到web推送：");
|
console.log(data.data + "\n");
|
store.commit('SET_WS_MSG', data.data);
|
// if(data.data.touch == 1){
|
// touchEvent(data.data);
|
// } else {
|
// voiceEvent(data.data);
|
// }
|
}
|
}
|
|
//~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
|
//~ 内部私有方法
|
//~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
|
send(message){
|
if(this.socket == null){
|
return;
|
}
|
if (this.socket.readyState == WebSocket.OPEN) {
|
this.socket.send(message);
|
} else {
|
console.log("connection is not start.");
|
}
|
}
|
|
connected(){
|
if(this.socket == null || this.socket == undefined){
|
return false;
|
}
|
if(this.socket.readyState == 1){
|
return true;
|
}
|
return false;
|
}
|
|
}
|
|
export default WebConnection;
|
