diff --git a/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/message/websocket/WebSocket.java b/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/message/websocket/WebSocket.java index 5d8cc9cf97252b76ef001f1da65f53046378fbfe..497b1193c64c969160a765f1a136391b8b7b418b 100644 --- a/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/message/websocket/WebSocket.java +++ b/jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/message/websocket/WebSocket.java @@ -13,6 +13,8 @@ import javax.websocket.server.ServerEndpoint; import org.springframework.stereotype.Component; +import com.alibaba.fastjson.JSONObject; + import lombok.extern.slf4j.Slf4j; @Component @@ -48,7 +50,11 @@ public class WebSocket { @OnMessage public void onMessage(String message) { - log.info("【websocket消息】收到客户端消息:"+message); + //log.info("【websocket消息】收到客户端消息:"+message); + JSONObject obj = new JSONObject(); + obj.put("cmd", "heartcheck");//业务类型 + obj.put("msgTxt", "心跳响应");//消息内容 + session.getAsyncRemote().sendText(obj.toJSONString()); } // 此为广播消息