From f0922a2eef3fc68676fe86a89fa971759c0e579a Mon Sep 17 00:00:00 2001 From: yangyang Date: Fri, 10 Apr 2026 17:45:14 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9:=20webscoket=E5=BF=83?= =?UTF-8?q?=E8=B7=B3=E6=A3=80=E6=B5=8B=E4=BC=98=E5=8C=96=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E7=BB=93=E6=9E=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/sdm/system/controller/WebSocketServer.java | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/system/src/main/java/com/sdm/system/controller/WebSocketServer.java b/system/src/main/java/com/sdm/system/controller/WebSocketServer.java index d88f1b3e..49a3224e 100644 --- a/system/src/main/java/com/sdm/system/controller/WebSocketServer.java +++ b/system/src/main/java/com/sdm/system/controller/WebSocketServer.java @@ -1,6 +1,6 @@ package com.sdm.system.controller; -import com.fasterxml.jackson.databind.ObjectMapper; +import com.alibaba.fastjson2.JSONObject; import com.sdm.common.common.ThreadLocalContext; import com.sdm.common.common.WsMessage; import com.sdm.common.common.WsSceneEnum; @@ -9,7 +9,6 @@ import jakarta.websocket.server.PathParam; import jakarta.websocket.server.ServerEndpoint; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; -import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.util.ArrayList; @@ -27,9 +26,6 @@ public class WebSocketServer { // ==================== 修复后:一个用户对应多个Session ==================== public static final Map> USER_SESSION_POOL = new ConcurrentHashMap<>(); - @Autowired - private ObjectMapper objectMapper; - // ==================== 连接建立 ==================== @OnOpen public void onOpen(Session session, @PathParam("userId") Long userId) { @@ -86,7 +82,7 @@ public class WebSocketServer { String json=""; try { // 1. 用Jackson序列化泛型对象,支持泛型 - json = objectMapper.writeValueAsString(backMessage); + json = JSONObject.toJSONString(backMessage); } catch (Exception e) { log.error("心跳检测失败,WebSocket消息序列化失败,userId:{},scene:{}.-->", backMessage.getUserId(),backMessage.getScene(), e); return;