wifi 关闭并再次打开时 Websocket 重新连接问题

Question

我遇到了 websocket 重新连接的问题。第一次启动应用程序时，创建 websocket 连接没有问题。然后我关闭 wifi，几秒钟后我再次打开 wifi，我在 onFailure 回调中得到以下异常。

WS onFailure javax.net.ssl.SSLException: Read error: ssl=0xbf4618c0: I/O error during system call, Software caused connection abort
    E/Mqtt: WS onFailure java.io.InterruptedIOException: executor rejected
E/Mqtt: WS onFailure java.io.InterruptedIOException: executor rejected
E/Mqtt: WS onFailure java.io.InterruptedIOException: executor rejected
E/Mqtt: WS onFailure java.io.InterruptedIOException: executor rejected
E/Mqtt: WS onFailure java.io.InterruptedIOException: executor rejected

这是我的连接方法：

public fun connect()
{
    if(mConnecting)
        return

    mConnecting = true

    val request = Request.Builder().url(mSocketUrl).build()

    mWebSocket = mOkHttpClient.newWebSocket(request, this)
    mOkHttpClient.dispatcher().executorService().shutdown()

}

这里是 websocket onFailure 回调

override fun onFailure(webSocket: WebSocket?, t: Throwable, response: Response?)
{
    Log.e(TAG, "WS onFailure $t")

    mConnecting = false
    reconnect()
}

这是我的重新连接方法

    public fun reconnectMqtt()
    {
        if(mStopping)
            return

        if(mMqttConnection == null)
        {
            startMqtt()
            return
        }

        if(!mMqttConnection!!.mConnecting)
        {
//            mMqttConnection = null
//            startMqtt()

            Handler(Looper.getMainLooper()).postDelayed({
                mMqttConnection!!.connect()
            }, 1000)
        }
    }

我搜索了很多但没有得到任何帮助。任何帮助将不胜感激。提前致谢！！

Answer 1

问题出在连接方法中的下面这一行。

mOkHttpClient.dispatcher().executorService().shutdown()

关闭方法不允许我重新连接 websocket。这是释放资源所必需的。我将此方法调用转移到服务 onDestroy。

wifi 关闭并再次打开时 Websocket 重新连接问题

Websocket reconnecting issue when wifi turned off and turned on again

ssl

android

websocket

mqtt

okhttp