138 lines
4.4 KiB
JavaScript
138 lines
4.4 KiB
JavaScript
import config from "@/config";
|
||
import storage from "@/utils/storage";
|
||
import constant from "@/utils/constant";
|
||
import { login, logout, getInfo } from "@/api/login";
|
||
import { getToken, setToken, removeToken } from "@/utils/auth";
|
||
import { GetListid } from "@/api/signln/SignTa/SignTa";
|
||
const baseUrl = config.baseUrl;
|
||
const qnDomain = config.qnDomain;
|
||
const chat = {
|
||
state: {
|
||
token: getToken(),
|
||
socket: storage.get(constant.socket),
|
||
sysMessageInfo: storage.get(constant.sysMessageInfo),
|
||
activiInfo: storage.get(constant.activiInfo),
|
||
sysAuditInfo: storage.get(constant.sysAuditInfo),
|
||
userMessageinfo: storage.get(constant.userMessageinfo),
|
||
interactMessage: storage.get(constant.interactMessage),
|
||
},
|
||
|
||
mutations: {
|
||
SET_socket: (state, socket) => {
|
||
state.socket = socket;
|
||
storage.set(constant.socket, socket);
|
||
},
|
||
SET_userMessageinfo: (state, userMessageinfo) => {
|
||
state.userMessageinfo = userMessageinfo;
|
||
storage.set(constant.userMessageinfo, userMessageinfo);
|
||
},
|
||
},
|
||
|
||
actions: {
|
||
// 进行webSocket链接
|
||
webSockerInfo({ commit, state }) {
|
||
GetListid().then((res) => {
|
||
let socket = null;
|
||
let heartBeatInterval = null;
|
||
let reconnectTimeout = null;
|
||
|
||
const connect = () => {
|
||
const fileWithoutProtocol = baseUrl.replace(/^https?:\/\//, "");
|
||
const url2 = "ws://" + fileWithoutProtocol + "/text/text?" + getToken();
|
||
|
||
// const url2 = "ws://www.daxueshen.top/text/text?" + res;
|
||
socket = uni.connectSocket({
|
||
url: url2,
|
||
success: () => {
|
||
console.log("ws连接成功");
|
||
},
|
||
fail: (err) => {
|
||
console.error("ws连接失败：", err);
|
||
}
|
||
});
|
||
|
||
commit("SET_socket", socket);
|
||
|
||
socket.onOpen(() => {
|
||
console.log("WebSocket连接已打开");
|
||
// 开始心跳
|
||
startHeartBeat();
|
||
|
||
});
|
||
|
||
socket.onMessage((event) => {
|
||
const jsonObject = JSON.parse(event.data);
|
||
if (jsonObject.messageType == 51 || jsonObject.messageType == 52) {
|
||
console.log("聊天新消息111:", jsonObject);
|
||
commit("SET_userMessageinfo", jsonObject);
|
||
}
|
||
});
|
||
|
||
socket.onError((error) => {
|
||
console.error("WebSocket发生错误：", error);
|
||
reconnect();
|
||
});
|
||
|
||
socket.onClose(() => {
|
||
console.log("WebSocket连接已关闭");
|
||
reconnect();
|
||
});
|
||
};
|
||
let heartbeatIntervalTime = 5000; // 初始心跳间隔时间（毫秒）
|
||
const maxHeartbeatInterval = 30000; // 最大心跳间隔时间（毫秒），例如设置为30秒
|
||
const startHeartBeat = () => {
|
||
heartBeatInterval = setInterval(() => {
|
||
if (socket && socket.readyState === 1) {
|
||
const info = {
|
||
fromid: null,
|
||
toid: 0,
|
||
content: "heartBeat",
|
||
};
|
||
socket.send({
|
||
data: JSON.stringify(info),
|
||
success: () => {
|
||
console.log("心跳包发送成功:",heartbeatIntervalTime);
|
||
// 如果当前心跳间隔小于最大值，则逐步增加心跳间隔
|
||
if (heartbeatIntervalTime < maxHeartbeatInterval) {
|
||
heartbeatIntervalTime += 1000; // 每次增加5秒
|
||
clearInterval(heartBeatInterval); // 清除旧的定时器
|
||
// 开始心跳
|
||
startHeartBeat();
|
||
}
|
||
},
|
||
fail: ()=>{
|
||
console.log("心跳包发送失败,尝试重新连接WebSocket");
|
||
reconnect();
|
||
}
|
||
});
|
||
}
|
||
}, heartbeatIntervalTime); // 每5秒发送一次心跳包
|
||
};
|
||
|
||
const stopHeartBeat = () => {
|
||
if (heartBeatInterval) {
|
||
clearInterval(heartBeatInterval);
|
||
heartBeatInterval = null;
|
||
}
|
||
};
|
||
|
||
const reconnect = () => {
|
||
stopHeartBeat();
|
||
if (reconnectTimeout) {
|
||
clearTimeout(reconnectTimeout);
|
||
reconnectTimeout = null;
|
||
}
|
||
reconnectTimeout = setTimeout(() => {
|
||
console.log("尝试重新连接WebSocket");
|
||
connect();
|
||
}, 5000); // 5秒后重连
|
||
};
|
||
|
||
connect();
|
||
});
|
||
},
|
||
},
|
||
};
|
||
|
||
export default chat;
|