github
/
jeecg-boot
mirror of https://github.com/jeecgboot/jeecg-boot
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

websocket会自动断开，断开时，发送通知公告无法推送 #457

pull/811/head
zhangdaihao 2019-08-28 20:03:49 +08:00
parent 6c3c24fe17
commit 527007f74b
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
jeecg-boot/jeecg-boot-module-system/src/main/java/org/jeecg/modules/message/websocket/WebSocket.java
View File

@ -13,6 +13,8 @@ import javax.websocket.server.ServerEndpoint;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
@Component @Component
@ -48,7 +50,11 @@ public class WebSocket {
@OnMessage @OnMessage
public void onMessage(String message) { 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());
} }
// 此为广播消息 // 此为广播消息