android 心跳包的分析

90 阅读 0 评论 60 点赞

我是靠谱客的博主完美机器猫，最近开发中收集的这篇文章主要介绍android 心跳包的分析，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

android 心跳的分析

最近在做一个项目中用到了心跳包的机制，其实就是传统的长连接。或许有的人知道消息推送的机制，消息推送也是一种长连接，是将数据有服务器端推送到客户端这边从而改变传统的“拉”的请求方式。下面我来介绍一下安卓和客户端两个数据请求的方式

1、push 这个也就是有服务器推送到客户端这边现在有第三方技术比如极光推送。

2、pull 这种方式就是客户端向服务器发送请求数据（http请求）

接下来我就给大家介绍 Socket tcp心跳包的机制虽然这块不是很难，找一些网上的资料不是很全面这个模块参照一个朋友的功能模块自己也受益匪浅，现在分享给大家。

一、首先服务器和客户端有一次“握手”

public void connect()

      {
       LogUtil.e(TAG, "准备链接...");
       InetAddress serverAddr;
       try {
           socket = new Socket(Config.Host, Config.SockectPort);
           _connect = true;
           mReceiveThread = new ReceiveThread();
           receiveStop = false;
           mReceiveThread.start();
           LogUtil.e(TAG, "链接成功.");

       } catch (Exception e) {
           LogUtil.e(TAG, "链接出错." + e.getMessage().toString());
           e.printStackTrace();
       }
   }

二、下面就要开启一个线程去不断读取服务器那边传过来的数据采用Thread去实现

     private class ReceiveThread extends Thread {
       private byte[] buf;
       private String str = null;

       @Override
       public void run() {
           while (true) {
               try {
                   // LogUtil.e(TAG, "监听中...:"+socket.isConnected());
                   if (socket!=null && socket.isConnected()) {

                       if (!socket.isInputShutdown()) {
                           BufferedReader inStream = new BufferedReader(
                                   new InputStreamReader(
                                           socket.getInputStream()));
                           String content = inStream.readLine();
                           if (content == null)
                               continue;
                           LogUtil.e(TAG, "收到信息:" + content);
                           LogUtil.e(TAG, "信息长度:"+content.length());
                           if (!content.startsWith("CMD:"))
                               continue;
                           int spacePos = content.indexOf(" ");
                           if (spacePos == -1)
                               continue;
                           String cmd = content.substring(4, spacePos);
//                           String body = StringUtil.DecodeBase64(content
//                                   .substring(spacePos));
                           String body = content.substring(spacePos).trim();
                           LogUtil.e(TAG, "收到信息(CMD):" + cmd);
                           LogUtil.e(TAG, "收到信息(BODY):" + body);

if (cmd.equals("LOGIN"))

                           {
                               // 登录
                               ReceiveLogin(body);
                               continue;
                           }

                              if (cmd.equals("KEEPLIVE")) {
                               if (!body.equals("1")) {
                                   Log.e(TAG, "心跳时检测到异常，重新登录!");
                                   socket = null;
                                   KeepAlive();
                               } else {
                                   Date now = Calendar.getInstance().getTime();
                                   lastKeepAliveOkTime = now;
                               }
                               continue;
                           }
                       }
                   } else {
                       if(socket!=null)
                           LogUtil.e(TAG, "链接状态:" + socket.isConnected());
                   }

               } catch (Exception e) {
                   LogUtil.e(TAG, "监听出错:" + e.toString());
                   e.printStackTrace();
               }
           }
       }

三、 Socket 是否断开了断开了需要重新去连接

public void KeepAlive()

        {
       // 判断socket是否已断开,断开就重连
       if (lastKeepAliveOkTime != null) {
           LogUtil.e(
                   TAG,
                   "上次心跳成功时间:"
                           + DateTimeUtil.dateFormat(lastKeepAliveOkTime,
                                   "yyyy-MM-dd HH:mm:ss"));
           Date now = Calendar.getInstance().getTime();
           long between = (now.getTime() - lastKeepAliveOkTime.getTime());// 得到两者的毫秒数
           if (between > 60 * 1000) {
               LogUtil.e(TAG, "心跳异常超过1分钟,重新连接:");
               lastKeepAliveOkTime = null;
               socket = null;
           }

       } else {
           lastKeepAliveOkTime = Calendar.getInstance().getTime();
       }

       if (!checkIsAlive()) {
           LogUtil.e(TAG, "链接已断开,重新连接.");
           connect();
           if (loginPara != null)
               Login(loginPara);
       }

//此方法是检测是否连接

      boolean checkIsAlive() {
       if (socket == null)
           return false;
       try {
           socket.sendUrgentData(0xFF);
       } catch (IOException e) {
           return false;
       }
       return true;

   }

//然后发送数据的方法

    public void sendmessage(String msg) {
       if (!checkIsAlive())
           return;
       LogUtil.e(TAG, "准备发送消息:" + msg);
       try {
           if (socket != null && socket.isConnected()) {
               if (!socket.isOutputShutdown()) {
                   PrintWriter outStream = new PrintWriter(new BufferedWriter(
                           new OutputStreamWriter(socket.getOutputStream())),
                           true);

                   outStream.print(msg + (char) 13 + (char) 10);
                   outStream.flush();
               }
           }
           LogUtil.e(TAG, "发送成功!");
       } catch (Exception e) {
           e.printStackTrace();
       }
   }