摘要：響應式編程在介紹前，我們先聊聊響應式編程。響應式編程的一個關鍵概念是事件。今天，響應式編程最通用的一個場景是我們的移動必須做出對網絡調用用戶觸摸輸入和系統彈框的響應。并于年二月份正式向外展示了。

轉載請注明出處：https://zhuanlan.zhihu.com/p/20687178

RxJava系列1(簡介)

RxJava系列2(基本概念及使用介紹)

RxJava系列3(轉換操作符)

RxJava系列4(過濾操作符)

RxJava系列5(組合操作符)

RxJava系列6(從微觀角度解讀RxJava源碼)

RxJava系列7(最佳實踐)

提升開發效率，降低維護成本一直是開發團隊永恒不變的宗旨。近一年來國內的技術圈子中越來越多的開始提及Rx，經過一段時間的學習和探索之后我也深深的感受到了RxJava的魅力。它能幫助我們簡化代碼邏輯，提升代碼可讀性。這對于開發效率的提升、后期維護成本的降低幫助都是巨大的。個人預測RxJava一定是2016年的一個大趨勢，所以也有打算將它引入到公司現有的項目中來，寫這一系列的文章主要也是為了團隊內部做技術分享。

由于我本人是個Android程序猿，因此這一系列文章中的場景都是基于Android平臺的。如果你是個Java Web工程師或者是其它方向的那也沒關系，我會盡量用通俗的語言將問題描述清楚。

在介紹RxJava前，我們先聊聊響應式編程。那么什么是響應式編程呢？響應式編程是一種基于異步數據流概念的編程模式。數據流就像一條河：它可以被觀測，被過濾，被操作，或者為新的消費者與另外一條流合并為一條新的流。

響應式編程的一個關鍵概念是事件。事件可以被等待，可以觸發過程，也可以觸發其它事件。事件是唯一的以合適的方式將我們的現實世界映射到我們的軟件中：如果屋里太熱了我們就打開一扇窗戶。同樣的，當我們的天氣app從服務端獲取到新的天氣數據后，我們需要更新app上展示天氣信息的UI；汽車上的車道偏移系統探測到車輛偏移了正常路線就會提醒駕駛者糾正，就是是響應事件。

今天，響應式編程最通用的一個場景是UI：我們的移動App必須做出對網絡調用、用戶觸摸輸入和系統彈框的響應。在這個世界上，軟件之所以是事件驅動并響應的是因為現實生活也是如此。

本章節中部分概念摘自《RxJava Essentials》一書

Rx是微軟.Net的一個響應式擴展，Rx借助可觀測的序列提供一種簡單的方式來創建異步的，基于事件驅動的程序。2012年Netflix為了應對不斷增長的業務需求開始將.NET Rx遷移到JVM上面。并于13年二月份正式向外展示了RxJava。
從語義的角度來看，RxJava就是.NET Rx。從語法的角度來看，Netflix考慮到了對應每個Rx方法,保留了Java代碼規范和基本的模式。

那么到底什么是RxJava呢？我對它的定義是：RxJava本質上是一個異步操作庫，是一個能讓你用極其簡潔的邏輯去處理繁瑣復雜任務的異步事件庫。

Android平臺上為已經開發者提供了AsyncTask,Handler等用來做異步操作的類庫，那我們為什么還要選擇RxJava呢？答案是簡潔！RxJava可以用非常簡潔的代碼邏輯來解決復雜問題；而且即使業務邏輯的越來越復雜，它依然能夠保持簡潔！再配合上Lambda用簡單的幾行代碼分分鐘就解決你負責的業務問題。簡直逼格爆表，拿它裝逼那是極好的！

多說無益，上代碼！

假設我們安居客用戶App上有個需求，需要從服務端拉取上海浦東新區塘橋板塊的所有小區Community[] communities，每個小區下包含多套房源List houses；我們需要把塘橋板塊的所有總價大于500W的房源都展示在App的房源列表頁。用于從服務端拉取communities需要發起網絡請求，比較耗時，因此需要在后臺運行。而這些房源信息需要展示到App的頁面上，因此需要在UI線程上執行。(此例子思路來源于扔物線的給Android開發者的RxJava詳解一文)

new Thread() {
        @Override
        public void run() {
            super.run();
            //從服務端獲取小區列表
            List communities = getCommunitiesFromServer();
            for (Community community : communities) {
                List houses = community.houses;
                for (House house : houses) {
                    if (house.price >= 5000000) {
                        runOnUiThread(new Runnable() {
                            @Override
                            public void run() {
                                //將房子的信息添加到屏幕上
                                addHouseInformationToScreen(house);
                            }
                        });
                    }
                }
            }
        }
    }.start();

使用RxJava的寫法是這樣的：

Observable.from(getCommunitiesFromServer())
            .flatMap(new Func1>() {
                @Override
                public Observable call(Community community) {
                    return Observable.from(community.houses);
                }
            }).filter(new Func1() {
                @Override
                public Boolean call(House house) {
                    return house.price>=5000000;
                }
            }).subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Action1() {
                @Override
                public void call(House house) {
                    //將房子的信息添加到屏幕上
                    addHouseInformationToScreen(house);
                }
            });

從上面這段代碼我們可以看到：雖然代碼量看起來變復雜了，但是RxJava的實現是一條鏈式調用，沒有任何的嵌套；整個實現邏輯看起來異常簡潔清晰，這對我們的編程實現和后期維護是有巨大幫助的。特別是對于那些回調嵌套的場景。配合Lambda表達式還可以簡化成這樣：

Observable.from(getCommunitiesFromServer())
        .flatMap(community -> Observable.from(community.houses))
        .filter(house -> house.price>=5000000).subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(this::addHouseInformationToScreen);

簡潔！有美感！這才是一個有情懷的程序員應該寫出來的代碼。

看完這篇文章大家應該能夠理解RxJava為什么會越來越火了。它能極大的提高我們的開發效率和代碼的可讀性！當然了RxJava的學習曲線也是比較陡的，在后面的文章我會對主要的知識點做詳細的介紹，敬請關注！

如果大家喜歡這一系列的文章，歡迎關注我的知乎專欄和GitHub。

知乎專欄：https://zhuanlan.zhihu.com/baron

GitHub：https://github.com/BaronZ88