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