即时通讯：socket 那些你不知道的事 - 心跳

Posted 2023-05-05

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了即时通讯：socket 那些你不知道的事 - 心跳相关的知识，希望对你有一定的参考价值。

参考技术A

首先说下心跳包的主要作用是告知对方连接端，我还活着，心还在跳。

所以，如上所述，如果NAT超时，连接被运营商移除，连接就会中断，而实际上, 根据网上的一些说法, 中移动2/3G下, NAT超时时间为5分钟, 中国电信3G则大于28分钟, 理想的情况下, 客户端应当以略小于NAT超时时间的间隔来发送心跳包.

Android Socket通讯之心跳消息

前言

不知道大家国庆节过的咋样，有没有学习呢？我是闲着没事就写点东西，本文篇幅较短，只是实现了心跳消息的处理，下面进入正文。

正文

先说说为什么要增加心跳消息，Socket在连接过程中会发生很多的意外，比如网络问题、连接不上、ip地址不对、异常断连，而心跳消息说白了就是通过指定时间去收发消息，通过收发消息就能知道连接双方处于什么状态。知道是什么状态就知道该怎么处理。

一、状态判断

在开始写之前我们需要先知道状态有哪些，直接在IOException中进行处理。

			catch (e: IOException) 
                e.printStackTrace()
                when (e) 
                    is SocketTimeoutException -> 
                        Log.e(TAG, "连接超时，正在重连")
                    
                    is NoRouteToHostException -> 
                        Log.e(TAG, "该地址不存在，请检查")
                    
                    is ConnectException -> 
                        Log.e(TAG, "连接异常或被拒绝，请检查")
                    
                    is SocketException -> 
                        when (e.message) 
                            "Already connected" -> Log.e(TAG, "连接异常或被拒绝，请检查")
                            "Socket closed" -> Log.e(TAG, "连接已关闭")

这里就可以直接做处理，我打印了日志，你可以在连接过程中，进行测试，这段代码添加的位置如下图所示：

这个代码对于服务端和客户端都一样。

二、心跳消息发送

心跳消息需要在什么时候发送呢？在客户端连接了服务端之后，由客户端发起心跳消息，进入SocketClient，增加如下代码：

	private const val HEART_SPACETIME = 3 * 1000

    private val mHandler: Handler = Handler()

这里定义了一个心跳间隔时间，也就是说，3秒发送一次心跳，下面写一个发送心跳的方法。

	private val mHeartRunnable = Runnable  sendHeartbeat() 

    /**
     * 发送心跳消息
     */
    private fun sendHeartbeat() 
        if (clientThreadPool == null) 
            clientThreadPool = Executors.newSingleThreadExecutor()
        
        val msg = "洞幺洞幺，呼叫洞拐，听到请回答，听到请回答，Over!"
        clientThreadPool?.execute 
            if (socket == null) 
                mCallback.otherMsg("客户端还未连接")
                return@execute
            
            if (socket!!.isClosed) 
                mCallback.otherMsg("Socket已关闭")
                return@execute
            
            outputStream = socket?.getOutputStream()
            try 
                outputStream?.write(msg.toByteArray())
                outputStream?.flush()
                //发送成功以后，重新建立一个心跳消息
                mHandler.postDelayed(mHeartRunnable, HEART_SPACETIME.toLong())
                Log.i(TAG, msg)
             catch (e: IOException) 
                e.printStackTrace()
                mCallback.otherMsg("向服务端发送消息: $msg 失败")

心跳消息中我定义了消息的内容，服务端收到这个内容就表示为心跳消息，这个消息内容还是有待商榷的，先实现功能就行，在这里发送消息之后，进行延时发送下一次心跳消息，这里打印了发送的心跳消息了，因为是连接到服务端之后就开始发送，所以还需要在connectServer()函数中处理，增加代码如下图所示：

最后就是处理服务端回复的服务端消息，修改ClientThread中的代码如下图所示：

这里判断一下服务端回复的内容是什么，如果是我们想要的内容就表明这是一个心跳消息，则只打印就行了，不需要回调的页面上进行显示，这里的内容因为你可能也会在输入框输入，所以会存在问题。

三、心跳消息回复

当服务端收到客户端发送的心跳时就要回复消息给客户端，这样客户端就知道服务端一直都在，服务端的代码就相对来说简单很多了，在SocketServer中增加一个函数，代码如下：

	fun replyHeartbeat() 
        if (serverThreadPool == null) 
            serverThreadPool = Executors.newCachedThreadPool()
        
        val msg = "洞拐收到，洞拐收到，Over!"
        serverThreadPool?.execute 
            if (socket == null) 
                mCallback.otherMsg("客户端还未连接")
                return@execute
            
            if (socket!!.isClosed) 
                mCallback.otherMsg("Socket已关闭")
                return@execute
            
            outputStream = socket!!.getOutputStream()
            try 
                outputStream.write(msg.toByteArray())
                outputStream.flush()
             catch (e: IOException) 
                e.printStackTrace()
                mCallback.otherMsg("向客户端发送消息: $msg 失败")