转发服务代码提交

soc-modules/soc-modules-mediator/src/main/java/com/xunmei/mediator/websocket/handler/SocWebSocketHandler.java

@@ -1,7 +1,6 @@
 package com.xunmei.mediator.websocket.handler;
 
 import cn.hutool.core.util.ObjectUtil;
-import com.alibaba.fastjson.JSONObject;
 import com.alibaba.fastjson2.JSON;
 import com.xunmei.common.core.domain.iot.domain.IotServerInfo;
 import com.xunmei.common.core.enums.iot.IotServerConnectStatus;
@@ -11,6 +10,7 @@ import com.xunmei.mediator.api.server.service.IotServerInfoService;
 import com.xunmei.mediator.websocket.constant.WebSocketConstants;
 import com.xunmei.mediator.websocket.dto.WebsocketExecuteReq;
 import com.xunmei.mediator.websocket.dto.WebsocketResult;
+import com.xunmei.mediator.websocket.enums.TopicTypeEnums;
 import com.xunmei.mediator.websocket.enums.WebsocketStatus;
 import com.xunmei.mediator.websocket.holder.WebSocketSessionHolder;
 import com.xunmei.mediator.websocket.service.RouterService;
@@ -102,7 +102,7 @@ public class SocWebSocketHandler extends AbstractWebSocketHandler {
      * @throws Exception 处理消息过程中可能抛出的异常
      */
     @Override
-    protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
+   /* protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
         // 从WebSocket会话中获取登录用户信息
         WebSocketSessionHolder.updateToken(session);
         String payload = message.getPayload();
@@ -136,9 +136,9 @@ public class SocWebSocketHandler extends AbstractWebSocketHandler {
         }
 
 
-    }
+    }*/
 
-    /*protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
+    protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
         // 从WebSocket会话中获取登录用户信息
         WebSocketSessionHolder.updateToken(session);
         String payload = message.getPayload();
@@ -194,7 +194,7 @@ public class SocWebSocketHandler extends AbstractWebSocketHandler {
         }
 
 
-    }*/
+    }
 
     /**
      * 处理接收到的二进制消息

soc-modules/soc-modules-mediator/src/main/java/com/xunmei/mediator/websocket/service/RouterService.java

@@ -6,6 +6,7 @@ import com.xunmei.mediator.websocket.enums.ProductEnums;
 public interface RouterService {
 
     ProductEnums product();
+
     String routerKey();
 
     Object execute(WebsocketExecuteReq req);