From ec93dff9dc48505566182f31a58c7d16fcbc0560 Mon Sep 17 00:00:00 2001
From: huangfeng <huangfeng@xinyingpower.com>
Date: Fri, 21 Jun 2024 16:57:27 +0800
Subject: [PATCH] =?UTF-8?q?perf:=20=E4=BC=98=E5=8C=96websocket=E4=BF=A1?=
 =?UTF-8?q?=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/xydl/cac/socket/WebSocketServer.java    | 17 +++++++++++++----
 1 file changed, 13 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/xydl/cac/socket/WebSocketServer.java b/src/main/java/com/xydl/cac/socket/WebSocketServer.java
index 9c866a0..d12901c 100644
--- a/src/main/java/com/xydl/cac/socket/WebSocketServer.java
+++ b/src/main/java/com/xydl/cac/socket/WebSocketServer.java
@@ -20,13 +20,13 @@ public class WebSocketServer {
     @OnOpen
     public void onOpen(Session session) {
         sessionPools.add(session);
-        log.info("当前连接数" + sessionPools.size());
+        log.info("当前socket连接数" + sessionPools.size());
     }
 
     @OnClose
     public void onClose(Session session) {
         sessionPools.remove(session);
-        log.info("剩余连接数" + sessionPools.size());
+        log.info("剩余socket连接数" + sessionPools.size());
     }
 
     public void sendMessage(String message) {
@@ -42,8 +42,17 @@ public class WebSocketServer {
 
     //收到客户端信息
     @OnMessage
-    public void onMessage(String message) {
-//        log.info("收到客户端信息:{}", message);
+    public void onMessage(Session session, String message) {
+        try {
+            if (!"1".equals(message)) {
+                message = message.replaceAll("吗", "")
+                        .replaceAll("你", "我")
+                        .replaceAll("？", "!")
+                        .replaceAll("\\?", "!");
+                session.getBasicRemote().sendText(message);
+            }
+        } catch (IOException ignore) {
+        }
     }
 
     //错误时调用