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