websocketSerivce/src/main/java/org/example/websocket/server/WsServer.java
@@ -216,10 +216,7 @@ // log.info("距离上次发送消息时间未达到指定间隔,不发送消息。"); } }else{ Map<String,Integer> map = new HashMap<>(); map.put("status",1); pushMessage(session,JSONUtil.toJsonStr(map)); closeSession(session,"没有订阅消息"); pushMessage(session,"没有订阅消息"); } } private static final Gson gson = new Gson(); @@ -363,6 +360,6 @@ log.error("强制断开连接----异常: {}", e.getMessage()); } wsServers.remove(this); log.info("客户端未及时发送订阅消息,断开连接"); log.info(reason); } }