From 020fde52021f0cc35b4680296394b3384c98bf11 Mon Sep 17 00:00:00 2001 From: huangfeng Date: Tue, 22 Oct 2024 10:11:04 +0800 Subject: [PATCH] =?UTF-8?q?perf:=20=E8=B0=83=E6=95=B4=E5=8F=91=E6=B6=88?= =?UTF-8?q?=E6=81=AF=E6=B5=8B=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/xydl/cac/controller/TestController.java | 4 ++-- src/main/java/com/xydl/cac/socket/WebSocketServer.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/xydl/cac/controller/TestController.java b/src/main/java/com/xydl/cac/controller/TestController.java index f91465e..fd6a2b7 100644 --- a/src/main/java/com/xydl/cac/controller/TestController.java +++ b/src/main/java/com/xydl/cac/controller/TestController.java @@ -33,7 +33,7 @@ public class TestController extends BasicController { @GetMapping("sendMsg") @ApiOperation("发送消息") - public void sendMsg(String msg) { - webSocketServer.sendMessage(msg , null); + public void sendMsg(String msg, Integer warningId) { + webSocketServer.sendMessage(msg, warningId); } } diff --git a/src/main/java/com/xydl/cac/socket/WebSocketServer.java b/src/main/java/com/xydl/cac/socket/WebSocketServer.java index 1be0d37..ed34aa4 100644 --- a/src/main/java/com/xydl/cac/socket/WebSocketServer.java +++ b/src/main/java/com/xydl/cac/socket/WebSocketServer.java @@ -29,7 +29,7 @@ public class WebSocketServer { log.info("剩余socket连接数" + sessionPools.size()); } - public void sendMessage(String message , Integer warningId) { + public void sendMessage(String message, Integer warningId) { MessageModel msg = new MessageModel(); msg.setType(1); msg.setContent(message);