diff --git a/src/main/java/com/example/chat/service/websocket/WebSocketServer.java b/src/main/java/com/example/chat/service/websocket/WebSocketServer.java index 7dc7ae6..9df7e5d 100644 --- a/src/main/java/com/example/chat/service/websocket/WebSocketServer.java +++ b/src/main/java/com/example/chat/service/websocket/WebSocketServer.java @@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSON; import com.example.chat.dao.chat.ChatMapper; import com.example.chat.dao.chat.ChatMessage; import com.example.chat.entity.chat.Message; +import com.fasterxml.jackson.databind.ObjectMapper; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; import org.springframework.web.bind.annotation.CrossOrigin; @@ -38,7 +39,11 @@ public class WebSocketServer { @OnMessage public void onMessage(String message) throws IOException { - Message message1 = JSON.parseObject(message, Message.class); + ObjectMapper objectMapper=new ObjectMapper(); + + Message message1 = objectMapper.readValue(message,Message.class); + log.info("Message+{}",message1); + log.info("webMessage{}",message); chatMapper.addMessage(message1); List messageList = chatMapper.getMessage(); sendAllSession(messageList);