src/main/java/com/moral/webSocketServer/WebSocketServer.java
@@ -114,6 +114,7 @@ /**从安全Set中 移除当前连接对象*/ webSocketSet.remove(this); try { channel.queueDelete("deviceInfo_" + accountId); connection.close(); } catch (IOException e) { log.error(e.getMessage()); @@ -122,7 +123,6 @@ @OnMessage public void onMessage(String message) { System.out.println(message); for (WebSocketServer webSocketServer : webSocketSet) { webSocketServer.sendMessage(message); }