From aac185a1117f6ba1f46351107bde99293eb6b90c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=83=9D=E5=85=88=E7=91=9E?= <1490493387@qq.com>
Date: Sat, 9 Sep 2023 23:00:42 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20:sparkles:=20=E5=AE=8C=E5=96=84websocke?=
 =?UTF-8?q?t=E6=A1=88=E4=BE=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Former-commit-id: 5dee4098eb7968cc47cd74c49a0c20908427b48e
---
 src/api/websocket/index.ts   | 27 ---------------------------
 src/views/demo/websocket.vue | 14 +++++++-------
 2 files changed, 7 insertions(+), 34 deletions(-)
 delete mode 100644 src/api/websocket/index.ts

diff --git a/src/api/websocket/index.ts b/src/api/websocket/index.ts
deleted file mode 100644
index 867a2a23..00000000
--- a/src/api/websocket/index.ts
+++ /dev/null
@@ -1,27 +0,0 @@
-import request from "@/utils/request";
-
-/**
- * 发送消息给所有人
- *
- * @param file
- */
-export function sendToAll(message: string) {
-  return request({
-    url: "/websocket/sendToAll",
-    method: "post",
-    params: { message: message },
-  });
-}
-
-/**
- * 发送消息给指定用户
- *
- * @param
- */
-export function sendToUser(userId: number, message: string) {
-  return request({
-    url: "/websocket/sendToUser/" + userId,
-    method: "post",
-    params: { message: message },
-  });
-}
diff --git a/src/views/demo/websocket.vue b/src/views/demo/websocket.vue
index eb4771dc..7ab39b16 100644
--- a/src/views/demo/websocket.vue
+++ b/src/views/demo/websocket.vue
@@ -1,7 +1,5 @@
 <!-- websocket 示例 -->
 <script setup lang="ts">
-import { sendToAll, sendToUser } from "@/api/websocket"; // 点对点消息列表
-
 import { useUserStore } from "@/store/modules/user";
 
 //  import SockJS from "sockjs-client"; // 报错 global is not defined 换成下面的引入
@@ -16,13 +14,11 @@ const p2pMsgs = ref<string[]>(["接收到一条点对线消息"]);
 const userId = useUserStore().userId;
 
 function handleSendToAll() {
-  sendToAll(inputVal.value);
-
   stompClient.send("/app/sendToAll", {}, inputVal.value);
 }
 
 function handleSendToUser() {
-  sendToUser(userId, inputVal.value);
+  stompClient.send("/app/sendToUser/" + userId, {}, inputVal.value);
 }
 
 let stompClient: Stomp.Client;
@@ -33,10 +29,14 @@ function initWebSocket() {
   stompClient = Stomp.over(socket);
 
   stompClient.connect({}, () => {
-    console.log("连接成功");
+    console.log("连接就绪，订阅主题：", "/topic/all");
 
     stompClient.subscribe("/topic/all", (res) => {
-      console.log("订阅响应");
+      console.log("广播消息接收", res);
+    });
+
+    stompClient.subscribe("/queue/user", (res) => {
+      console.log("点对点消息接收", res);
     });
   });
 }