From 4a3e0f80e3449817c4a06bb923ce5291de8becdc Mon Sep 17 00:00:00 2001
From: huangfeng <huangfeng@xinyingpower.com>
Date: Tue, 2 Jul 2024 09:16:00 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E5=A2=9E=E5=8A=A0websocket=E9=94=99?=
 =?UTF-8?q?=E8=AF=AF=E5=A4=84=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/com/xydl/cac/socket/WebSocketServer.java | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/xydl/cac/socket/WebSocketServer.java b/src/main/java/com/xydl/cac/socket/WebSocketServer.java
index d12901c..b5f41e5 100644
--- a/src/main/java/com/xydl/cac/socket/WebSocketServer.java
+++ b/src/main/java/com/xydl/cac/socket/WebSocketServer.java
@@ -35,7 +35,7 @@ public class WebSocketServer {
             Session session = it.next();
             try {
                 session.getBasicRemote().sendText(message);
-            } catch (IOException ignore) {
+            } catch (Exception ignore) {
             }
         }
     }
@@ -46,6 +46,8 @@ public class WebSocketServer {
         try {
             if (!"1".equals(message)) {
                 message = message.replaceAll("吗", "")
+                        .replaceAll("b", "c")
+                        .replaceAll("a", "b")
                         .replaceAll("你", "我")
                         .replaceAll("？", "!")
                         .replaceAll("\\?", "!");
@@ -57,7 +59,9 @@ public class WebSocketServer {
 
     //错误时调用
     @OnError
-    public void onError(Session session, Throwable throwable) {
+    public void onError(Session session, Throwable e) {
+        sessionPools.remove(session);
+        log.info("剩余socket连接数" + sessionPools.size());
     }
 
 }