[toc]
本文基于 Android 7.1.1 源码,分析 LocalBroadcastManager 机制!
0 前言
BroadcastReceiver 是基于 Binder 通信的,其可以用于跨进程的通信,而 LocalBroadcastManager 是基于 Handler 的,其适用于进程内的通信,在进程内进行局部广播发送与注册。
相比 BroadcastReceiver 的广播,LocalBroadcastManager 有以下几点优点。
- 广播数据只在本应用内传播,不用担心数据泄露;
- 广播数据不用担心别的应用伪造广播,更加安全;
- 因为只在应用内广播,所以更加的高效;
LocalBroadcastManager 位于 android.support.v4.content 包中,适用于动态注册的广播:
1 基本使用
注册接收者到 LocalBroadcastManager:
1 2 3 4
| filter = new IntentFilter(); filter.addAction(action); mLocalBroadcastManager = LocalBroadcastManager.getInstance(this); mLocalBroadcastManager.registerReceiver(receiver, filter);
|
解除注册:
1
| mLocalBroadcastManager.unregisterReceiver(receiver);
|
然后就是发送广播:
1
| mLocalBroadcastManager.sendBroadcast(intent);
|
2 源码分析
2.1 LocalBroadcastManager.getInstance - 创建单例
LocalBroadcastManager 采用的是单例模式:
1 2 3 4 5 6 7 8 9
| public static LocalBroadcastManager getInstance(Context context) { synchronized (mLock) { if (mInstance == null) { mInstance = new LocalBroadcastManager(context.getApplicationContext()); } return mInstance; } }
|
getInstance 方法中会调用 LocalBroadcastManager 构造器:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18
| private LocalBroadcastManager(Context context) { mAppContext = context; mHandler = new Handler(context.getMainLooper()) { @Override public void handleMessage(Message msg) { switch (msg.what) { case MSG_EXEC_PENDING_BROADCASTS: executePendingBroadcasts(); break; default: super.handleMessage(msg); } } }; }
|
context.getMainLooper() 会返回当前进程主线程的 Looper 对象!
继续分析!
2.2 LocalBroadcastManager.registerReceiver - 注册
注册接收者:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23
| public void registerReceiver(BroadcastReceiver receiver, IntentFilter filter) { synchronized (mReceivers) { ReceiverRecord entry = new ReceiverRecord(filter, receiver); ArrayList<IntentFilter> filters = mReceivers.get(receiver); if (filters == null) { filters = new ArrayList<IntentFilter>(1); mReceivers.put(receiver, filters); } filters.add(filter); for (int i=0; i<filter.countActions(); i++) { String action = filter.getAction(i); ArrayList<ReceiverRecord> entries = mActions.get(action); if (entries == null) { entries = new ArrayList<ReceiverRecord>(1); mActions.put(action, entries); } entries.add(entry); } } }
|
在 LocalBroadcastManager 有如下两个 hash 表:
1 2 3 4 5 6
| private final HashMap<BroadcastReceiver, ArrayList<IntentFilter>> mReceivers = new HashMap<BroadcastReceiver, ArrayList<IntentFilter>>();
private final HashMap<String, ArrayList<ReceiverRecord>> mActions = new HashMap<String, ArrayList<ReceiverRecord>>();
|
不多说了!
2.2.1 new ReceiverRecord
ReceiverRecord 的代码很简单,不多说了!
1 2 3 4 5 6 7 8 9 10 11
| private static class ReceiverRecord { final IntentFilter filter; final BroadcastReceiver receiver; boolean broadcasting;
ReceiverRecord(IntentFilter _filter, BroadcastReceiver _receiver) { filter = _filter; receiver = _receiver; } ... ... ... }
|
2.3 LocalBroadcastManager.unregisterReceiver - 取消注册
取消注册:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30
| public void unregisterReceiver(BroadcastReceiver receiver) { synchronized (mReceivers) { ArrayList<IntentFilter> filters = mReceivers.remove(receiver); if (filters == null) { return; } for (int i=0; i<filters.size(); i++) { IntentFilter filter = filters.get(i); for (int j=0; j<filter.countActions(); j++) { String action = filter.getAction(j); ArrayList<ReceiverRecord> receivers = mActions.get(action); if (receivers != null) { for (int k=0; k<receivers.size(); k++) { if (receivers.get(k).receiver == receiver) { receivers.remove(k); k--; } } if (receivers.size() <= 0) { mActions.remove(action); } } } } } }
|
不多说了!
2.4 LocalBroadcastManager.sendBroadcast - 异步广播
sendBroadcast 用于发送异步的广播,该方法在调用会后立刻返回!!
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80
| public boolean sendBroadcast(Intent intent) { synchronized (mReceivers) { final String action = intent.getAction(); final String type = intent.resolveTypeIfNeeded( mAppContext.getContentResolver()); final Uri data = intent.getData(); final String scheme = intent.getScheme(); final Set<String> categories = intent.getCategories();
final boolean debug = DEBUG || ((intent.getFlags() & Intent.FLAG_DEBUG_LOG_RESOLUTION) != 0); if (debug) Log.v( TAG, "Resolving type " + type + " scheme " + scheme + " of intent " + intent); ArrayList<ReceiverRecord> entries = mActions.get(intent.getAction()); if (entries != null) { if (debug) Log.v(TAG, "Action list: " + entries);
ArrayList<ReceiverRecord> receivers = null; for (int i=0; i<entries.size(); i++) { ReceiverRecord receiver = entries.get(i); if (debug) Log.v(TAG, "Matching against filter " + receiver.filter); if (receiver.broadcasting) { if (debug) { Log.v(TAG, " Filter's target already added"); } continue; } int match = receiver.filter.match(action, type, scheme, data, categories, "LocalBroadcastManager"); if (match >= 0) { if (debug) Log.v(TAG, " Filter matched! match=0x" + Integer.toHexString(match)); if (receivers == null) { receivers = new ArrayList<ReceiverRecord>(); } receivers.add(receiver); receiver.broadcasting = true; } else { if (debug) { String reason; switch (match) { case IntentFilter.NO_MATCH_ACTION: reason = "action"; break; case IntentFilter.NO_MATCH_CATEGORY: reason = "category"; break; case IntentFilter.NO_MATCH_DATA: reason = "data"; break; case IntentFilter.NO_MATCH_TYPE: reason = "type"; break; default: reason = "unknown reason"; break; } Log.v(TAG, " Filter did not match: " + reason); } } } if (receivers != null) { for (int i=0; i<receivers.size(); i++) { receivers.get(i).broadcasting = false; } mPendingBroadcasts.add(new BroadcastRecord(intent, receivers)); if (!mHandler.hasMessages(MSG_EXEC_PENDING_BROADCASTS)) { mHandler.sendEmptyMessage(MSG_EXEC_PENDING_BROADCASTS); } return true; } } } return false; }
|
在 LocalBroadcastManager 还有如下的一个 list 表:
1 2 3
| private final ArrayList<BroadcastRecord> mPendingBroadcasts = new ArrayList<BroadcastRecord>();
|
其实,sendBroadcast 方法,本质上是将 BroadcastRecord 添加到内部的 mPendingBroadcasts 集合中,然后发送 MSG_EXEC_PENDING_BROADCASTS 消息,处理广播!
之所以是异步的原因是,sendBroadcast 方法只是将广播加入到了 mPendingBroadcasts 中后,会立刻返回;
而广播的分发是在主线程,如果我们在子线程中 sendBroadcast 的话,整个过程显然是异步的!
继续分析:
2.4.1 new BroadcastRecord
用于表示一个广播实例:
1 2 3 4 5 6 7 8 9
| private static class BroadcastRecord { final Intent intent; final ArrayList<ReceiverRecord> receivers;
BroadcastRecord(Intent _intent, ArrayList<ReceiverRecord> _receivers) { intent = _intent; receivers = _receivers; } }
|
不用多说了!
2.5 LocalBroadcastManager.sendBroadcastSync - 同步广播
sendBroadcastSync 用于同步发送广播:
1 2 3 4 5 6 7
| public void sendBroadcastSync(Intent intent) { if (sendBroadcast(intent)) { executePendingBroadcasts(); } }
|
sendBroadcastSync 方法之所以是同步的是因为,当我们 sendBroadcast 将广播加入到 mPendingBroadcasts 列表中后,会立刻调用 executePendingBroadcasts 分发广播,整个流程都是在同一个线程中执行的!
注意:
按照以往认知:BroadcastReceiver 的 onReceive 应该是在主线程中调用的,但是在这里,BroadcastReceiver 的 onReceive 方法却可以在非主线程中调用!
主要差别是:两种情况下的实现方式不同,前者是跨进程通信,所以 onReceive 始终是在主线程中拉起的;而后者由于实质上只是一个回调,所以可以在任何线程中拉起!
2.6 LocalBroadcastManager.executePendingBroadcasts - 接收广播
executePendingBroadcasts 用于分发和接收广播!
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23
| private void executePendingBroadcasts() { while (true) { BroadcastRecord[] brs = null; synchronized (mReceivers) { final int N = mPendingBroadcasts.size(); if (N <= 0) { return; } brs = new BroadcastRecord[N]; mPendingBroadcasts.toArray(brs); mPendingBroadcasts.clear(); } for (int i=0; i<brs.length; i++) { BroadcastRecord br = brs[i]; for (int j=0; j<br.receivers.size(); j++) { br.receivers.get(j).receiver.onReceive(mAppContext, br.intent); } } } }
|
逻辑也很清楚!