java websocketclient 心跳

Java WebSocket Client中的心跳检测是一种保持连接活跃状态的技术，通常用于防止因长时间无数据传输而导致的连接关闭。WebSocket协议本身并不强制实施心跳机制，但是作为客户端，开发者可能会选择定期发送空闲消息（ping）到服务器，然后等待服务器响应（pong），以此验证连接是否正常。

在Java中，使用WebSocket API如`javax.websocket`，可以创建一个自定义的`MessageHandler`来处理心跳操作。下面是一个简单的示例：

import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import java.net.URI;

public class HeartbeatClient {
    private Session session;

    @OnOpen
    public void onOpen(Session session) {
        this.session = session;
        // 开始定时发送心跳
        session.getAsyncRemote().sendText("ping");
        startHeartbeat();
    }

    private void startHeartbeat() {
        Runnable heartbeatTask = () -> {
            while (true) {
                try {
                    session.getBasicRemote().sendText("ping"); // 发送ping请求
                    Thread.sleep(HEARTBEAT_INTERVAL); // 设置心跳间隔时间，比如5秒
                } catch (Exception e) {
                    handleConnectionFailure();
                    break;
                }
            }
        };
        new Thread(heartbeatTask).start(); // 异步执行心跳任务
    }

    @OnMessage
    public void onMessage(String message) {
        if ("pong".equals(message)) { // 如果接收到pong，则继续心跳
            continueHeartbeat();
        } else {
            System.out.println("Received unexpected message: " + message);
        }
    }

    @OnClose
    public void onClose(int code, String reason) {
        System.out.println("Connection closed: " + reason);
        stopHeartbeat();
    }

    @OnError
    public void onError(Throwable error) {
        System.err.println("An error occurred: " + error.getMessage());
        stopHeartbeat();
    }

    private synchronized void stopHeartbeat() {
        if (session != null && !isHeartbeatRunning()) {
            session.close();
        }
    }

    private boolean isHeartbeatRunning() {
        return heartBeatThread != null && heartBeatThread.isAlive();
    }

    // ... 其他相关方法
}

在这个例子中，`startHeartbeat()`方法启动了一个后台线程定期发送心跳，并在`onMessage()`中检查是否接收到服务器的pong回应。如果接收到，就调用`continueHeartbeat()`继续下一次心跳；如果接收的是其他消息或遇到错误，会停止心跳并关闭连接。