如何检查Websocket连接是否处于活动状态
如何检查Websocket连接是否处于活动状态
提问于 2018-05-01 21:21:20
我有一个到服务器的websocket连接：
import javax.websocket.*;
import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;
@ClientEndpoint
public class WebsocketExample {
private Session userSession;
private void connect() {
try {
WebSocketContainer container = ContainerProvider.getWebSocketContainer();
container.connectToServer(this, new URI("someaddress"));
} catch (DeploymentException | URISyntaxException | IOException e) {
e.printStackTrace();
}
}
@OnOpen
public void onOpen(Session userSession) {
// Set the user session
this.userSession = userSession;
System.out.println("Open");
}
@OnClose
public void onClose(Session userSession, CloseReason reason) {
this.userSession = null;
System.out.println("Close");
}
@OnMessage
public void onMessage(String message) {
// Do something with the message
System.out.println(message);
}
}过了一段时间后，我似乎没有从服务器收到更多的消息，但是onClose方法还没有被调用。
我希望有一种计时器，如果我在过去的五分钟内没有收到任何消息，它至少会记录一个错误(并且最多尝试重新连接)。当我收到新消息时，定时器将被重置。
我该怎么做呢？
回答 2
Stack Overflow用户
回答已采纳
发布于 2018-05-01 22:07:18
这就是我所做的。我通过jetty更改了javax.websocket，并实现了一个ping调用：
import org.eclipse.jetty.util.ssl.SslContextFactory;
import org.eclipse.jetty.websocket.api.Session;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketClose;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketConnect;
import org.eclipse.jetty.websocket.api.annotations.OnWebSocketMessage;
import org.eclipse.jetty.websocket.api.annotations.WebSocket;
import org.eclipse.jetty.websocket.client.WebSocketClient;
import java.io.IOException;
import java.net.URI;
import java.nio.ByteBuffer;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
@WebSocket
public class WebsocketExample {
private Session userSession;
private final ScheduledExecutorService executorService = Executors.newScheduledThreadPool(1);
private void connect() {
try {
SslContextFactory sslContextFactory = new SslContextFactory();
WebSocketClient client = new WebSocketClient(sslContextFactory);
client.start();
client.connect(this, new URI("Someaddress"));
} catch (Exception e) {
e.printStackTrace();
}
}
@OnWebSocketConnect
public void onOpen(Session userSession) {
// Set the user session
this.userSession = userSession;
System.out.println("Open");
executorService.scheduleAtFixedRate(() -> {
try {
String data = "Ping";
ByteBuffer payload = ByteBuffer.wrap(data.getBytes());
userSession.getRemote().sendPing(payload);
} catch (IOException e) {
e.printStackTrace();
}
},
5, 5, TimeUnit.MINUTES);
}
@OnWebSocketClose
public void onClose(int code, String reason) {
this.userSession = null;
System.out.println("Close");
}
@OnWebSocketMessage
public void onMessage(String message) {
// Do something with the message
System.out.println(message);
}
}编辑：这只是一个ping示例...我不知道是否所有的服务器都应该通过pong应答...
Edit2：下面是如何处理pong消息。诀窍不是监听字符串消息，而是帧消息：
@OnWebSocketFrame
@SuppressWarnings("unused")
public void onFrame(Frame pong) {
if (pong instanceof PongFrame) {
lastPong = Instant.now();
}
}为了管理服务器超时，我修改了计划任务，如下所示：
scheduledFutures.add(executorService.scheduleAtFixedRate(() -> {
try {
String data = "Ping";
ByteBuffer payload = ByteBuffer.wrap(data.getBytes());
userSession.getRemote().sendPing(payload);
if (lastPong != null
&& Instant.now().getEpochSecond() - lastPong.getEpochSecond() > 60) {
userSession.close(1000, "Timeout manually closing dead connection.");
}
} catch (IOException e) {
e.printStackTrace();
}
},
10, 10, TimeUnit.SECONDS));..。并在onClose方法中处理重新连接
Stack Overflow用户
发布于 2018-05-12 18:17:42
您应该通过实现一个心跳系统来解决此问题，该系统的一端发送ping，另一端使用pong应答。据我所知，几乎每个websocket客户端和服务器都在内部支持此功能。此ping/pong帧可以从两端发送。我通常在服务器端实现它，因为我通常知道它比客户端有更好的存活机会(我的观点)。如果客户端很长一段时间没有发回pong，我就知道连接已经死了。在客户端，我进行了同样的检查:如果服务器很长时间没有发送ping消息，我知道连接是死的。
如果您使用的库中没有实现ping/pong (我认为javax websocket已经实现了)，那么您可以为此制定自己的协议。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/50117284
复制相关文章
相似问题
腾讯云开发者
