Spring Websocket Stomp-Client, wie die Verbindung zu erfassen ist verloren

Question

Ich benutze spring websocket Stomp-Client. Unten ist ein Codefragment:

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!"); 
    } 
}); 

Es funktioniert, aber wenn websocket Server geschlossen ist, wird der Client nicht die Nachricht empfangen.

Wie zum Listener Server schließen Ereignis?

Answer 1

Ich habe die Lösung gefunden.

MyWebSocketHandler implementiert StompSessionHandler wie folgt aus:

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) { 
    } 
} 

Sie Methode handleTransportError sehen können. Vielen Dank.

Referenz Spring WebSocket Document 25.4.13 STOMP-Client.

Answer 2

Ich glaube, Sie auch SessionDisconnectEvent fangen können:

SessionDisconnectEvent - veröffentlicht, wenn eine STOMP Sitzung beendet. Der DISCONNECT wurde möglicherweise vom Client gesendet oder wird beim Schließen der WebSocket-Sitzung automatisch generiert. In einigen Fällen kann dieses Ereignis mehr als einmal pro Sitzung veröffentlicht werden. Komponenten sollten in Bezug auf mehrere Disconnect-Ereignisse idempotent sein.