El cliente de Websocket de Spring no detecta la pérdida de conexión de red.

El cliente de websocket @ClientEndpoint de Spring no detecta la desconexión de red debido a un desenchufe del cable. También he implementado un mecanismo de ping/pong. ¿Alguien puede ayudarme con lo que está sucediendo?

Sin embargo, veo la siguiente excepción después de volver a conectar el cable, para su información, todas las configuraciones están por defecto. Además, me estoy conectando a un punto final remoto de terceros donde no tengo ningún control.


xxxxxException: cerrado con el código: CLOSED_ABNORMALLY reason: CloseReason: código [1006], motivo [java.io.IOException: Connection reset by peer]
en xxxxxx.onClose(WSClient.java:xx)


@ClientEndpoint
public class WSClient {
private Session session;
private int i = 0;

@OnOpen
public void open(Session session) {
System.out.println(“Conectado al servidor”);
this.session = session;
}

@OnClose
public void close(Session session, CloseReason closeReason) {
System.out.println(“conexión cerrada ” + closeReason.getReasonPhrase());
}

@OnError
public void error(Session session, Throwable t) {
System.out.println(session.getId());
System.out.println(“Error en la conexión ” + t.getMessage());
}

@OnMessage
public void message(Session session, String message) {
System.out.println(“mensaje recibido: ” + message + ” ” + i++);
}

public void send(String message){
try {
if(session.isOpen()) {
this.session.getBasicRemote().sendPing(ByteBuffer.wrap(message.getBytes()));
System.out.println(“el socket está abierto ” + i++);
} else {
System.out.println(“socket cerrado”);
}
} catch (IOException e) {
e.printStackTrace();
}
}
}

@Component
public class ClientApp implements ApplicationListener {

private void startConnection() throws Exception {
WebSocketContainer container = ContainerProvider.getWebSocketContainer();
WSClient client = new WSClient();
container.connectToServer(client, new URI(“ws://wshost:8080/ping”));

while (true) {
    client.send("ping");
    TimeUnit.SECONDS.sleep(3);
}

}

@Override
public void onApplicationEvent(ApplicationReadyEvent event) {
try {
startConnection();
} catch (Exception e) {
System.out.println(e);
}
}
}