网络状态优化

This commit is contained in:
yj 2024-09-27 14:02:04 +08:00
parent cfa5a3b2a3
commit c6c900309a
3 changed files with 9 additions and 15 deletions

View File

@ -9,7 +9,7 @@ import Meeting from '@/page/Meeting/index'
import NotFound from '@/page/NotFound/index'
import { storage } from '@/utils'
import { message, Spin } from "antd";
import { onOtherSignalr, onReconnected, onStop, startSignalr } from "@/utils/package/signalr";
import { onOtherSignalr, onStop, startSignalr } from "@/utils/package/signalr";
import JoinMeetingModal from "@/components/JoinMeetingModal";
import UpdateModal from "@/components/UpdateModal";
import * as CryptoJS from 'crypto-js';
@ -185,9 +185,6 @@ const App: React.FC = () => {
break;
}
})
onReconnected(async () => {
storage.setItem('reconnect', true)
})
}
const toSrc = (path: string): void => {
window.electron.getWindowSize().then((res: any) => {

View File

@ -759,7 +759,6 @@ const Meeting: React.FC = () => {
onConnectionStateChanged: async (_connection: RtcConnection, stateNumber: ConnectionStateType, reason: ConnectionChangedReasonType) => {
const reconnectingCode = [2, 16, 11, 13, 14, 12]
if (stateNumber === 4 && reconnectingCode.indexOf(reason) >= 0) {
storage.setItem('reconnect', false)
message.error('网络断开,请检查网络')
}
},

View File

@ -10,10 +10,15 @@ export const startSignalr = async () => {
accessTokenFactory: () => user.token
})
.build();
await onStart()
onStart()
storage.setItem('isSignalr', true)
connection.onclose(async () => {
await onStart()
storage.setItem('reconnect', true)
connection.onreconnected(async () => {
storage.setItem('reconnect', true)
});
connection.onreconnecting(async () => {
onStart()
storage.setItem('reconnect', false)
});
}
@ -29,13 +34,6 @@ export const onStart = async (callBack?: Function) => {
}
}
}
export const onReconnected = async (callBack: Function) => {
if (connection) {
connection.onreconnected(async (_newConnectionId: any) => {
callBack()
});
}
}
export const onOtherSignalr = (callBack: Function) => {
if (connection) {
// 邀请