在 Java 中实现 WebSocket 心跳有多种方式，我将为你介绍两种常见的实现方式，并提供示例代码以及相关的依赖坐标。
这种方式使用 Java 自带的 javax.websocket 包来实现 WebSocket 心跳。
步骤流程：
javax.websocket.Endpoint 接口，并实现其 onOpen() 方法来处理 WebSocket 连接。onOpen() 方法中，创建一个定时任务（比如使用 ScheduledExecutorService ）来定期发送心跳消息到客户端。示例代码：
// 服务端端点类
import javax.websocket.*;
import java.io.IOException;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
@javax.websocket.server.ServerEndpoint("/heartbeat")
public class HeartbeatEndpoint {
private ScheduledExecutorService executorService;
@OnOpen
public void onOpen(Session session) {
executorService = Executors.newSingleThreadScheduledExecutor();
executorService.scheduleAtFixedRate(() -> {
try {
session.getBasicRemote().sendText("Heartbeat");
} catch (IOException e) {
e.printStackTrace();
}
}, 0, 10, TimeUnit.SECONDS);
}
@OnClose
public void onClose() {
if (executorService != null) {
executorService.shutdown();
}
}
@OnMessage
public void onMessage(String message, Session session) throws IOException {
if ("HeartbeatResponse".equals(message)) {
// 处理心跳回复
// ...
}
}
}
在这个例子中，服务端每隔 10 秒向客户端发送心跳消息 "Heartbeat"，然后客户端收到消息后发送心跳回复 "HeartbeatResponse"。
Maven 依赖坐标：
<dependency>
<groupId>javax.websocket</groupId>
<artifactId>javax.websocket-api</artifactId>
<version>1.1</version>
</dependency>
Tyrus 是一个提供 WebSocket 实现的库，可以简化 WebSocket 的开发。
步骤流程：
示例代码：
// 客户端代码
import org.glassfish.tyrus.client.ClientManager;
import javax.websocket.*;
import java.io.IOException;
import java.net.URI;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class HeartbeatClient {
public static void main(String[] args) throws Exception {
ClientManager clientManager = ClientManager.createClient();
ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();
executorService.scheduleAtFixedRate(() -> {
try {
Session session = clientManager.connectToServer(HeartbeatClientEndpoint.class, new URI("ws://localhost:8080/heartbeat"));
session.getBasicRemote().sendText("Heartbeat");
} catch (Exception e) {
e.printStackTrace();
}
}, 0, 10, TimeUnit.SECONDS);
}
}
// 客户端端点类
@ClientEndpoint
public class HeartbeatClientEndpoint {
@OnMessage
public void onMessage(String message, Session session) throws IOException {
if ("HeartbeatResponse".equals(message)) {
// 处理心跳回复
// ...
}
}
}
Maven 依赖坐标：
<dependency>
<groupId>org.glassfish.tyrus</groupId>
<artifactId>tyrus-client</artifactId>
<version>1.17</version>
</dependency>
这两种方式都可以用来实现 WebSocket 的心跳功能，选择哪种方式取决于你的项目需求和偏好。请根据实际情况进行调整和扩展。
