春季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客户端。

Answer 2

我想你也能赶上SessionDisconnectEvent：

SessionDisconnectEvent - 出版时STOMP会话结束。 DISCONNECT可能已从客户端发送，或者也可能在WebSocket会话关闭时自动生成。在某些情况下，此事件可能会在每个会话中多次发布。对于多个断开连接事件，组件应该是幂等的。