Android上保持Socket长连接

作者: CokeNello | 来源:发表于2018-01-07 21:25 被阅读1737次

    0.Thanks

    性能优化十六之Wake_Lock唤醒锁以及JobScheduler使用
    安卓 java 判断socket断开
    android保持服务不休眠(持续运行)以及唤醒屏幕的方法
    Android API 19 及以上版本AlarmManager setRepeating 不准或只执行一次的解决方案

    1.概述

    前阵子接到一个用户反馈说,公司的一款机器人,很容易掉线。这款产品上,跑的是Android5.1系统,用的是Socket与自己服务器保持着长链接。于是开始排查问题。。。

    我们知道,一般我们在客户端上使用心跳协议,跟服务器保持着长连接。所以,先从这里下手,怀疑是服务器心跳协议那段代码有问题。然后实际上不是。

    后面继续找,发现了几个问题:

    • 问题1,心跳包是客户端发送的,而服务器收到心跳包是没有回包的,这样会存在一个情况,有时候因网络原因,心跳包一直有发送,但客户端并不知道是否成功,而使得socket链接被服务器判定为超时,就被服务器断开了。

    • 问题2,接着上面的问题,socket被服务器判断为超时,服务器主动断开socket,但是,客户端并没有收到fin包,也就是socket断开的信号。为啥没有收到4次挥手,嗯,有机会要深究。

    • 问题3,发送心跳包是有间隔的,并不是一支持续地发送,但从客户端本地的日志来看,发现在锁屏的时候,心跳包的发送并不是按照程序那样子去跑。程序写的是每5分钟跑一次心跳,但是,锁屏后,这个时间就不是5分钟,有可能是10分钟

    2.解决问题1:修改心跳协议

    心跳协议是让双方知道,双方都在线,既然是双方,心跳也应该是有回包的。所以,后面把心跳协议改成,服务器收到心跳包,也应该回一个收到心跳包的通知。考虑到有时候,会因为网络的缘故,会丢包,所以,在客户端上增加重试的逻辑。所以现在变成,先发送心跳包,在N秒内若没有收到回复,则再发送一次。重试M次。

    3.解决问题2:判断socket是否已经断开了

    1)isClosed()、isConnected()、isInputStreamShutdown()、isOutputStreamShutdown()方法来判断

    • 这种方式只是本地判断,只是本地操作connect()或close()方法后保存的一个状态,
      对于远程服务器主动断开就没有用了

    2)sendUrgentData()判断远程服务器是否断开Socket

    • 往输出流发送一个字节的数据,只要对方Socket的SO_OOBINLINE属性没有打开,就会自动舍弃这个字节,SO_OOBINLINE属性默认情况下就是关闭的!

    • 但是,经测试,这个方法行不通。但网上说这个方法有用,唉,可能我的是假socket。

    3)通过OutputStream.write

    • 有人说,发送心跳协议的时候,try catch一下,如果有报异常,就说明是断开了。实际并不然,实际测试中,
      服务器断开socket,还是可以发包,并且不会报异常

    既然以上的办法都无法判断,只能依靠心跳协议了,只要服务器没有按心跳的逻辑回包,就判断已经断开并主动去链接。实际测试中,修该后的心跳协议,是可以很好地保持长链接。

    4.解决问题3:系统休眠定时器不准

    系统锁屏后一段时间,系统会进入一个休眠状态,此状态下,系统会把线程挂起,所以Timer定时器会不准确。

    清楚问题了,就好解决。可以通过以下解决:

    1)准确定时

    • 系统休眠导致定时器不准备,那有没有办法可以让定时器正常工作呢?有!
      在API19,可以这样做,亲测起效,还有,你还需监听此Action的广播:
    /**
    * 设置定时器
    * @param timeMs    毫秒,既是,多少毫秒后,触发
    * @param action    触发,以广播形式,传入广播的action
    */
    private void setAlarm(int timeMs,String action) {
       try {
           AlarmManager am = (AlarmManager) XHoneyBotApplicationLike.getInstance().getApplication().getSystemService(Context.ALARM_SERVICE);
           Intent intent = new Intent(action);
           PendingIntent sender = PendingIntent.getBroadcast(XHoneyBotApplicationLike.getInstance().getApplication(), 0, intent,PendingIntent.FLAG_CANCEL_CURRENT);
           if (am!=null) {
               if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.KITKAT) {
                   //参数2是开始时间、参数3是允许系统延迟的时间
                   am.setWindow(AlarmManager.RTC, System.currentTimeMillis() + timeMs, 500, sender);
               } else {
                   am.setRepeating(AlarmManager.RTC, System.currentTimeMillis() + timeMs, 500, sender);
               }
           }
       } catch (Exception e){
           e.printStackTrace();
       }
    }
    /**
    * 取消对应action的定时器
    * @param action    action
    */
    private void canalAlarm(String action,Context context) {
       try {
           Intent intent = new Intent(action);
           PendingIntent pi = PendingIntent.getBroadcast(context.getApplicationContext(), 0, intent,PendingIntent.FLAG_CANCEL_CURRENT);
           AlarmManager am = (AlarmManager) context.getApplicationContext().getSystemService(Context.ALARM_SERVICE);
           if (am!=null)
               am.cancel(pi);
       } catch (Exception e){
           e.printStackTrace();
       }
    }
    

    2)添加唤醒锁

    • 在Android中还有一种唤醒锁的机制,详情可以百度学习一下。其实大概就是,你可以使用唤醒锁
      强制让系统不进行休眠!
    /**
     * Thanks:  http://blog.csdn.net/wzj0808/article/details/52608940
     * 保持系统CUP Active
     */
    private static PowerManager.WakeLock wl;
    public static void setCPUAliveLock(Context context) {
        try {
            if (wl!=null)
                releaseKeepAliveOnScreenOff();
            PowerManager pm = (PowerManager) context.getApplicationContext().getSystemService(Context.POWER_SERVICE);
            if (pm!=null) {
                wl = pm.newWakeLock(PowerManager.PARTIAL_WAKE_LOCK, "ScreenOff");
                wl.acquire();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    public static void releaseCPUAliveLock() {
        try {
            if (wl!=null)
                wl.release();
            wl = null;
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    

    唤醒后,CPU处于ACTIVE状态,然后执行任务,执行完成后,便释放锁。

    PS,如果在锁屏的时候,一直唤醒CPU,在实际应用中,会出现一个非常严重的问题:耗电!
    所以,推介是,使用定时器,在定时器定触发的时候,唤醒CPU,进行心跳,心跳逻辑跑完后,就释放锁。

    相关文章

      网友评论

      • 天选之盆:你的方法三星手机是稳的,很多国产手机应该是不稳定的。
        全程强制使用PowerManager,显然不可行,耗电量太大了。
        而AlarmManager,无论是setWindow还是setRepeating,断开USB线,关屏一段时间后,都会逐渐失效。华为Mate7,Mate8都会出现。
        另外socket长连接,阻塞式收数据时:
        socket.getInputStream().read(receiveTemp)
        正常来说当服务端主动发消息过来时,它就会触发。实际上关屏拔线后一段时间,它就不触发了,再打开APP界面时,直接进入IOException里。
        11284e2b9e3c:@tgvincent 三星Android 6.0 可以, 红米5Plus Android 7.0 没问题, 荣耀9Lite Android 8.0 不行
        11284e2b9e3c:非常赞同, 真机测试的确是如此, 国产ROM的Doze, 特别是Android 8.0, 网络依然会被挂起.
      • 因帅被判刑:您好 有没有demo
        CokeNello:@因帅被判刑 没有……
      • Taozii:假如发完心跳释放锁,设备进入休眠了,还能处理Socket过来的命令吗
        CokeNello:这个应该要看设备,感觉不同厂商会不同。在我手上的机器(原生Android5.1),进入休眠了,能处理Socket的包。收到包信息后,我会获取唤醒锁,执行完后释放。其他设备要具体看。
      • 码农朱同学:还有各种设备适配的大坑
        CokeNello:@zhuxh 😪都是心酸
      • d3b602e70cc9:都是之前遇到的问题.
        天门一只猿:@kangjinwen 哥们我现在跟你一样,但还是会出现,省电模式下,socket断开的问题
        d3b602e70cc9:@栗子酱油饼 我最后更换的Mina框架,配合 wl.acquire();你这样操作应该也把问题解决了
        CokeNello:@kangjinwen 都是过来人,不知道我这边做法有啥不妥的地方?😁

      本文标题:Android上保持Socket长连接

      本文链接:https://www.haomeiwen.com/subject/arwmnxtx.html