|
|
@@ -13,6 +13,7 @@ import okio.ByteString;
|
|
|
|
|
|
import java.io.EOFException;
|
|
|
import java.net.ConnectException;
|
|
|
+import java.net.ProtocolException;
|
|
|
|
|
|
/**
|
|
|
* @author reghao
|
|
|
@@ -59,7 +60,9 @@ public class WebSocketListenerImpl extends WebSocketListener {
|
|
|
@Override
|
|
|
public void onFailure(WebSocket webSocket, Throwable throwable, Response response) {
|
|
|
log.info("WebSocket 异常事件: {}", throwable.toString());
|
|
|
- if (throwable instanceof ConnectException || throwable instanceof EOFException) {
|
|
|
+ if (throwable instanceof ConnectException
|
|
|
+ || throwable instanceof EOFException
|
|
|
+ || throwable instanceof ProtocolException) {
|
|
|
wsClient.setConnected(false);
|
|
|
if (wsClient.isRetry()) {
|
|
|
reconnect();
|