8.7

liugl

2020-08-08 df9083f10ffaf993bc23a3dcee248a0ad406aa68

 app/src/main/java/com/okgoincar/base/MyApplication.kt

@@ -76,6 +76,9 @@
    }

    private fun initSocket() {
        Handler(Looper.getMainLooper()).post {
            toast("websocket初始化")
        }
        NettyClient.getInstance().init(this, Api.SOCKET_SERVER, Api.SOCKET_PORT, true)
        NettyClient.getInstance()
            .addOnMessageListener { message: String? ->
@@ -85,9 +88,9 @@
                    currentTime = System.currentTimeMillis()
                    val json = JSONObject(message)
                    val method = json.optString("method")
//                    Handler(Looper.getMainLooper()).post {
//                        toast("收到websocket=$method")
//                    }
                    Handler(Looper.getMainLooper()).post {
                        toast("收到websocket=$method")
                    }
                    val data = json.optString("data")
                    val code = json.optInt("code", -1)
                    if (code == 200) {
@@ -159,6 +162,7 @@
            .setOnConnectListener {
                sendHeart()
            }
        sendHeart()
    }

    override fun attachBaseContext(base: Context?) {
@@ -266,7 +270,7 @@
        }
    }

    private fun sendHeart() {
    open fun sendHeart() {
        if (getUserId() != -1) {
            Log.i(TAG, "sendHeart: userId === " + getUserId())
            val bean = HeartBean()
@@ -282,7 +286,8 @@
            if ((System.currentTimeMillis() - currentTime) / 1000 > 30) {
                sysErr("sendHeart_websocket 重新连接")
                currentTime = System.currentTimeMillis()
                NettyClient.getInstance().checkNettyState()
//                NettyClient.getInstance().checkNettyState()
                initSocket()
                heartHandler!!.postDelayed({ sendHeart() }, 5000)
            } else {
                sysErr("sendHeart_websocket 发送心跳")