From 260d88a383e3a909ac507cd893a48aea38b0e6a8 Mon Sep 17 00:00:00 2001 From: huangfeng Date: Thu, 26 Sep 2024 14:15:41 +0800 Subject: [PATCH] =?UTF-8?q?perf:=20=E9=80=9A=E7=9F=A5=E5=89=8D=E7=AB=AFact?= =?UTF-8?q?ion=E5=A5=BD=E5=90=8E=E7=BB=AD=E6=93=8D=E4=BD=9C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/shxy/xymanager_admin/controller/TestController.java | 2 +- .../java/com/shxy/xymanager_common/model/MessageModel.java | 1 + .../com/shxy/xymanager_framework/socket/WebSocketServer.java | 3 ++- 3 files changed, 4 insertions(+), 2 deletions(-) diff --git a/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TestController.java b/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TestController.java index 9d909c5..0959671 100644 --- a/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TestController.java +++ b/xymanager_admin/src/main/java/com/shxy/xymanager_admin/controller/TestController.java @@ -25,7 +25,7 @@ public class TestController extends BaseController { @GetMapping("sendMsg") @ApiOperation("发送消息") public void sendMsg(String msg) { - webSocketServer.sendNotice(msg); + webSocketServer.sendNotice(null, msg); } @GetMapping("test") diff --git a/xymanager_common/src/main/java/com/shxy/xymanager_common/model/MessageModel.java b/xymanager_common/src/main/java/com/shxy/xymanager_common/model/MessageModel.java index 828784a..c0eb971 100644 --- a/xymanager_common/src/main/java/com/shxy/xymanager_common/model/MessageModel.java +++ b/xymanager_common/src/main/java/com/shxy/xymanager_common/model/MessageModel.java @@ -6,4 +6,5 @@ import lombok.Data; public class MessageModel { int type; String content; + String action; } diff --git a/xymanager_framework/src/main/java/com/shxy/xymanager_framework/socket/WebSocketServer.java b/xymanager_framework/src/main/java/com/shxy/xymanager_framework/socket/WebSocketServer.java index f40bb1b..46ca434 100644 --- a/xymanager_framework/src/main/java/com/shxy/xymanager_framework/socket/WebSocketServer.java +++ b/xymanager_framework/src/main/java/com/shxy/xymanager_framework/socket/WebSocketServer.java @@ -46,10 +46,11 @@ public class WebSocketServer { } } - public void sendNotice(String message) { + public void sendNotice(String action, String message) { MessageModel msg = new MessageModel(); msg.setType(2); msg.setContent(message); + msg.setAction(action); String json = JSONUtil.object2Json(msg); Iterator it = sessionPools.listIterator(); while (it.hasNext()) {