diff --git a/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/config/WebSocketHandlerConfig.java b/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/config/WebSocketHandlerConfig.java index c591a7914..4c7809709 100644 --- a/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/config/WebSocketHandlerConfig.java +++ b/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/config/WebSocketHandlerConfig.java @@ -2,6 +2,7 @@ package com.pig4cloud.pigx.common.websocket.config; import com.pig4cloud.pigx.common.websocket.custom.PigxSessionKeyGenerator; import com.pig4cloud.pigx.common.websocket.custom.UserAttributeHandshakeInterceptor; +import com.pig4cloud.pigx.common.websocket.handler.CustomPlanTextMessageHandler; import com.pig4cloud.pigx.common.websocket.handler.CustomWebSocketHandler; import com.pig4cloud.pigx.common.websocket.handler.PingJsonMessageHandler; import com.pig4cloud.pigx.common.websocket.handler.PlanTextMessageHandler; @@ -40,6 +41,12 @@ public class WebSocketHandlerConfig { return new UserAttributeHandshakeInterceptor(); } + @Bean + @ConditionalOnMissingBean(PlanTextMessageHandler.class) + public PlanTextMessageHandler planTextMessageHandler() { + return new CustomPlanTextMessageHandler(); + } + @Bean @ConditionalOnMissingBean({ TextWebSocketHandler.class, PlanTextMessageHandler.class }) public WebSocketHandler webSocketHandler1(@Autowired(required = false) SessionKeyGenerator sessionKeyGenerator) { diff --git a/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/handler/CustomPlanTextMessageHandler.java b/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/handler/CustomPlanTextMessageHandler.java new file mode 100644 index 000000000..b2685b0b4 --- /dev/null +++ b/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/handler/CustomPlanTextMessageHandler.java @@ -0,0 +1,25 @@ +package com.pig4cloud.pigx.common.websocket.handler; + +import lombok.extern.slf4j.Slf4j; +import org.springframework.web.socket.WebSocketSession; + +/** + * @author lengleng + * @date 2021/11/4 + * + * 默认消息处理 + */ +@Slf4j +public class CustomPlanTextMessageHandler implements PlanTextMessageHandler { + + /** + * 普通文本消息处理 + * @param session 当前接收消息的session + * @param message 文本消息 + */ + @Override + public void handle(WebSocketSession session, String message) { + log.info("sessionId {} ,msg {}", session.getId(), message); + } + +} diff --git a/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/handler/PlanTextMessageHandler.java b/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/handler/PlanTextMessageHandler.java index 12267d196..38c6808c9 100644 --- a/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/handler/PlanTextMessageHandler.java +++ b/pigx-common/pigx-common-websocket/src/main/java/com/pig4cloud/pigx/common/websocket/handler/PlanTextMessageHandler.java @@ -5,7 +5,7 @@ import org.springframework.web.socket.WebSocketSession; /** * 普通文本类型(非指定json类型)的消息处理器 即消息不满足于我们定义的Json类型消息时,所使用的处理器 * - * @see JsonWebSocketMessage + * @see com.pig4cloud.pigx.common.websocket.message.JsonWebSocketMessage * @author Hccake 2021/1/5 * @version 1.0 */