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

Posted 2023-03-22

【中文标题】wifi关闭并再次打开时Websocket重新连接问题

【英文标题】：Websocket reconnecting issue when wifi turned off and turned on again

【发布时间】：2020-04-28 02:09:58

【问题描述】：

我遇到了 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)
        
    

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

【问题讨论】：

出于任何原因，您要重新连接自己，而不是让 MQTT 客户端库（paho？）为您完成。

mqtt 是如何自动做到这一点的？

重新连接是 Paho MQTT 库中的内置功能

所以你建议我不要在 onFailure 中调用 reconnect 方法

我试过了，但它没有重新连接，我已经实现了 MqttCallbackExtended 监听器来重新连接状态，但是这个监听器没有调用

【参考方案1】：

问题在于连接方法中的以下行。

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

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