Весенний websocket клиент stomp, как захватить соединение, потерян?

Question

Я использую spring websocket клиент stomp. Ниже приведен фрагмент кода:

List<Transport> transports = new ArrayList<Transport>(2); 
transports.add(new WebSocketTransport(new StandardWebSocketClient())); 
transports.add(new RestTemplateXhrTransport()); 

WebSocketHttpHeaders headers = new WebSocketHttpHeaders(); 
headers.add("Cookie", client.getCookieString()); 

SockJsClient sockJsClient = new SockJsClient(transports); 

WebSocketStompClient stompClient = new WebSocketStompClient(sockJsClient); 
stompClient.setMessageConverter(new StringMessageConverter()); 
ListenableFuture<StompSession> future = 
    stompClient.connect(configuration.getApp().getWebsocketServerBase() + "/websocket/sa", headers, new MyWebSocketHandler()); 

future.addCallback(new SuccessCallback<StompSession>() { 
    public void onSuccess(StompSession stompSession) { 
     System.out.println("on Success!"); 
    } 
}, new FailureCallback() { 
    public void onFailure(Throwable throwable) { 
     System.out.println("on Failure!"); 
    } 
}); 

Он работает, но когда сервер WebSocket закрыт, клиент не получает сообщение.

Как прослушать события закрытия сервера?

Answer 1

Я нашел решение.

MyWebSocketHandler реализует StompSessionHandler так:

private class MyWebSocketHandler implements StompSessionHandler { 
    @Override 
    public void afterConnected(StompSession stompSession, StompHeaders stompHeaders) { 

    } 

    @Override 
    public void handleException(StompSession stompSession, StompCommand stompCommand, StompHeaders stompHeaders, byte[] bytes, Throwable throwable) { 
    } 

    @Override 
    public void handleTransportError(StompSession stompSession, Throwable throwable) { 
     if (throwable instanceof ConnectionLostException) { 
      // if connection lost, call this 
     } 
    } 

    @Override 
    public Type getPayloadType(StompHeaders stompHeaders) { 
     return null; 
    } 

    @Override 
    public void handleFrame(StompHeaders stompHeaders, Object o) { 
    } 
} 

Вы можете увидеть метод handleTransportError. Спасибо.

Ссылка Spring WebSocket Document 25.4.13 STOMP Client.

Answer 2

Я думаю, вы могли бы также поймать SessionDisconnectEvent:

SessionDisconnectEvent - опубликована, когда ТОПАЙТЕ сессия заканчивается. DISCONNECT может быть отправлен от клиента, или он также может быть автоматически сгенерирован при закрытии сеанса WebSocket. В некоторых случаях это событие может быть опубликовано более одного раза за сеанс. Компоненты должны быть идемпотентными в отношении нескольких событий отключения.