Former-commit-id: ccfe75690cfcec47f240bf9fbbc1cca19c9714da
This commit is contained in:
hxr
2023-09-13 07:42:39 +08:00

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);
}); });
}); });