websocket-放开消息发送

dk-modules/sample/src/main/java/org/dromara/sample/websocket/service/impl/WebSocketMessageServiceImpl.java

@@ -92,9 +92,9 @@ public class WebSocketMessageServiceImpl implements IWebSocketMessageService {
 //                    return;
                     continue;
                 }
-//                session.sendMessage(data);//数据发送 //关闭数据
+                session.sendMessage(data);//数据发送 //关闭数据
 
-                String token = parseTokenFromQuery(session.getUri().getQuery());
+               /* String token = parseTokenFromQuery(session.getUri().getQuery());
 //                System.out.println("tok"+token);
 //                String newToken = "eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJsb2dpblR5cGUiOiJsb2dpbiIsImxvZ2luSWQiOiJzeXNfdXNlcjoxIiwicm5TdHIiOiJMVUoxUGUzczNMVGNndHkzTVI1SFRRV3NUcjdWamlsSSIsImNsaWVudGlkIjoiZTVjZDdlNDg5MWJmOTVkMWQxOTIwNmNlMjRhN2IzMmUiLCJ0ZW5hbnRJZCI6IjAwMDAwMCIsInVzZXJJZCI6MSwidXNlck5hbWUiOiJhZG1pbiIsImRlcHRJZCI6MiwiZGVwdE5hbWUiOiLmsZ_oi4_nnIEiLCJkZXB0Q2F0ZWdvcnkiOiIifQ.5SX070r1cmmQGbEmd9MMD88XnLDJ8wPJ5LvddJ3cn_Y";
 //                System.out.println(ObjectUtil.equals(token,newToken));
@@ -112,7 +112,7 @@ public class WebSocketMessageServiceImpl implements IWebSocketMessageService {
                 if(ObjectUtil.isNotEmpty(snStr) && Arrays.asList(snSplit).contains(targetDockSn) ){
 //                if(ObjectUtil.isNotEmpty(sn)){
                     session.sendMessage(data);//数据发送
-                }
+                }*/
 
 //                boolean keyExist = RedisOpsUtils.checkExist(keyPrefix + ":" + token);
 //                if (keyExist) {