android發送廣播延時

A. android廣播阻塞、延遲問題

        最近項目中，多次碰到app研發人員反饋廣播從發送到接收器接收，間隔時間太長，要求系統進行優化，特別是開機階段。對此，專門閱讀了一下廣播從發送到接收這個流程的源碼，以徹底搞明白怎樣讓自己發送的廣播盡快到達接收器。

涉及到的源碼類不多，主要就是ActivityManagerService.java 和 BroadcastQueue.java。發送廣播進程調用發送介面，通過IPC到達AMS,AMS根據Intent是否配置Intent.FLAG_RECEIVER_FOREGROUND，選擇當前廣播加入前台廣播隊列還是後台廣播隊列。根據當前廣播是否有序，將廣播加入廣播隊列的串列列表還是並行列表。廣播隊列和廣播隊列中的廣播列表是影響廣播接收時間的主要因素。

BroadcastQueue廣播隊列，負責將廣播發送給廣播接收器。AMS中有兩個成員變數， 

BroadcastQueue mFgBroadcastQueue;//前台廣播隊列

BroadcastQueue mBgBroadcastQueue;//後台廣播隊列

前台廣播隊列和後台廣播隊列的區別有兩處：1 超時時間，前台10s，後台60s. 2 是否延遲廣播等待前一個廣播進程完成。這兩個區別已經說明前台廣播對廣播接收器要求更高，響應時間更短，如果廣播要排隊，時間上前台廣播更短。同時系統默認使用後台廣播隊列，所以前台廣播隊列處理的廣播要少，避免了可能的大量廣播排隊情況。

廣播隊列中的列表

//存放無序並發送給動態廣播接收器的廣播任務

final ArrayList<BroadcastRecord> mParallelBroadcasts = new ArrayList<BroadcastRecord>();

//存放無序發送給靜態廣播接收器的廣播任務或者存放有序廣播任務

final ArrayList<BroadcastRecord> mOrderedBroadcasts = new ArrayList<BroadcastRecord>();

mParallelBroadcasts 此列表中存放的是無序廣播動態廣播接收器任務，廣播隊列會在處理任務時通過嵌套循環，把每個廣播通過ipc發送到關注它的所有進程。所有無序廣播+動態廣播接收器，廣播不需要排隊。這種情況是最快能讓廣播到達目標進程的方式。

mOrderedBroadcasts存放的廣播任務特點：廣播有序，或者廣播接收器是靜態注冊的。此種類型的廣播全部要在mOrderedBroadcasts中排隊，廣播之間按時間先後，同一個廣播不同廣播接收器按優先順序。mOrderedBroadcasts存放的廣播必須等一個廣播任務處理完畢才能處理下一個，中間可能包含進程的啟動等。

由此可見，廣播最快的情況是前台廣播、無序廣播、動態注冊廣播接收器。最糟糕的情況是：後台廣播、有序或靜態注冊廣播接收器、廣播接收器優先順序低。如果一個應用只是簡單的靠注冊一個靜態廣播接收器拉起進程，對應的正是最糟糕的情況。如果又發生在開機階段，自然延遲嚴重。

如果必須注冊靜態廣播接收器，縮短時間的辦法為：配置Intent.FLAG_RECEIVER_FOREGROUND，加入前台廣播隊列，設置廣播優先順序

源碼：

廣播發送：Context .sendBroadcast ->ActivityManagerNative.broadcastIntent->ActivityManagerService.broadcastIntent->ActivityManagerService.broadcastIntentLocked.到此階段，跟發送廣播的進程通信結束。此階段AMS完成的工作主要是根據Intent查找該廣播對應的動態廣播接收器、靜態廣播接收器、以此發送該廣播使用的廣播隊列。

private final int broadcastIntentLocked(

......//許可權檢查

......//特殊系統廣播進行必要處理

if (sticky) {//粘性廣播處理

......

//查找靜態注冊的接收器

receivers = collectReceiverComponents(intent, resolvedType, users);

if (intent.getComponent() == null) {

    // 查找動態廣播接收器

            registeredReceivers = mReceiverResolver.queryIntent(intent,

                    resolvedType, false, userId);

        }

//動態廣播接收器

        int NR = registeredReceivers != null ? registeredReceivers.size() : 0;

        if (!ordered && NR > 0) { 

//確定隊列

            final BroadcastQueue queue = broadcastQueueForIntent(intent);

//創建廣播任務BroadcastRecord

            BroadcastRecord r = new BroadcastRecord(queue, intent, callerApp,

                    callerPackage, callingPid, callingUid, resolvedType, requiredPermission,

                    appOp, registeredReceivers, resultTo, resultCode, resultData, map,

                    ordered, sticky, false, userId);

......

//廣播任務加入並行列表中

                queue.(r);

//啟動非同步發送廣播任務

                queue.scheleBroadcastsLocked();

registeredReceivers = null;

            NR = 0;

......

while (it < NT && ir < NR) {

......

//根據優先順序排序

          if (curt == null) {

                    curt = (ResolveInfo)receivers.get(it);

                }

                if (curr == null) {

                    curr = registeredReceivers.get(ir);

                }

                if (curr.getPriority() >= curt.priority) {

                    // Insert this broadcast record into the final list.

                    receivers.add(it, curr);

//獲取廣播隊列

            BroadcastQueue queue = broadcastQueueForIntent(intent);

//創建廣播任務

            BroadcastRecord r = new BroadcastRecord(queue, intent, callerApp,

                    callerPackage, callingPid, callingUid, resolvedType,

                    requiredPermission, appOp, receivers, resultTo, resultCode,

                    resultData, map, ordered, sticky, false, userId);

//加入到廣播隊列串列列表中

                queue.enqueueOrderedBroadcastLocked(r);

//啟動非同步發送任務

                queue.scheleBroadcastsLocked();

廣播隊列處理廣播：

final void processNextBroadcast(boolean fromMsg) {

......

//並行列表,遍歷廣播任務

            while (mParallelBroadcasts.size() > 0) {

final int N = r.receivers.size();

//遍歷接收器

                for (int i=0; i<N; i++) {

//IPC調用發送給目標進程

(r, (BroadcastFilter)target, false);

}

}

//有串列廣播任務正在執行

if (mPendingBroadcast != null) {

             //接收廣播的目標進程正常

                if (!isDead) {

                    // It's still alive, so keep waiting 繼續等待目前進程反饋

                    return;

                }

}

             //取出第一個廣播

                r = mOrderedBroadcasts.get(0);//判斷是否超時，

                    if ((numReceivers > 0) && 

                            (now > r.dispatchTime + (2*mTimeoutPeriod*numReceivers))) {

                         //廣播超時

                          broadcastTimeoutLocked(false);//超時處理，終止當前廣播，啟動下一個任務。

                          }

                if (r.receivers == null || r.nextReceiver >= numReceivers

                        || r.resultAbort || forceReceive) {

                 //所有廣播任務執行完畢

}

int recIdx = r.nextReceiver++;//下一個廣播接收器

r.dispatchTime = r.receiverTime;//設置派發時間

setBroadcastTimeoutLocked(timeoutTime);//啟動超時計時

if (nextReceiver instanceof BroadcastFilter){//動態廣播接收器

(r, filter, r.ordered);//發送

return;

}

.//靜態廣播

            ResolveInfo info =

                (ResolveInfo)nextReceiver;

......

//檢查進程是否已啟動

            ProcessRecord app = mService.getProcessRecordLocked(targetProcess,

                    info.activityInfo.applicationInfo.uid, false);

            if (app != null && app.thread != null) { /進程啟動

               processCurBroadcastLocked(r, app);//發送靜態廣播

               return;

            }

     if ((r.curApp=mService.startProcessLocked(targetProcess,//啟動進程

                    info.activityInfo.applicationInfo, true,

                    r.intent.getFlags() | Intent.FLAG_FROM_BACKGROUND,

                    "broadcast", r.curComponent,

                    (r.intent.getFlags()&Intent.FLAG_RECEIVER_BOOT_UPGRADE) != 0, false, false))

                            == null) {

                      //進程啟動失敗

                  }

             //標志正在發送的串列廣播

            mPendingBroadcast = r;

            mPendingBroadcastRecvIndex = recIdx;//正在發送的廣播任務對應的接收器索引

}

B. 簡述在android中如何發送廣播消息

1. 首先要聲明廣播

=newBroadcastReceiver()

{

@Override

publicvoidonReceive(Contextcontext,Intentintent)//onReceive函數不能做耗時的事情，參考值：10s以內

{

Log.d("scott","onreceiveaction="+intent.getAction());

Stringaction=intent.getAction();

if(action.equals("com.scott.sayhi"))

{

showDialog("onreceiveaction="+intent.getAction());

}

}

};

2.其次要注冊廣播，有兩種方式：xml注冊和代碼注冊

xml注冊：

<receiver android:name="com.scott.sayhi.MyBroadcastReceiver" >
<intent-filter>
<action android:name="com.scott.sayhi" />
</intent-filter>
</receiver>

代碼注冊：

IntentFilter filter = new IntentFilter();
filter.addAction("com.scott.sayhi");
MyActivity.this.registerReceiver(mBroadcastReceiver, filter);

上述2個步驟就可以了。

3.發送廣播

Intentintent=newIntent();

intent.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK);

intent.setAction("com.scott.sayhi");

MyActivity.this.sendBroadcast(intent);

Intent intent = new Intent();
intent.setFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
intent.setAction("com.scott.sayhi");
MyActivity.this.sendBroadcast(intent);

4.收聽開機廣播

intent-filter設置如下即可

<intent-filter>
<action android:name="android.intent.action.BOOT_COMPLETED" />
<category android:name="android.intent.category.HOME" />
</intent-filter>

C. android怎麼發送特定廣播的

起一個線程，每發一個廣播後就sleep一分鍾，如此循環。（或者接受系統的timechanged這個廣播，這個廣播好像一分鍾發一次）。

Android 在發送廣播時的方法 sendBroadcast（Intent）。

①：Intent myIntent = new Intent();——【創建Intent對象】

②：myIntent.setAction(String)——【設置一般的要執行的動作。參數：動作一個動作的名稱，如ACTION_VIEW。應用程序的具體行動，應與供應商的包名作為前綴。】

③：myIntent.putExtra(String,Object)——【廣播中額外發送的數據，String為自定義key,Object表示多種數據類型】

④：sendBroadcast(myIntent);——【發送廣播】

接收廣播

Android在接收廣播的方法是注冊一個廣播接收器 registerReceiver(MyReceiver,IntentFilter)。

①：首先創建MyReceiver類（類名自定義） 繼承 BroadcastReceiver類。——【創建廣播接收器】

②：在MyReceiver中重寫public void onReceive(Context context, Intent intent)方法。這個方法在接收到廣播後觸發。——【重寫處理方法】

③：在Activity或者Service啟動時 onCreate()、onStartCommand()等方法中實例化 MyReceiver類——【啟動時實例化廣播接收器】

④：IntentFilter filter = new IntentFilter();——【創建IntentFilter對象 意圖過濾器】

⑤：filter.addAction(String);——【在過濾器中加入過濾條件，說明接收什麼廣播】

⑥：registerReceiver(cmdReceiver, filter);——【注冊廣播，參數為（廣播接收器，意圖過濾器）】

D. Android系統廣播(Broadcast)注冊，發送，接收流程解析

以下廣播簡稱Broadcast

   是Android四大組件之一，在四大組件的另外兩個組件 和 擁有發送和接收廣播的能力。Android 是在 進程間通信機制的基礎上實現的，內部基於消息發布和訂閱的事件驅動模型，廣播發送者負責發送消息，廣播接收者需要先訂閱消息，然後才能收到消息。 進程間通信與 的區別在於：

   有三種類型

   存在一個注冊中心，也可以說是一個調度中心，即 。廣播接收者將自己注冊到 中，並指定要接收的廣播類型；廣播發送者發送廣播時，發送的廣播首先會發送到 ， 根據廣播的類型找到對應的 ，找到後邊將廣播發送給其處理。

   這里以普通廣播為例子， 接收者有兩種注冊方式，一種是 ，一種是 ：

（廣播的發送分為 兩種，這里針對有序的廣播） 中的android:priority=""和 中的IntentFilter.setPriority(int)可以用來設置廣播接收者的優先順序，默認都是0 , 范圍是[-1000, 1000]，值越大優先順序越高，優先順序越高越早收到。

   在相同優先順序接收同個類型廣播時， 的廣播接收器比 的廣播接收者更快的接收到對應的廣播，這個之後會進行分析。

   註：以下源碼基於rk3399_instry Android7.1.2

   的流程可分為 ， 和 三個部分，這里依次分析下

   在Android系統的 機制中，前面提到， 作為一個注冊和調度中心負責注冊和轉發 。所以 的注冊過程就是把它注冊到 的過程。

   這里我們分析 廣播的過程， 和 有一個共同的父類 ，所以它們對應的注冊過程其實是調用 ，接下來我們按照流程逐步分析調用流程的源碼。

frameworks/base/core/java/android/content/ContextWrapper.java

   在之前的 Android應用程序啟動入口ActivityThread.main流程分析 分析過，在我們啟動 Activity 時會創建一個 對象，然後通過 傳給我們啟動的 ，其內部就會將該對象賦值給 ； 的 方法也是類似的賦值流程，這里放個簡易的源碼應該更好理解

   可以看到最後都會將生成的 對象賦值給對應的
對象。接下來繼續分析 ， 即 函數。

/frameworks/base/core/java/android/app/ContextImpl.java

   這里我們首先看下如何將廣播接收者 封裝成一個 介面的 本地對象
/frameworks/base/core/java/android/app/LoadedApk.java

   每一個注冊過廣播接收者的 或 組件在<font color='Crimson'> LoadedApk </font>類中都有個對應的 對象，該對象負責將 與 組件關聯起來。這些對象，以關聯的 作為關鍵字保存在一個 中。之後對應的 又以 的 作為關鍵字保存在 的成員變數 對象中。最後通過 對應的 方法獲得其 介面的 本地對象。之後再回到 注冊方法內，將 對象發給 進行注冊。

/frameworks/base/core/java/android/app/ActivityManagerNative.java

/frameworks/base/services/core/java/com/android/server/am/ActivityManagerService.java

   在的 或 注冊一個 時，並不是將其注冊到<font color='OrangeRed'>AMS</font>中，而是將與它關聯的<font color='OrangeRed'>InnerReceiver</font>對象注冊到<font color='OrangeRed'>AMS</font>中，當<font color='OrangeRed'>AMS</font>接收到廣播時，會根據 在內部找到對應的<font color='OrangeRed'>InnerReceiver</font>對象，然後在通過這個對象將這個廣播發送給對應的 處理。

   注冊過程這邊畫了一個簡單的流程圖:

   <font color='OrangeRed'>Broadcast</font>的發送過程可簡單描述為以下幾個過程：

frameworks/base/core/java/android/content/ContextWrapper.java

/frameworks/base/core/java/android/app/ContextImpl.java

/frameworks/base/core/java/android/app/ActivityManagerNative.java

/frameworks/base/services/core/java/com/android/server/am/ActivityManagerService.java