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()); } }