OkHttp WebSocket RejectedExecutionException 尝试重新启动时答案

【问题标题】：OkHttp WebSocket RejectedExecutionException when try to restartOkHttp WebSocket RejectedExecutionException 尝试重新启动时
【发布时间】：2022-07-28 19:55:40
【问题描述】：

我有这个客户：

OkHttpClient okHttpClient = new OkHttpClient.Builder()
            .pingInterval(Duration.ofMinutes(3))
            .readTimeout(Duration.ofMillis(0))
            .build();

还有这个启动和停止的方法：

private WebSocket webSocket = null;
private MyListener wsListener = null;

private void start(){

    if(webSocket != null){ return; }

    wsListener = new MyListener();

    Request request = new Request.Builder()
        .url("wss://stream.binance.com:9443/ws")
        .build();

    webSocketBinance = okHttpClient.newWebSocket(request, wsListener); //here triggers error

}

private void stop(){

    if(webSocket == null){ return; }

    webSocket.close(1000, "{\"reason\": \"With love\"}");
    webSocket= null;

    okHttpClient.dispatcher().executorService().shutdown();
    okHttpClient.connectionPool().evictAll();

    wsListener = null;

}

有时我想像这样重新启动连接：

start();

Thread.sleep(10_000);

//restart connection
stop();
start(); //here triggers the error

但是在start() 我得到这个错误：

java.io.InterruptedIOException: executor rejected
    at okhttp3.internal.connection.RealCall$AsyncCall.executeOn(RealCall.kt:501)
    at okhttp3.Dispatcher.promoteAndExecute(Dispatcher.kt:184)
    at okhttp3.Dispatcher.enqueue$okhttp(Dispatcher.kt:125)
    at okhttp3.internal.connection.RealCall.enqueue(RealCall.kt:164)
    at okhttp3.internal.ws.RealWebSocket.connect(RealWebSocket.kt:165)
    at okhttp3.OkHttpClient.newWebSocket(OkHttpClient.kt:281)
    at foo.Foo.start(...)

Caused by: 
java.util.concurrent.RejectedExecutionException: 
    Task okhttp3.internal.connection.RealCall$AsyncCall@2aceadd4 rejected from 
    java.util.concurrent.ThreadPoolExecutor@24aed80c
    [Shutting down, pool size = 1, active threads = 1, queued tasks = 0, completed tasks = 0]
    
at java.base/java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2080)
    
at java.base/java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:832)
    
at java.base/java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1365)
    
at okhttp3.internal.connection.RealCall$AsyncCall.executeOn(RealCall.kt:498)
    
... 8 more

【问题讨论】：

我对 OKHttp 不是很了解，但在我看来，罪魁祸首可能是.readTimeout(Duration.ofMillis(0))。尝试将 0 增加到 10 000。它现在崩溃之前需要十秒钟吗？
@LajosArpad，在文档中说如果我将其设置为 0，则意味着没有超时。
你测试了吗？
@LajosArpad，是的，我做到了，但仍然是同样的错误。
明白。很遗憾，我无法为您提供更多帮助。

标签： java websocket okhttp

【解决方案1】：

我的解决方案是每次我想重新启动时创建一个新的OkHttpClient 和WebSocket。

【讨论】：