From d0f31715c415f5e92c46409581ca2570764b6159 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=83=A1=E5=B0=91=E7=BF=94?= <971366405@qq.com>
Date: Mon, 2 Sep 2024 16:25:00 +0800
Subject: [PATCH] =?UTF-8?q?wip:=20:construction:=20=E9=80=9A=E7=9F=A5?=
=?UTF-8?q?=E5=85=AC=E5=91=8A=E4=B8=B4=E6=97=B6=E6=8F=90=E4=BA=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
通知公告临时提交
---
.../NavBar/components/NavbarAction.vue | 33 +++----------------
src/views/system/notice/index.vue | 4 +--
2 files changed, 6 insertions(+), 31 deletions(-)
diff --git a/src/layout/components/NavBar/components/NavbarAction.vue b/src/layout/components/NavBar/components/NavbarAction.vue
index def658a2..3ac541a7 100644
--- a/src/layout/components/NavBar/components/NavbarAction.vue
+++ b/src/layout/components/NavBar/components/NavbarAction.vue
@@ -201,6 +201,7 @@ function logout() {
let stompClient: Client;
function connectWebSocket() {
+ console.log("连接消息ws的url：" + socketEndpoint.value);
stompClient = new Client({
brokerURL: socketEndpoint.value,
connectHeaders: {
@@ -210,32 +211,11 @@ function connectWebSocket() {
console.log(str);
},
onConnect: () => {
- console.log("连接成功");
+ console.log("消息ws连接成功");
isConnected.value = true;
- // messages.value.push({
- // sender: "Server",
- // content: "Websocket 已连接",
- // type: "tip",
- // });
- // 订阅 /topic/chat 主题
- while (messages.value.length > 3) {
- messages.value.shift();
- }
- stompClient.subscribe("/topic/chat", (res) => {
+
+ stompClient.subscribe("/user/queue/message", (res) => {
console.log("收到消息：" + res.body);
- const message = JSON.parse(res.body);
- console.log("当前有：" + message.id);
- console.log("数组已更新，强制重新渲染");
- messages.value.push({
- id: message.id,
- title: message.title,
- type: MessageTypeEnum.MESSAGE,
- });
- while (messages.value.length > 3) {
- messages.value.shift();
- }
- console.log("当前还有：" + messages.value);
- nextTick(async () => {});
});
},
onStompError: (frame) => {
@@ -244,11 +224,6 @@ function connectWebSocket() {
},
onDisconnect: () => {
isConnected.value = false;
- // messages.value.push({
- // sender: "Server",
- // content: "Websocket 已断开",
- // type: "tip",
- // });
},
});
diff --git a/src/views/system/notice/index.vue b/src/views/system/notice/index.vue
index 385d7b5f..1bc4dc3b 100644
--- a/src/views/system/notice/index.vue
+++ b/src/views/system/notice/index.vue
@@ -69,6 +69,7 @@
@selection-change="handleSelectionChange"
>
+