我有一个简单的 Java WebSocket 客户端。有时与 WebSocket 服务器的连接可能会丢失。连接丢失后如何自动重连?
import javax.websocket.*;
import java.net.URI;
@ClientEndpoint
public class WebsocketClientEndpoint {
Session userSession = null;
public WebsocketClientEndpoint(URI endpointURI) {
try {
WebSocketContainer container = ContainerProvider.getWebSocketContainer();
container.connectToServer(this, endpointURI);
} catch (Exception e) {
throw new RuntimeException(e);
}
}
@OnOpen
public void onOpen(Session userSession) {
System.out.println("Opening websocket");
this.userSession = userSession;
}
@OnClose
public void onClose(Session userSession, CloseReason reason) {
System.out.println("Closing websocket");
this.userSession = null;
}
@OnMessage
public void onMessage(String message) {
System.out.println("Received message: "+ message);
}
public void sendMessage(String message) {
this.userSession.getAsyncRemote().sendText(message);
}
}
测试应用
import java.net.URI;
import java.net.URISyntaxException;
public class TestApp {
public static void main(String[] args) {
try {
final WebsocketClientEndpoint clientEndPoint = new WebsocketClientEndpoint(new URI("ws://localhost:8080/websocket/api"));
while (true) {
Thread.sleep(30000);
}
} catch (Exception ex) {
System.err.println("Exception: " + ex.getMessage());
}
}
}
java中有简单的WebSocket客户端和测试类。有时与 WebSocket 服务器的连接可能会丢失。连接丢失后如何自动重连?
最佳答案
重新连接不属于 WebSocket JSR 356 Specs并且必须通过编写具体的逻辑来实现。
但是,您可以使用具有 ReconnectHandler 的客户端库,例如“Tyrus”。 基本上,它有 APIS 来捕获 onDisconnect 、 onConnectFailure 等事件,可用于重新连接。
请参阅此链接了解如何使用它:Tyrus Reconnect Handler
关于java - 如何在java中重新连接websocket?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56544437/