LocalBroadcastManager源碼分析

概述

當(dāng)我們使用廣播Broadcast的時(shí)候逞度,需要考慮程序安全問(wèn)題额划。

  • 我們發(fā)送的廣播會(huì)不會(huì)被別的app接收到,導(dǎo)致數(shù)據(jù)泄漏档泽。
  • 別的惡意軟件會(huì)不會(huì)發(fā)送偽造廣播導(dǎo)致我們的程序收到廣播后執(zhí)行某些非法動(dòng)作俊戳。

其實(shí)這兩個(gè)問(wèn)題可以使用Android源碼中的LocalBroadcastManager來(lái)解決,LocalBroadcastManager是只在當(dāng)前進(jìn)程內(nèi)進(jìn)行通信馆匿,而用法與Broadcast相同抑胎。

LocalBroadcastManager與Broadcast比較有三個(gè)優(yōu)點(diǎn):

  1. 廣播數(shù)據(jù)不會(huì)超出你的應(yīng)用程序內(nèi)部,不會(huì)別的程序接收到渐北,所以不需要擔(dān)心泄露隱私數(shù)據(jù)阿逃。
  2. 廣播接收器不會(huì)接收到其他應(yīng)用程序發(fā)送的廣播,所以不必?fù)?dān)心可以利用安全漏洞腔稀。
  3. 通信方式比Broadcast更加高效盆昙,LocalBroadcastManager使用handler為核心機(jī)制,Broadcast則是使用Android內(nèi)部的Binder機(jī)制焊虏。

基本使用

LocalBroadcastManager與Broadcast的使用方式完全一致淡喜,基本用法就是注冊(cè)、反注冊(cè)诵闭、發(fā)送廣播炼团。但是,LocalBroadcastManager只適用于動(dòng)態(tài)注冊(cè)使用疏尿,在AndroidManifest中注冊(cè)的廣播接收瘟芝,則不適用。


    LocalBroadcastManager lbm;
    BroadcastReceiver receiver;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        
        //注冊(cè)
        receiver = new BroadcastReceiver() {
            @Override
            public void onReceive(Context context, Intent intent) {
                Log.i(TAG, "LocalBroadcastManager  onReceive");
                //do samething...
            }
        };
        lbm = LocalBroadcastManager.getInstance(this);
        lbm.registerReceiver(receiver, new IntentFilter("test_action"));
    }
    
    @Override
    protected void onDestroy() {
        super.onDestroy();
        //反注冊(cè)
        lbm.unregisterReceiver(receiver);
    }
    
     @Override
    public void onClick(View v) {
        if(v == btnSendBroadcast){
            //發(fā)送廣播
            lbm.sendBroadcast(new Intent("test_action"));
        }
    }

源碼分析

構(gòu)造方法

LocalBroadcastManager使用單例模式構(gòu)造褥琐,在構(gòu)造方法內(nèi)部創(chuàng)建一個(gè)Handler锌俱,Handler用來(lái)執(zhí)行廣播的分發(fā)。

static final int MSG_EXEC_PENDING_BROADCASTS = 1;
    
    //上下文對(duì)象
    private final Context mAppContext;
    //LocalBroadcastManager的核心機(jī)制是Handler
    private final Handler mHandler;
    //同步鎖
    private static final Object mLock = new Object();
    //LocalBroadcastManager實(shí)例對(duì)象
    private static LocalBroadcastManager mInstance;
    
    //LocalBroadcastManager采用的單例模式
    public static LocalBroadcastManager getInstance(Context context) {
        synchronized (mLock) {
            if (mInstance == null) {
                //上下文對(duì)象為getApplicationContext敌呈,不用擔(dān)心內(nèi)存泄漏問(wèn)題
                mInstance = new LocalBroadcastManager(context.getApplicationContext());
            }
            return mInstance;
        }
    }

    //私有構(gòu)造函數(shù)
    private LocalBroadcastManager(Context context) {
        mAppContext = context;
        //傳入context.getMainLooper()贸宏,Handler執(zhí)行在主線程
        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);
                }
            }
        };
    }

基本數(shù)據(jù)結(jié)構(gòu)和內(nèi)部類

  • 內(nèi)部類ReceiverRecord造寝,用于存放相對(duì)應(yīng)的IntentFilter和BroadcastReceiver。
  • 內(nèi)部類BroadcastRecord吭练,用于存放相對(duì)應(yīng)的Intent和ReceiverRecord诫龙。
    //存放相對(duì)應(yīng)的IntentFilter和BroadcastReceiver
    private static class ReceiverRecord {
        final IntentFilter filter;
        final BroadcastReceiver receiver;
        boolean broadcasting;

        ReceiverRecord(IntentFilter _filter, BroadcastReceiver _receiver) {
            filter = _filter;
            receiver = _receiver;
        }

        @Override
        public String toString() {
            StringBuilder builder = new StringBuilder(128);
            builder.append("Receiver{");
            builder.append(receiver);
            builder.append(" filter=");
            builder.append(filter);
            builder.append("}");
            return builder.toString();
        }
    }

    //存放相對(duì)應(yīng)的Intent和ReceiverRecord
    private static class BroadcastRecord {
        final Intent intent;
        final ArrayList<ReceiverRecord> receivers;

        BroadcastRecord(Intent _intent, ArrayList<ReceiverRecord> _receivers) {
            intent = _intent;
            receivers = _receivers;
        }
    }
  • HashMap mReceivers 存儲(chǔ)廣播和過(guò)濾器信息,方便管理BroadcastReceiver的注冊(cè)和取消鲫咽。
  • HashMap mActions存儲(chǔ)action和相對(duì)應(yīng)的ReceiverRecord列表签赃,方便管理廣播Actions的分發(fā)和執(zhí)行。
  • mPendingBroadcasts 存儲(chǔ)所有的BroadcastRecord分尸,方便管理BroadcastRecord創(chuàng)建和銷毀锦聊。
    //方便管理BroadcastReceiver的注冊(cè)和取消
    private final HashMap<BroadcastReceiver, ArrayList<IntentFilter>> mReceivers
            = new HashMap<BroadcastReceiver, ArrayList<IntentFilter>>();
    //方便管理廣播Actions的分發(fā)和執(zhí)行
    private final HashMap<String, ArrayList<ReceiverRecord>> mActions
            = new HashMap<String, ArrayList<ReceiverRecord>>();
    //管理BroadcastRecord,方便執(zhí)行
    private final ArrayList<BroadcastRecord> mPendingBroadcasts
            = new ArrayList<BroadcastRecord>();

注冊(cè)與反注冊(cè)

LocalBroadcastManager的注冊(cè)與反注冊(cè)寓落,直白的說(shuō)就是將廣播相對(duì)應(yīng)的必要元素(BroadcastReceiver括丁、IntentFilter、Action)進(jìn)行添加和移除伶选。

注冊(cè)廣播:

/**
     * Register a receive for any local broadcasts that match the given IntentFilter.
     *
     * @param receiver The BroadcastReceiver to handle the broadcast.
     * @param filter Selects the Intent broadcasts to be received.
     *
     * @see #unregisterReceiver
     */
    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);
            }
        }
    }

這里的注冊(cè)主要就是將注冊(cè)的廣播接收器BroadcastReceiver和過(guò)濾器IntentFilter添加到相應(yīng)的數(shù)據(jù)結(jié)構(gòu)當(dāng)中史飞。將BroadcastReceiver作為key,把IntentFilter添加到對(duì)應(yīng)的Value的集合中仰税。將IntentFilter中的action作為key构资,將ReceiverRecord對(duì)象(包含對(duì)應(yīng)的BroadcastReceiver和IntentFilter)添加到對(duì)應(yīng)的Value的集合中。添加到這些數(shù)據(jù)結(jié)構(gòu)中就是為了方便反注冊(cè)和廣播分發(fā)陨簇。

取消注冊(cè):

/**
     * Unregister a previously registered BroadcastReceiver.  <em>All</em>
     * filters that have been registered for this BroadcastReceiver will be
     * removed.
     *
     * @param receiver The BroadcastReceiver to unregister.
     *
     * @see #registerReceiver
     */
    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);
                        }
                    }
                }
            }
        }
    }

取消注冊(cè)就是將需要取消的BroadcastReceiver以及對(duì)應(yīng)的IntentFilter和Action全部移除河绽。源碼中使用了3個(gè)for循環(huán),遍歷了mReceivers和mActions纹笼,移除所有的相應(yīng)元素苟跪。

發(fā)送與分發(fā)

發(fā)送廣播:

/**
     * Broadcast the given intent to all interested BroadcastReceivers.  This
     * call is asynchronous; it returns immediately, and you will continue
     * executing while the receivers are run.
     *
     * @param intent The Intent to broadcast; all receivers matching this
     *     Intent will receive the broadcast.
     *
     * @see #registerReceiver
     */
    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;
    }

發(fā)送廣播的內(nèi)部機(jī)制簡(jiǎn)單來(lái)說(shuō)就是,根據(jù)Intent中的action兄猩,從mAction中取出對(duì)應(yīng)的ReceiverRecord列表,然后遍歷所有的ReceiverRecord援岩,判斷其IntentFilter是否與Intent中的action, type, scheme, data, categories相匹配掏导,如果匹配成功羽峰,就將ReceiverRecord添加到mPendingBroadcasts中,最后執(zhí)行mHandler.sendEmptyMessage(int what)交由Handler去執(zhí)行值纱。

分發(fā)執(zhí)行:

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);
                }
            }
        }
    }

mHandler收到消息后會(huì)執(zhí)行executePendingBroadcasts()方法虐唠,將mPendingBroadcasts
轉(zhuǎn)換成數(shù)組brs惰聂,遍歷brs中所有的BroadcastRecord,再遍歷所有的BroadcastReceiver杆故,調(diào)用其onReceive方法溉愁,完成整個(gè)廣播的執(zhí)行。

總結(jié)

在整個(gè)源碼分析的過(guò)程中撤蟆,我們可以清晰的看到堂污,LocalBroadcastManager的核心機(jī)制還是使用的Handler,與一般的廣播使用Binder機(jī)制完全不一樣息楔。從而做到了開篇所說(shuō)的幾個(gè)優(yōu)點(diǎn):當(dāng)前APP內(nèi)部通信扒披,數(shù)據(jù)安全,無(wú)可利用漏洞愿险,且效率更高。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末风秤,一起剝皮案震驚了整個(gè)濱河市缤弦,隨后出現(xiàn)的幾起案子彻磁,更是在濱河造成了極大的恐慌,老刑警劉巖累提,帶你破解...
    沈念sama閱讀 217,084評(píng)論 6 503
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件斋陪,死亡現(xiàn)場(chǎng)離奇詭異置吓,居然都是意外死亡,警方通過(guò)查閱死者的電腦和手機(jī)骑科,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,623評(píng)論 3 392
  • 文/潘曉璐 我一進(jìn)店門咆爽,熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái)置森,“玉大人,你說(shuō)我怎么就攤上這事呛凶⌒刑埃” “怎么了?”我有些...
    開封第一講書人閱讀 163,450評(píng)論 0 353
  • 文/不壞的土叔 我叫張陵崭捍,是天一觀的道長(zhǎng)殷蛇。 經(jīng)常有香客問(wèn)我,道長(zhǎng)亮航,這世上最難降的妖魔是什么匀们? 我笑而不...
    開封第一講書人閱讀 58,322評(píng)論 1 293
  • 正文 為了忘掉前任昼蛀,我火速辦了婚禮,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘沦辙。我一直安慰自己,他們只是感情好详民,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,370評(píng)論 6 390
  • 文/花漫 我一把揭開白布陌兑。 她就那樣靜靜地躺著兔综,像睡著了一般。 火紅的嫁衣襯著肌膚如雪涧窒。 梳的紋絲不亂的頭發(fā)上锭亏,一...
    開封第一講書人閱讀 51,274評(píng)論 1 300
  • 那天慧瘤,我揣著相機(jī)與錄音,去河邊找鬼糖儡。 笑死休玩,一個(gè)胖子當(dāng)著我的面吹牛,可吹牛的內(nèi)容都是我干的永部。 我是一名探鬼主播呐矾,決...
    沈念sama閱讀 40,126評(píng)論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼蜒犯,長(zhǎng)吁一口氣:“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼罚随!你這毒婦竟也來(lái)了?” 一聲冷哼從身側(cè)響起遵班,我...
    開封第一講書人閱讀 38,980評(píng)論 0 275
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤狭郑,失蹤者是張志新(化名)和其女友劉穎汇在,沒(méi)想到半個(gè)月后,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體亩鬼,經(jīng)...
    沈念sama閱讀 45,414評(píng)論 1 313
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡辛孵,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,599評(píng)論 3 334
  • 正文 我和宋清朗相戀三年魄缚,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了冶匹。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片咆瘟。...
    茶點(diǎn)故事閱讀 39,773評(píng)論 1 348
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡袒餐,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出卧檐,到底是詐尸還是另有隱情霉囚,我是刑警寧澤,帶...
    沈念sama閱讀 35,470評(píng)論 5 344
  • 正文 年R本政府宣布,位于F島的核電站盅粪,受9級(jí)特大地震影響,放射性物質(zhì)發(fā)生泄漏瓤逼。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,080評(píng)論 3 327
  • 文/蒙蒙 一库物、第九天 我趴在偏房一處隱蔽的房頂上張望贷帮。 院中可真熱鬧撵枢,春花似錦锄禽、人聲如沸沃但。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,713評(píng)論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)晒他。三九已至陨仅,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間触徐,已是汗流浹背饺蔑。 一陣腳步聲響...
    開封第一講書人閱讀 32,852評(píng)論 1 269
  • 我被黑心中介騙來(lái)泰國(guó)打工孔祸, 沒(méi)想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留崔慧,地道東北人穴墅。 一個(gè)月前我還...
    沈念sama閱讀 47,865評(píng)論 2 370
  • 正文 我出身青樓皇钞,卻偏偏與公主長(zhǎng)得像夹界,于是被迫代替她去往敵國(guó)和親可柿。 傳聞我的和親對(duì)象是個(gè)殘疾皇子复斥,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,689評(píng)論 2 354

推薦閱讀更多精彩內(nèi)容