轉自https://blog.csdn.net/u013174217/article/details/53376793

websocketstompclient端實現和服務端建立連線和通訊之後，如果服務端斷開或重啟，client端需要實現自動定時重連機制。

查閱了官網和一些資料沒有找到相關的原始碼，自己寫了個：

在client端重寫StompSessionHandlerAdapter的類中重寫handleTransportError方法：

1. @Override
2. publicvoid handleTransportError(StompSession session, Throwable exception) {  
3.     if
    (exception instanceof ConnectionLostException || !isConnected) {  
4.         // if connection lost, call this
5.         isConnected = false;  
6.         while (!isConnected) try {  
7.             Thread.sleep(5000);  
8.             //new connect--start
9.             WebSocketClient webSocketClient = new SockJsClient(transports);  
10.             WebSocketStompClient stompClient = new WebSocketStompClient(webSocketClient);  
11.             stompClient.setInboundMessageSizeLimit(size);  
12.             stompClient.setMessageConverter(new MappingJackson2MessageConverter());  
13.             stompClient.setTaskScheduler(new DefaultManagedTaskScheduler()); 
    // for heartbeats
14.             stompClient.connect(url, wsHeaders, sessionHandler);  
15.             //new connect--end
16.             isConnected = true;  
17.         } catch (Exception e) {  
18.             logger.error("error {}", e.getMessage());  
19.         }  
20.     }  
21. }  

程式碼解釋：WebSocketStompClient的connect失敗後會被這個方法捕獲並處理，此處捕獲ConnectionLostException錯誤，則每隔5秒重新建立連線。

                  建立connect即new connect的程式碼區域為建立client連線的地方，需要根據程式碼情況自己修改。

執行之後服務端斷開，client端會每隔5s發起一次連線，連線失敗則報錯。如果服務端啟動後，client端則會正常連線成功。

以上這種方法，並不是一種很好的方法，

更好的是

ListenableFuture<StompSession> future = stompClient.connect(url, logHandler);
try {
    session = future.get();
    session.setAutoReceipt(true);
}
catch (Exception e) {
    e.printStackTrace();
}

每隔2秒鐘，boolean connected = session.isConnected();

如果為false就，重新呼叫一次connect