Browse Source

Merge branch 'music_score'

Joburgess 4 years ago
parent
commit
fff9fa89f2

+ 5 - 5
mec-biz/src/main/java/com/ym/mec/biz/handler/WebSocketHandler.java

@@ -73,7 +73,6 @@ public class WebSocketHandler extends AbstractWebSocketHandler {
 
 
     @Override
     @Override
     protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
     protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
-        super.handleTextMessage(session, message);
         String phone = session.getPrincipal().getName().split(":")[1];
         String phone = session.getPrincipal().getName().split(":")[1];
         LOGGER.info("{}: {}", phone, message.getPayload());
         LOGGER.info("{}: {}", phone, message.getPayload());
         WebSocketInfo webSocketInfo = JSON.parseObject(message.getPayload(), WebSocketInfo.class);
         WebSocketInfo webSocketInfo = JSON.parseObject(message.getPayload(), WebSocketInfo.class);
@@ -118,7 +117,6 @@ public class WebSocketHandler extends AbstractWebSocketHandler {
 
 
     @Override
     @Override
     protected void handleBinaryMessage(WebSocketSession session, BinaryMessage message) throws Exception {
     protected void handleBinaryMessage(WebSocketSession session, BinaryMessage message) throws Exception {
-        super.handleBinaryMessage(session, message);
         String phone = session.getPrincipal().getName().split(":")[1];
         String phone = session.getPrincipal().getName().split(":")[1];
         if(!userSoundInfoMap.containsKey(phone)){
         if(!userSoundInfoMap.containsKey(phone)){
             return;
             return;
@@ -158,11 +156,13 @@ public class WebSocketHandler extends AbstractWebSocketHandler {
 
 
     @Override
     @Override
     public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
     public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
-        super.handleTransportError(session, exception);
-        exception.printStackTrace();
         String phone = session.getPrincipal().getName().split(":")[1];
         String phone = session.getPrincipal().getName().split(":")[1];
-        LOGGER.info("发生了错误,移除客户端: {}", phone);
         session.close();
         session.close();
+        if(!WS_CLIENTS.containsKey(phone)){
+            return;
+        }
+        exception.printStackTrace();
+        LOGGER.info("发生了错误,移除客户端: {}", phone);
         WS_CLIENTS.remove(phone);
         WS_CLIENTS.remove(phone);
         createHeader(phone);
         createHeader(phone);
     }
     }