bug fix

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

      */
     @OnClose
     public void onClose() {
-        webSocketSet.remove(this);
-        subOnlineCount();
+        removeFromSets();
         log.info("有一连接关闭！当前在线人数为" + getOnlineCount());
     }
 
 
         JSONObject jsnMsg = JSONObject.parseObject(message);
 
-        if ( null == ChatServer.taChatService) {
+        if (null == ChatServer.taChatService) {
             ChatServer.taChatService = applicationContext.getBean(ITaChatService.class);
         }
         System.out.println("收到的聊天消息的信息=========" + jsnMsg.toJSONString());
     public void onError(Session session, Throwable error) {
         log.error("发生错误");
         error.printStackTrace();
-        webSocketSet.remove(this);
+        removeFromSets();
     }
 
     /**
         this.session.getBasicRemote().sendText(message);
     }
 
+    private void removeFromSets() {
+        for(ChatServer c: webSocketSet) {
+            if (sid.equals(c.sid)) {
+                webSocketSet.remove(c);
+                subOnlineCount();
+            }
+        }
+    }
+
     /**
      * 发自定义消息
      * */