远程管理接口调试

This commit is contained in:
zhaoyz 2024-03-19 18:43:38 +08:00
parent 9186e1a01b
commit b2ae2c432e

View File

@ -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");
}
</script>