bug

src/main/java/com/huiju/estateagents/websocket/ChatServer.java

@@ -48,6 +48,7 @@ public class ChatServer {
      * 连接建立成功调用的方法*/
     @OnOpen
     public void onOpen(Session session,@PathParam("sid") String sid) {
+        removeSameFromSets(sid);
         this.session = session;
         webSocketSet.add(this);
         addOnlineCount();
@@ -61,7 +62,6 @@ public class ChatServer {
     @OnClose
     public void onClose() {
         removeFromSets();
-        log.info("有一连接关闭！当前在线人数为" + getOnlineCount());
     }
 
     /**
@@ -120,6 +120,17 @@ public class ChatServer {
             if (sid.equals(c.sid)) {
                 webSocketSet.remove(c);
                 subOnlineCount();
+                log.info("有一连接关闭:"+sid+"！当前在线人数为" + getOnlineCount());
+            }
+        }
+    }
+
+    private void removeSameFromSets(String currentSid) {
+        for(ChatServer c: webSocketSet) {
+            if (currentSid.equals(c.sid)) {
+                webSocketSet.remove(c);
+                subOnlineCount();
+                log.info("有一连接关闭:"+sid+"！当前在线人数为" + getOnlineCount());
             }
         }
     }