最近逛github，突然發(fā)現(xiàn)facebook居然寫了個檢測網(wǎng)絡質(zhì)量的框架源碼地址，好奇心驅(qū)使那就研究一下吧。分析源碼之前，先看一看官方給我們提供的例子效果：

這個是faceBook官方為這個小框架提供的demo，點擊Test按鈕即可測出當前手機網(wǎng)絡速度的質(zhì)量，但是這里出現(xiàn)了一串英文EXCELLENT，什么鬼這表示的速度是什么，查詢源碼找到包含參數(shù)的這個枚舉類

public enum ConnectionQuality {/*** Bandwidth under 150 kbps.*/POOR,/*** Bandwidth between 150 and 550 kbps.*/MODERATE,/*** Bandwidth between 550 and 2000 kbps.*/GOOD,/*** EXCELLENT - Bandwidth over 2000 kbps.*/EXCELLENT,/*** Placeholder for unknown bandwidth. This is the initial value and will stay at this value* if a bandwidth cannot be accurately found.*/UNKNOWN }
英文已經(jīng)說明的很清楚了，測試的當前網(wǎng)絡速度2000 kbps以上，說明手機當前網(wǎng)絡質(zhì)量不錯吆！好，看完例子，接下來進入重點

mConnectionClassManager = ConnectionClassManager.getInstance();mDeviceBandwidthSampler = DeviceBandwidthSampler.getInstance();.....mListener = new ConnectionChangedListener();

@Overrideprotected void onPause() {super.onPause();mConnectionClassManager.remove(mListener);}@Overrideprotected void onResume() {super.onResume();mConnectionClassManager.register(mListener);}
例子當中與框架交互的首先映入眼簾的就是這幾句代碼，可以看到，小框架中聲明了兩個單例ConnectionClassManager類和DeviceBandwidthSampler類，然后通過ConnectionClassManager注冊了一個監(jiān)聽回調(diào)方法，用于顯示網(wǎng)絡變化，既然是一直在監(jiān)聽網(wǎng)絡速度變化的，那么八成會有死循環(huán)一直運行監(jiān)測網(wǎng)速。ok，先看看DeviceBandwidthSampler類，驗證一下推論。

private DeviceBandwidthSampler(ConnectionClassManager connectionClassManager) {mConnectionClassManager = connectionClassManager;mSamplingCounter = new AtomicInteger();mThread = new HandlerThread("ParseThread");mThread.start();mHandler = new SamplingHandler(mThread.getLooper());} 這個類的構造方法聲明了一個HandlerThread，看到 HandlerThread，已經(jīng)能看出來，它是想在在線程當中執(zhí)行消息隊列，start（）方法創(chuàng)建一個新的消息隊列管理，類Loop，然后進行輪詢查看是否有消息，有消息就處理，接下來創(chuàng)建一個綁定這個 HandlerThread的Loop的Handler，用來發(fā)消息。按照猜測接下來就是利用Handler來循環(huán)傳送消息了，在點擊按鈕下載圖片的時候調(diào)用了?mDeviceBandwidthSampler.startSampling()方法發(fā)送了消息。

/*** 開始檢測網(wǎng)絡速度*/public void startSampling() {if (mSamplingCounter.getAndIncrement() == 0) {//看這里mHandler.startSamplingThread();mLastTimeReading = SystemClock.elapsedRealtime();}} public void startSamplingThread() {sendEmptyMessage(SamplingHandler.MSG_START);} 看這個方法鏈的調(diào)用，最終通過發(fā)消息的方式實現(xiàn)循環(huán)

public void handleMessage(Message msg) {switch (msg.what) {case MSG_START:addSample();sendEmptyMessageDelayed(MSG_START, SAMPLE_TIME);
消息處理中每隔一段時間重新發(fā)送相通消息，那么計算處理網(wǎng)絡速度的也只有 addSample方法了

protected void addSample() {//得到手機自啟動以來的總共消耗的流量long newBytes = TrafficStats.getTotalRxBytes();long byteDiff = newBytes - sPreviousBytes;//有變化的時候才去計算if (sPreviousBytes >= 0) {synchronized (this) {//得到當前的時間long curTimeReading = SystemClock.elapsedRealtime();//傳入流量變化的差值和時間差值mConnectionClassManager.addBandwidth(byteDiff, curTimeReading - mLastTimeReading);mLastTimeReading = curTimeReading;}}sPreviousBytes = newBytes;}
這個方法首先獲得了手機自啟動以來的流量消耗的總量，然后用當前量減去上一次的量，也就是說網(wǎng)絡速度是通過單位時間內(nèi)流量的差值進行計算的，接下來進入?mConnectionClassManager.addBandwidth進行計算

public synchronized void addBandwidth(long bytes, long timeInMs) {// Ignore garbage values.// 變化量小于10計算終止重新記錄值if (timeInMs == 0|| (bytes) * 1.0 / (timeInMs) * BYTES_TO_BITS < BANDWIDTH_LOWER_BOUND) {return;}double bandwidth = (bytes) * 1.0 / (timeInMs) * BYTES_TO_BITS;mDownloadBandwidth.addMeasurement(bandwidth);// 如果它為true連續(xù)mSampleCounter+1if (mInitiateStateChange) {mSampleCounter += 1;// 判斷當前的值和期望的值是否處在同一個范圍內(nèi)，不處在同一個范圍內(nèi),連續(xù)5次計算的值和波動值在同一個范圍內(nèi)的話,減少網(wǎng)絡波動造成的誤差if (getCurrentBandwidthQuality() != mNextBandwidthConnectionQuality.get()) {// 計數(shù)重新開始,mInitiateStateChangemInitiateStateChange = false;mSampleCounter = 1;}/*** 網(wǎng)絡穩(wěn)定到5次以上才通知計算結果，波動比較大的時候不通知，優(yōu)化更準確*/if (mSampleCounter >= DEFAULT_SAMPLES_TO_QUALITY_CHANGE&& significantlyOutsideCurrentBand()) {mInitiateStateChange = false;mSampleCounter = 1;// 確定改變的時候設置通知mCurrentBandwidthConnectionQuality.set(mNextBandwidthConnectionQuality.get());notifyListeners();}return;}// 如果上一個速率和現(xiàn)在的計算速率不一樣，那么mInitiateStateChange=true,mNextBandwidthConnectionQuality儲存當前的速錄if (mCurrentBandwidthConnectionQuality.get() != getCurrentBandwidthQuality()) {mInitiateStateChange = true;mNextBandwidthConnectionQuality = new AtomicReference<ConnectionQuality>(getCurrentBandwidthQuality());}}
計算的核心都在這個方法里面，首先判斷如果前后消耗流量的變化小于10kbs那么，重新記錄值計算終止，滿足條件通過mDownloadBandwidth.addMeasurement方法計算出變化的平均值，也就是通過指數(shù)移動平均值來重新估算這個差值，由于移動網(wǎng)絡的不穩(wěn)定性，通過計算平均值計算會更準確，假設當前網(wǎng)絡已經(jīng)有了上一次的速度，但是由于某種原因，速度發(fā)生變化，比如信號不好，那么此時為了排除誤差，采取連續(xù)計算五次方式，也就是說如果當前網(wǎng)絡速度變化值滿足五次在同一個范圍內(nèi)并且和上一次計算的速度不在同一范圍內(nèi)的話，那么通知客戶端速度改變，當前速度值刷新，也就是網(wǎng)絡速度值必須保持5次計算都在同一個范圍內(nèi)，才認為當前網(wǎng)絡質(zhì)量的速度為準確的，也就是說假設當前速度為100kbs，信號突然不好掉到30kbs，但是有可能信號又突然恢復了，那么當前速度還是100kbs，沒必要通知客戶端網(wǎng)絡速度發(fā)生了改變。這種方式可以是測量值更接近真實情況的值，當然不肯能100%準確。

最后看一下指數(shù)移動平均值是怎么計算的

public void addMeasurement(double measurement) {// 0.95double keepConstant = 1 - mDecayConstant;// 累加次數(shù)大于20次if (mCount > mCutover) {// 自然對數(shù)Math.log(mValue),Math.exp() 函數(shù)返回 exmValue = Math.exp(keepConstant * Math.log(mValue) + mDecayConstant* Math.log(measurement));}// 0<mCount<20走這里else if (mCount > 0) {// 如果mCount是4的話double retained = keepConstant * mCount / (mCount + 1.0);double newcomer = 1.0 - retained;mValue = Math.exp(retained * Math.log(mValue) + newcomer* Math.log(measurement));}// 第一次mCount是等于0的else {mValue = measurement;}mCount++;} 指數(shù)平均值通過前后變化的兩個數(shù)進行權重平均值計算，至于這樣計算為什么準確，筆者暫時有點懵逼，但是這個算法是統(tǒng)計學當中的，不管怎么說閱讀此代碼讓筆者了解到，想成為高手中的戰(zhàn)斗機算法必須牛，那么接下來的目標就是拾起曾經(jīng)遺忘的數(shù)學

總結

以上是生活随笔為你收集整理的facebook的network-connection-class（测量移动端网络质量）源码详解的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。