思路

在我之前的一篇文章當中寫到了websocket的實時刷新，但是有個問題沒有解決，就是長時間沒有數據的時候，這個連接就會自動斷開，然后再次進行連接的話，需要再次進行連接。如果加入心跳機制的話，10秒鐘客戶端向服務端發送數據，服務端接收到數據，發條消息，告訴客戶端我還在，客戶端接收到消息，知道我們還是連接的狀態，就沒有必要再進行連接。如果客戶端發送的消息，服務端沒有對這個消息進行響應，則說明已經斷開連接，則需要重新連接。

服務端代碼如下：

package cn.lsmsp.alarm.snmp.config;

import com.alibaba.fastjson.JSON;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.stereotype.Component;

import javax.websocket.*;

import javax.websocket.server.PathParam;

import javax.websocket.server.ServerEndpoint;

import java.time.LocalDateTime;

import java.util.HashMap;

import java.util.Map;

import java.util.concurrent.CopyOnWriteArraySet;

@Component

@ServerEndpoint("/websocket/{shopId}")

//此注解相當于設置訪問URL

public class WebSocket {

private Logger logger = LoggerFactory.getLogger(WebSocket.class);

private Session session;

private static CopyOnWriteArraySetwebSockets = new CopyOnWriteArraySet<>();

private static MapsessionPool = new HashMap();

@OnOpen

public void onOpen(Session session, @PathParam(value = "shopId") String shopId) throws InterruptedException {

this.session = session;

webSockets.add(this);

// sessionPool.put(shopId, session);

// System.out.println("【websocket消息】有新的連接，總數為:"+webSockets.size());

System.out.println("【websocket消息】有新的連接啦！！！"+LocalDateTime.now());

// webSocketXdxService.xdxTest(shopId);

}

@OnClose

public void onClose(Session session) {

try {

webSockets.remove(this);

session.close();

System.out.println("【websocket消息】連接斷開，總數為:" + webSockets.size());

} catch (Exception e) {

e.printStackTrace();

}

}

@OnMessage

public void onMessage(String message) {

logger.info("【websocket消息】收到客戶端消息:" + message);

Mapmaps = new HashMap<>();

maps.put("type", message);

this.sendAllMessage(JSON.toJSONString(maps));

}

// 此為廣播消息

public void sendAllMessage(String message) {

for (WebSocket webSocket : webSockets) {

System.out.println("【websocket消息】廣播消息:" + message);

try {

webSocket.session.getAsyncRemote().sendText(message);

} catch (Exception e) {

e.printStackTrace();

}

}

}

// 此為單點消息 (發送文本)

public void sendTextMessage(String shopId, String message) {

Session session = sessionPool.get(shopId);

if (session != null) {

try {

session.getBasicRemote().sendText(message);

} catch (Exception e) {

e.printStackTrace();

}

}

}

// 此為單點消息 (發送對象)

public void sendObjMessage(String shopId, Object message) {

Session session = sessionPool.get(shopId);

if (session != null) {

try {

session.getAsyncRemote().sendObject(message);

} catch (Exception e) {

e.printStackTrace();

}

}

}

}

相對于上次，結合我這邊的業務進行了調整，刪除了session的存儲，就變成了一個用戶多個聊天窗口的那種概念。

客戶端代碼如下：

測試webSocket

相對于刪上次，加入了心跳的時間。這樣的話客戶端會收到兩種類型的數據，heartbeat和sendMessage，便于區別哪個是心跳數據，哪個是發送的數據。還有一點，我這里是https的請求，如果你是http請求的話，把wss://127.0.0.1:9231改為ws://127.0.0.1:9231。其它想知道的，參考我之前的一篇文章：springboot websocket 實時刷新(親測可用版)

總結

以上是生活随笔為你收集整理的springboot心跳检测_springboot websocket 实时刷新 添加心跳机制（亲测可用版）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。