websocket如何检测session的存活时间

WebSocket 是一种基于 TCP 协议的全双工通信协议，在建立连接后可以保持长时间的连接。在使用 WebSocket 时，通常需要检测客户端的会话（session）是否过期，以及断开已经过期的会话。

一种常见的做法是使用心跳机制来检测客户端的会话存活时间。具体的做法是，在客户端和服务器端之间定时发送一个心跳包（ping），如果客户端一段时间内没有响应，就认为会话已经过期，关闭 WebSocket 连接。

在客户端，可以使用 JavaScript 中的 `setInterval()` 方法定时发送心跳包。例如，以下代码可以每隔 30 秒向服务器发送一个心跳包：

var pingInterval = setInterval(function() {
  // 发送心跳包
  websocket.send("ping");
}, 30000);

在服务器端，可以接收到客户端发送的心跳包，并在一定时间内判断客户端的会话是否过期。以下是一个示例代码：

@OnMessage
public void onMessage(Session session, String message) {
    if ("ping".equals(message)) {
        // 收到客户端的心跳包，更新最后活动时间
        session.getUserProperties().put("last_active_time", System.currentTimeMillis());
        // 向客户端发送一个 pong 包
        session.getAsyncRemote().sendText("pong");
    } else if ("pong".equals(message)) {
        // 收到客户端的 pong 包，表示客户端存活
        session.getUserProperties().put("last_active_time", System.currentTimeMillis());
    }
}

@OnClose
public void onClose(Session session, CloseReason reason) {
    // WebSocket 连接关闭时，清除会话的状态信息
    session.getUserProperties().remove("last_active_time");
}

@OnError
public void onError(Session session, Throwable error) {
    // WebSocket 发生错误时，关闭连接并清除会话的状态信息
    session.getUserProperties().remove("last_active_time");
    session.close();
}

// 检查会话存活时间的方法
public boolean isSessionAlive(Session session) {
    Object lastActiveTime = session.getUserProperties().get("last_active_time");
    if (lastActiveTime != null) {
        long currentTime = System.currentTimeMillis();
        long lastTime = (long) lastActiveTime;
        return (currentTime - lastTime) < SESSION_TIMEOUT;
    } else {
        return false;
    }
}

在上述代码中，`onMessage()` 方法用于接收客户端发送的消息，在收到客户端的心跳包时更新会话的最后活动时间，并向客户端发送一个 pong 包。`onClose()` 方法用于处理 WebSocket 连接关闭的情况，在连接关闭时清除会话的状态信息。`onError()` 方法用于处理 WebSocket 发生错误的情况，在发生错误时关闭连接并清除会话的状态信息。

除此之外，还定义了一个 `isSessionAlive()` 方法，用于判断会话是否存活。该方法通过读取会话的最后活动时间，并将其与当前时间进行比较，来判断会话是否过期。如果会话过期，就需要关闭 WebSocket 连接，并清除会话的状态信息。

需要注意的是，在实际应用中，需要根据具体的需求和业务场景来设置心跳包的发送间隔和会话的过期时间。过短的心跳包发送间隔可能会降低系统的性能，而过长的心跳包发送间隔可能会影响会话的实时性。同时，也需要定期检查会话的状态，及时关闭已经过期的会话。