tongtong/vue3-element-admin
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: 🐛 websocket 指定用户消息接收问题修复

Browse Source 
Former-commit-id: ed7644956d9d99b8565beec5aeae21a02f52bf12
This commit is contained in:
郝先瑞
2023-09-12 18:29:40 +08:00
parent eea7f8ea63
commit 9fd683529d
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/views/demo/websocket.vue
View File

@@ -4,6 +4,10 @@
import SockJS from "sockjs-client"; import SockJS from "sockjs-client";
import Stomp from "stompjs"; import Stomp from "stompjs";
import { useUserStoreHook } from "@/store/modules/user";
const userStore = useUserStoreHook();
const inputVal = ref("初始内容"); const inputVal = ref("初始内容");
const topicMsgs = ref<string[]>(["接收到一条主题消息"]); // 主题消息列表 const topicMsgs = ref<string[]>(["接收到一条主题消息"]); // 主题消息列表
@@ -14,7 +18,7 @@ function handleSendToAll() {
} }
function handleSendToUser() { function handleSendToUser() {
stompClient.send("/app/sendToUser", {}, inputVal.value); stompClient.send("/app/sendToUser/root", {}, inputVal.value);
} }
let stompClient: Stomp.Client; let stompClient: Stomp.Client;
@@ -24,14 +28,14 @@ function initWebSocket() {
stompClient = Stomp.over(socket); stompClient = Stomp.over(socket);
stompClient.connect({}, () => { stompClient.connect({ Authorization: userStore.token }, () => {
console.log("连接就绪，订阅主题：", "/topic/all"); console.log("连接就绪，订阅主题：", "/topic/all");
stompClient.subscribe("/topic/all", (res) => { stompClient.subscribe("/topic/notice", (res) => {
console.log("广播消息接收", res); console.log("广播消息接收", res);
}); });
stompClient.subscribe("/user/queue/reply", (res) => { stompClient.subscribe("/user/queue/greeting", (res) => {
console.log("点对点消息接收", res); console.log("点对点消息接收", res);
}); });
}); });