diff --git a/src/views/remote-manage/remote-manage.vue b/src/views/remote-manage/remote-manage.vue index ceaccad..ca601af 100644 --- a/src/views/remote-manage/remote-manage.vue +++ b/src/views/remote-manage/remote-manage.vue @@ -140,6 +140,7 @@ const breakRemote = (e: RemoteItem) => { title: e.title, state: '断开连接' }, e.index) + disconnectSurgeryData("", "1") } const addLogAfter = () => { messagePartRef.value.scrollToBottom() @@ -148,11 +149,15 @@ const addLogAfter = () => { const surgeryClient = new Client({ brokerURL: 'ws://localhost:5173/socket.io/admin/rax/SurgeryData', connectHeaders: { - access_token: Session.get('token') + token: Session.get('token') } }) surgeryClient.activate() +surgeryClient.onConnect = (data: any) => { + console.log("connect", data); +} + surgeryClient.onWebSocketError = (error) => { console.log('Error with websocket', error) }; @@ -166,7 +171,7 @@ function getSurgeryData(username: string, db: string) { console.log(username, db); surgeryClient.publish({ destination: "/front/getSurgeryData", - body: JSON.stringify({'status': "start", db}) + body: JSON.stringify({status: "start", db, token: Session.get('token')}) }); const account = "admin"; surgeryClient.subscribe('/topic/user/' + account + ":" + db + '/surgeryData', (data: any) => { @@ -175,11 +180,8 @@ function getSurgeryData(username: string, db: string) { } function disconnectSurgeryData(username: string, db: string) { - surgeryClient.publish({ - destination: "/front/getSurgeryData", - body: JSON.stringify({'status': "stop", db, username}) - }); - surgeryClient.unsubscribe("/topic/user/" + username + "/surgeryData"); + const account = "admin"; + surgeryClient.unsubscribe("/topic/user/" + account + ":" + db + "/surgeryData"); }