很多App要做到极致的话,对网络状态的监听是很有必要的,比如在网络差的时候加载质量一般的小图,缩略图,在网络好的时候,加载高清大图,脸书的android 客户端就是这么做的,

当然伟大的脸书也把这部分代码开源出来,今天就来带着大家分析一下脸书的这个开源代码。

GitHub 地址https://github.com/facebook/network-connection-class

注意这个项目下载下来以后 会报很多错误,导致很多人运行不了,大家要根据各自电脑不同的情况修改gradle脚本,才能让他运行。

如果有人对gradle不熟悉的话 可以下载我编写好的gradle脚本 直接放在你项目的根目录下即可。

地址在

http://pan.baidu.com/s/1pJuxesz

注意下载以后替换完成 把项目里为数不多的注解代码给删除即可正常运行,另外请自己查毒,中毒不要来找我~

下面来看下源码,其实大部分的代码还是很简单的,

首先从MainActivity 代码来看

  /**
      * AsyncTask for handling downloading and making calls to the timer.
      */
     private class DownloadImage extends AsyncTask<String, Void, Void> {

         @Override
         protected void onPreExecute() {
             mDeviceBandwidthSampler.startSampling();
             mRunningBar.setVisibility(View.VISIBLE);
         }

         @Override
         protected Void doInBackground(String... url) {
             String imageURL = url[0];
             try {
                 // Open a stream to download the image from our URL.
                 InputStream input = new URL(imageURL).openStream();
                 try {
                     byte[] buffer = new byte[1024];

                     // Do some busy waiting while the stream is open.
                     while (input.read(buffer) != -1) {
                     }
                 } finally {
                     input.close();
                 }
             } catch (IOException e) {
                 Log.e(TAG, "Error while downloading image.");
             }
             return null;
         }

         @Override
         protected void onPostExecute(Void v) {
             mDeviceBandwidthSampler.stopSampling();
             // Retry for up to 10 times until we find a ConnectionClass.
             if (mConnectionClass == ConnectionQuality.UNKNOWN && mTries < 10) {
                 mTries++;
                 new DownloadImage().execute(mURL);
             }
             if (!mDeviceBandwidthSampler.isSampling()) {
                 mRunningBar.setVisibility(View.GONE);
             }
         }
     }

主要就是通过上面的 这个task 来访问一个网络上的图片,然后计算 “瞬时“流量。

然后到DeviceBandwidthSampler来看这个方法

  /**
      * Method call to start sampling for download bandwidth.
      */
     public void startSampling() {
         if (mSamplingCounter.getAndIncrement() == 0) {
             mHandler.sendEmptyMessage(SamplingHandler.MSG_START);
             long lastTimeReading = SystemClock.elapsedRealtime();
             mLastTimeReading = lastTimeReading;
         }
     }

这个lastTimeReading 实际上就代表这一次请求发起的时间,大家可以看到这里去了Samplinghandler,注意他是子线程的消息队列~

 private class SamplingHandler extends Handler {
         static final int MSG_START = 1;
         static final int MSG_STOP = 2;

         public SamplingHandler(Looper looper) {
             super(looper);
         }

         @Override
         public void handleMessage(Message msg) {
             switch (msg.what) {
                 case MSG_START:
                     addSample();
                     sendEmptyMessageDelayed(MSG_START, SAMPLE_TIME);
                     break;
                 case MSG_STOP:
                     addFinalSample();
                     removeMessages(MSG_START);
                     break;
                 default:
                     throw new IllegalArgumentException("Unknown what=" + msg.what);
             }
         }

看11-15行,实际上就是不断的在调用add Sample这个函数,当我们那个DownloadTask 任务完成以后 就会发MSG_STOP消息。

然后addFinalSample 这个过程就完成了(即代表本次对网络状态的监听完成)。

好,我们就来看看这个add Sample做了什么

 /**
          * Method for polling for the change in total bytes since last update and
          * adding it to the BandwidthManager.
          */
         private void addSample() {
             long byteDiff = QTagParser.getInstance().parseDataUsageForUidAndTag(Process.myUid());
             synchronized (this) {
                 long curTimeReading = SystemClock.elapsedRealtime();
                 if (byteDiff != -1) {
                     mConnectionClassManager.addBandwidth(byteDiff, curTimeReading - mLastTimeReading);
                 }
                 mLastTimeReading = curTimeReading;
             }
         }

这边代码也很好理解,实际上第六航,byteDiff 就是代表 获取了多少流量,单位是byte。

然后7-12行 就是用这个byteDiff 和你算出来的时间差,这2个值,来算你的瞬时网络状态。

第10行 就是算这个网络状态的,第10行的代码 我不准备深入分析,因为这个是FACEBOOK对网络状态的定义,

大家在使用的时候 并不一定要按照他的来,比如他认为100k/s是网络糟糕,但是我们4g网络这么烂,可能50kb 就认为网络很好了。所以这个地方代码

以后有时间大家要根据自己的公司业务来调整。我们主要要看byteDiff 这个值是怎么算出来的,实际上这个才是代码的精髓。

 /**
      * Reads the qtaguid file and returns a difference from the previous read.
      *
      * @param uid The target uid to read bytes downloaded for.
      * @return The difference between the current number of bytes downloaded and
      */
     public long parseDataUsageForUidAndTag(int uid) {
         // The format of each line is
         // idx iface acct_tag_hex uid_tag_int cnt_set rx_bytes rx_packets tx_bytes
         // (There are many more fields but we are not interested in them)
         // For us parts: 1, 2, 3 are to see if the line is relevant
         // and part 5 is the received bytes
         // (part numbers start from 0)

         // Permit disk reads here, as /proc/net/xt_qtaguid/stats isn't really "on
         // disk" and should be fast.
         StrictMode.ThreadPolicy savedPolicy = StrictMode.allowThreadDiskReads();
         try {
             long tagRxBytes = 0;

             FileInputStream fis = new FileInputStream(mPath);
             //sStatsReader.setFileStream(fis);
             // writeFileToSD(sStatsReader);
             sStatsReader.setFileStream(fis);
             byte[] buffer = sLineBuffer.get();
             try {
                 int length;
                 sStatsReader.readLine(buffer);
                 sStatsReader.skipLine(); // skip first line (headers)

                 int line = 2;
                 while ((length = sStatsReader.readLine(buffer)) != -1) {
                     try {

                         // Content is arranged in terms of:
                         // idx iface acct_tag_hex uid_tag_int cnt_set rx_bytes rx_packets tx_bytes tx_packets rx_tcp_bytes
                         // rx_tcp_packets rx_udp_bytes rx_udp_packets rx_other_bytes rx_other_packets tx_tcp_bytes tx_tcp_packets
                         // tx_udp_bytes tx_udp_packets tx_other_bytes tx_other_packets

                         // The ones we're interested in are:
                         // idx - ignore
                         // interface, filter out local interface ("lo")
                         // tag - ignore
                         // uid_tag_int, match it with the UID of interest
                         // cnt_set - ignore
                         // rx_bytes
                         //Log.v("burning", "buffer==" + new String(buffer));
                         sScanner.reset(buffer, length);
                         sScanner.useDelimiter(' ');

                         sScanner.skip();
                         if (sScanner.nextStringEquals("lo")) {
                             continue;
                         }
                         sScanner.skip();
                         if (sScanner.nextInt() != uid) {
                             continue;
                         }
                         sScanner.skip();
                         int rxBytes = sScanner.nextInt();
                         tagRxBytes += rxBytes;
                         line++;

                         // If the line is incorrectly formatted, ignore the line.
                     } catch (NumberFormatException e) {
                         Log.e(TAG, "Cannot parse byte count at line" + line + ".");
                         continue;
                     } catch (NoSuchElementException e) {
                         Log.e(TAG, "Invalid number of tokens on line " + line + ".");
                         continue;
                     }
                 }
             } finally {
                 fis.close();
             }

             if (sPreviousBytes == -1) {
                 sPreviousBytes = tagRxBytes;
                 return -1;
             }
             long diff = tagRxBytes - sPreviousBytes;
             sPreviousBytes = tagRxBytes;
             return diff;

         } catch (IOException e) {
             Log.e(TAG, "Error reading from /proc/net/xt_qtaguid/stats. Please check if this file exists.");
         } finally {
             StrictMode.setThreadPolicy(savedPolicy);
         }

         // Return -1 upon error.
         return -1;
     }

17行-21行,实际上就是对/proc/net/xt_qtaguid/stats 这个文件进行读取,然后分析他的内容 来算出来我们的bytediff的,

熟悉linux的同学 尤其是运维的同学 肯定对/proc/net 不陌生,后面的xt_qtaguid/stats这个路径实际上就是谷歌android

给我们特殊的一个监听网络状态的接口文件。我这里可以给出一部分日志的结构 供大家参考。因为这个函数的内容就是对

这个日志的解析,你能读懂这个日志 就读懂了 这个开源项目最核心的部分。

idx哪一行就代表着文件头,下面对应的就是数据。

可以看到iface就代表着 那个网络接口,因为我是wifi下运行的这个代码 所以肯定是wlan,acct_tag_hex 这个标记就代表socket  当然这些参数值都不重要。

uid_tag_int 这个值 是比较重要的,很多人不明白为什么这个函数一定要先判断下uid的值,大家在这里一定要注意,对于linux系统来说 uid 就代表用户。

而android 是单用户系统,谷歌把这个地方改造成了uid代表你的app!!!!!!!!!!!!!!所以我们在监听app网络状态的时候 你一定要判断uid

你不能把别的app的流量也算在你自己的头上!

然后看cnt_set 实际上着就是一个标志位 0代表前台流量 1代表后台流量罢了。然后看rx_bytes r就代表是receive tx_bytes就代表transmit所以

就代表着 一个是收到的byte 一个是发送的byte,对于手机来说 发送的byte一般较少,我们主要关心的就是收到的byte。

好,分析完毕以后 我们再接着看那个函数 就比较容易了。

第29行 就是跳过文件头,因为我们的目标是获取rx_bytes

56行 就是看如果不是自己的app 的流量 自然跳出 不会计算。

77-83行,就是算bytediff的,注意那个sPreviousBytes 这个就是存储你上一次的流量的,初始化的时候是-1

他是一个静态变量,

因为我们的日志里面 rx_bytes是存储的总流量!,所以这边计算的时候要用流量差 来表示bytediff。

到这 这个框架就分析完毕了,希望能带给大家一点启发,

最后有的人可能要问 为什么 那个while循环 要把rx_bytes 给加起来,因为大家要注意啊 一个app

可能有多个进程啊,我们要计算自己的app 或者某个app的 网络状态,肯定是要把他所有进程的

流量全算进去的!所以这个地方要不断遍历!此外就是如果你真的能读懂我的这篇博客的话,又恰好会python的

话,就可以用python和adb 来完成对你手机上app的流量测试了!很方便,再也不用装什么360来测试你app

的流量了!

人生苦短,何不用python!

Android 网络流量监听开源项目-ConnectionClass源码分析的更多相关文章

  1. Android 开源项目PhotoView源码分析

    https://github.com/chrisbanes/PhotoView/tree/master/library 这个就是项目地址,相信很多人都用过,我依然不去讲怎么使用.只讲他的原理和具体实现 ...

  2. go开源项目influxdb-relay源码分析(一)

    influxdb-relay项目地址: https://github.com/influxdata/influxdb-relay,主要作为负载均衡节点,写入多个influxdb节点,起到高可用效果. ...

  3. 【原】Android热更新开源项目Tinker源码解析系列之三:so热更新

    本系列将从以下三个方面对Tinker进行源码解析: Android热更新开源项目Tinker源码解析系列之一:Dex热更新 Android热更新开源项目Tinker源码解析系列之二:资源文件热更新 A ...

  4. 【原】Android热更新开源项目Tinker源码解析系列之一:Dex热更新

    [原]Android热更新开源项目Tinker源码解析系列之一:Dex热更新 Tinker是微信的第一个开源项目,主要用于安卓应用bug的热修复和功能的迭代. Tinker github地址:http ...

  5. 【原】Android热更新开源项目Tinker源码解析系列之二:资源文件热更新

    上一篇文章介绍了Dex文件的热更新流程,本文将会分析Tinker中对资源文件的热更新流程. 同Dex,资源文件的热更新同样包括三个部分:资源补丁生成,资源补丁合成及资源补丁加载. 本系列将从以下三个方 ...

  6. Android事件传递机制详解及最新源码分析——ViewGroup篇

    版权声明:本文出自汪磊的博客,转载请务必注明出处. 在上一篇<Android事件传递机制详解及最新源码分析--View篇>中,详细讲解了View事件的传递机制,没掌握或者掌握不扎实的小伙伴 ...

  7. Android事件传递机制详解及最新源码分析——View篇

    摘要: 版权声明:本文出自汪磊的博客,转载请务必注明出处. 对于安卓事件传递机制相信绝大部分开发者都听说过或者了解过,也是面试中最常问的问题之一.但是真正能从源码角度理解具体事件传递流程的相信并不多, ...

  8. Android事件传递机制详解及最新源码分析——Activity篇

    版权声明:本文出自汪磊的博客,转载请务必注明出处. 在前两篇我们共同探讨了事件传递机制<View篇>与<ViewGroup篇>,我们知道View触摸事件是ViewGroup传递 ...

  9. Android应用AsyncTask处理机制详解及源码分析

    1 背景 Android异步处理机制一直都是Android的一个核心,也是应用工程师面试的一个知识点.前面我们分析了Handler异步机制原理(不了解的可以阅读我的<Android异步消息处理机 ...

随机推荐

  1. 计算机人物系列-Mauchly,Eckert,Goldstine

    关键词:莫尔学院(Moore School),阿伯丁试验场(Aberdeen Proving Ground), 雷明顿兰德公司(Remington Rand Corporation), IBM院士(I ...

  2. python基础(五)缩进和选择

    作者:Vamei 出处:http://www.cnblogs.com/vamei 欢迎转载,也请保留这段声明.谢谢! 缩进 Python最具特色的是用缩进来标明成块的代码.我下面以if选择结构来举例. ...

  3. electron package can not find module xml2json

    问题 electron 打包好的应用找不到xml2json 但是开发环境npm start 运行正常 定位 node_modules没有包含在打的包中, 解决办法 --no-prune Be care ...

  4. Head First 设计模式 --4 工厂模式 抽象工厂模式

    (用到了依赖倒置原则) 我们写的代码中,有的时候可能会出现根据外面给定的不同的参数在方法中根据参数实例化不同的实例,就是会根据不同的参数会new出不同的实例.如果这么写了,这段代码会非常的脆弱,一旦出 ...

  5. 分布式存储Memcache替代Session方案

    PHP自带的Session实际是在服务器中为每个客户建立独立的文件存放各自的信息. 在不做处理的情况下,很容易被客户端伪造.并且由于采用文件形式,所以存在着IO 读写的瓶颈.一般当用户在线达到1000 ...

  6. Linux bash重拾 2016-8-16

    bash支持的引号: "" 双引号:弱引用,可以实现变量替换(变量会替换为值) [root@localhost ssh-6Xolw4LLAMwe]# echo "dire ...

  7. MVC4.0 上传Excel并存入数据库

    这里的这个功能实现在WebForm很好实现,上传阶段简单的一个FileUoLoad控件就搞定了,什么取值,什么上传都是浮云,微软都帮我们封装好了,我们只需要一拖一拽就OK了,但这些在MVC中是不行的! ...

  8. 几个Python oj的网站

    http://www.rqnoj.cn/ http://www.pythontip.com/

  9. php短数组写法

    在php 5.4+的版本中,可以使用  []  来表示  array() 例子: // On PHP 5.1 $data = array("foo", "bar" ...

  10. API认证&amp;SDK&amp;RESTful

    python API的安全认证   我们根据pid加客户端的时间戳进行加密md5(pid|时间戳)得到的单向加密串,与时间戳,或者其它字段的串的url给服务端. 服务端接收到请求的url进行分析 客户 ...