导航:首页 > 操作系统 > android发送广播延时

android发送广播延时

发布时间:2023-06-27 19:18:23

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

阅读全文

与android发送广播延时相关的资料

热点内容
php开发学习门户 浏览:383
传奇游戏服务器怎么设置 浏览:823
敲击东西解压完整版 浏览:401
刺络学pdf 浏览:868
怎么给手机文件夹设置封面 浏览:931
汽车保养app怎么用 浏览:62
线程javalock 浏览:896
c语言编译运行结果查看器 浏览:112
androidpx转dip 浏览:841
西藏编译局是什么级别 浏览:1001
php提交代码 浏览:597
如何用命令查找并删除代码块 浏览:582
python初学路线图 浏览:534
matlab遗传算法旅行商问题 浏览:304
将办公软件加入加密软件的进程 浏览:724
联想小新pro14编译器 浏览:462
为什么服务器要关掉icmp协议 浏览:855
源码编辑器如何设置难度 浏览:357
给pdf加目录 浏览:476
加密软件怎么改安全问题 浏览:552