Cool
/
Chat
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改接受数据Bug，对Json字符串进行了解析

This commit is contained in:
Cool 2023-11-25 17:18:07 +08:00
parent 1c84d4faa4
commit b4155bec4f
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/com/example/chat/service/websocket/WebSocketServer.java
View File

@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSON;
import com.example.chat.dao.chat.ChatMapper; import com.example.chat.dao.chat.ChatMapper;
import com.example.chat.dao.chat.ChatMessage; import com.example.chat.dao.chat.ChatMessage;
import com.example.chat.entity.chat.Message; import com.example.chat.entity.chat.Message;
import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.CrossOrigin; import org.springframework.web.bind.annotation.CrossOrigin;
@ -38,7 +39,11 @@ public class WebSocketServer {
@OnMessage @OnMessage
public void onMessage(String message) throws IOException { 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); chatMapper.addMessage(message1);
List<Message> messageList = chatMapper.getMessage(); List<Message> messageList = chatMapper.getMessage();
sendAllSession(messageList); sendAllSession(messageList);