關(guān)于Rxjs的現(xiàn)狀
鑒于響應(yīng)式編程近幾年才開(kāi)始真正流行源葫，而且響應(yīng)式的理念也并不是在所有領(lǐng)域都深得人心咙边，對(duì)于不是特別喜歡追求新概念新技術(shù)的公司或程序員來(lái)說(shuō)，不排除有確實(shí)沒(méi)聽(tīng)說(shuō)過(guò)的可能扎附。
對(duì)于聽(tīng)說(shuō)過(guò)的人來(lái)說(shuō)第煮，可能也并不是都理解響應(yīng)式編程的理念杜秸，可能只是把 Rx 當(dāng)成和 Promise放仗、Async 類似的用來(lái)替代 Callback 的異步方案，但是可能自己的需求用 Promise 等已經(jīng)足夠解決撬碟，所以沒(méi)有足夠的意愿和時(shí)間來(lái)了解 Rx诞挨。
對(duì)于了解 Rx 的響應(yīng)式編程及其優(yōu)勢(shì)的人來(lái)說(shuō)，可能出于實(shí)際項(xiàng)目中團(tuán)隊(duì)合作的需要呢蛤，并不經(jīng)常能夠使用 Rx惶傻。并且目前大部分類庫(kù)還是基于回調(diào)或者 Promise 的，要使用 Rx 的話需要一些膠水代碼來(lái)封裝顾稀，對(duì)于異步邏輯不是足夠復(fù)雜的可能在 Glue 上也需要一些額外的成本达罗。
對(duì)于用 ES5 的開(kāi)發(fā)人員來(lái)說(shuō)坝撑，由于沒(méi)有 Lambda 所以 Rx 在寫(xiě)法上可能也較為復(fù)雜静秆。
Rx 的一個(gè)問(wèn)題就是它其實(shí)是一個(gè) paradigm，侵入性很強(qiáng)巡李。你如果要用 Rx 寫(xiě)東西抚笔，最好就整個(gè)系統(tǒng)都是以 Rx 為核心來(lái)設(shè)計(jì)。（比如 Cycle.js）對(duì)于已經(jīng)用傳統(tǒng)范式開(kāi)發(fā)了一定時(shí)間的項(xiàng)目來(lái)說(shuō)侨拦，引入 Rx 會(huì)比較尷尬殊橙。
另外單就前端來(lái)說(shuō)，很多場(chǎng)景并沒(méi)有復(fù)雜到需要 Rx，這種時(shí)候用 Rx 反而成本變高了膨蛮。
Rxjs是什么
RxJS全名Reactive Extensions for JavaScript : Javascript的響應(yīng)式擴(kuò)展
Rxjs是一個(gè)基于JavaScript的庫(kù)
還有支持其他語(yǔ)言的庫(kù)叠纹，比如：Rxjava
什么是響應(yīng)式編程(RP: Reactive programming)
響應(yīng)式的思路：是把隨時(shí)間不斷變化的數(shù)據(jù)、狀態(tài)敞葛、事件等等轉(zhuǎn)成可被觀察的序列(Observable Sequence)誉察，然后訂閱序列中那些Observable對(duì)象的變化，一旦變化惹谐，就會(huì)執(zhí)行事先安排好的各種轉(zhuǎn)換和操作持偏。
響應(yīng)式編程是使用異步數(shù)據(jù)流進(jìn)行編程
由誰(shuí)發(fā)明的？
微軟出品
為什么要使用（它解決了什么問(wèn)題）
有人這樣說(shuō) ：
RxJS是一個(gè)解決異步問(wèn)題的JS開(kāi)發(fā)庫(kù).它起源于 Reactive Extensions 項(xiàng)目氨肌，它帶來(lái)了觀察者模式和函數(shù)式編程的相結(jié)合的最佳實(shí)踐.觀察者模式是一個(gè)被實(shí)踐證明的模式鸿秆，基于生產(chǎn)者（事件的創(chuàng)建者）和消費(fèi)者（事件的監(jiān)聽(tīng)者）的邏輯分離關(guān)系.
知乎上這樣說(shuō)：
RxJS/Cycle.js解決的是數(shù)據(jù)流的問(wèn)題，為什么有數(shù)據(jù)流的問(wèn)題怎囚，是因?yàn)楦鼉A向于或者受限于使用單向數(shù)據(jù)綁定卿叽，核心其實(shí)解決的是State管理的問(wèn)題。偏向于Redux或者Flux架構(gòu)會(huì)有全局State的困擾
Rxjs的原理恳守，核心
Rxjs核心概念之Observable
對(duì)觀察者模式的實(shí)現(xiàn)才是Rxjs的核心附帽，但這僅僅是RxJS旅程的開(kāi)始，豐富的擴(kuò)展 才是RxJS的威力所在井誉。
Observable（可觀察對(duì)象）是基于推送（Push）運(yùn)行時(shí)執(zhí)行（lazy）的多值集合
就 RxJS 來(lái)說(shuō)蕉扮，可以把 JavaScript 工程師分為以下幾個(gè)層次：
沒(méi)聽(tīng)說(shuō)過(guò) RxJS 的；
聽(tīng)說(shuō)過(guò)但是不會(huì)的颗圣；
會(huì)的但是不常用的喳钟；
會(huì)的并且經(jīng)常用的。
下面就來(lái)說(shuō)說(shuō)說(shuō)它的用法
Rxjs的用法
RxJS的基本用法:
Rx.Observable.*創(chuàng)建一個(gè)Observable對(duì)象當(dāng)它發(fā)生變化時(shí)在岂，以流式的方式觸發(fā)各種轉(zhuǎn)換（如有需要可以對(duì)變化的值做合并奔则、映射、過(guò)濾等操作）蔽午，最后傳到訂閱回調(diào)拿到處理后的最終結(jié)果易茬。
-
數(shù)據(jù)的轉(zhuǎn)換
Rxjs將數(shù)據(jù)分為兩種類型：
- 普通數(shù)據(jù) - 比如：數(shù)組，字符串及老，json對(duì)象之類的
-
可觀測(cè)對(duì)象 - 比如使用Rx.Observable.create()方法獲得的對(duì)象
數(shù)據(jù)轉(zhuǎn)換的過(guò)程
就像普通數(shù)據(jù)可以進(jìn)行加抽莱、減、乘骄恶、除等運(yùn)算一樣食铐，RxJS提供了相當(dāng)多的 擴(kuò)展方法來(lái)擴(kuò)展對(duì)Observable對(duì)象的操作能力。
比如你可以使用from()方法將普通的數(shù)據(jù)變換到Observable域僧鲁，或者 使用to()方法將Observable還原為普通數(shù)據(jù)：
var a = Rx.Observable.from([1,2,3,4]);
var b = a.toArray();
-
create()方法的使用
使用create方法從零開(kāi)始創(chuàng)建一個(gè)可觀測(cè)序列/Observable：
create方法的參數(shù)是一個(gè)封裝數(shù)據(jù)生成邏輯的函數(shù)虐呻，其參數(shù)為觀測(cè)者/Observer：
var generator = function(observer){
//數(shù)據(jù)生成邏輯
}
Rx.Observable.create(generator);
在函數(shù)generator的實(shí)現(xiàn)中象泵，通過(guò)調(diào)用參數(shù)對(duì)象observer的三個(gè)方法，實(shí)現(xiàn)數(shù)據(jù) 的生成斟叼、錯(cuò)誤的通知和結(jié)束聲明：
onNext(data)* - 向觀測(cè)者傳送新的數(shù)據(jù)data
onError(err)* - 通知觀測(cè)者有錯(cuò)誤發(fā)生偶惠，并且終止當(dāng)前序列
onCompleted()* - 通知觀測(cè)者當(dāng)前序列已結(jié)束
-
簡(jiǎn)單擴(kuò)展方法的使用：
或者將多個(gè)可觀測(cè)對(duì)象使用concat()方法拼接起來(lái)：
//a：1 2 3
//b: 4 5 6
//c: 7 8 9
a.concat(b,c); //結(jié)果： 1 2 3 4 5 6 7 8 9
或者對(duì)Observable對(duì)象生成的數(shù)據(jù)使用sum()方法求和：
//a: 1 2 3
a.sum(); //結(jié)果：6
或者對(duì)Observable對(duì)象生成的每個(gè)數(shù)據(jù)進(jìn)行映射處理：
//a: 1 2 3
a.map(function(d,i){ return d*10 }) //結(jié)果： 10 20 30
這些擴(kuò)展的方法，RxJS稱之為操作符/Operator朗涩，一個(gè)操作符通常返回的 是另一個(gè)新的Observable對(duì)象洲鸠，這意味著它還處于Observable域，從而 可以將多個(gè)操作符鏈接起來(lái)馋缅，構(gòu)成一條對(duì)Observable進(jìn)行處理的流水線：
Rx.Observable.of(1,2,3) // 1 2 3
.map(function(d){ return d*10;}) // 10 20 30
.concat(Rx.Observable.from([4,5,6])) // 10 20 30 4 5 6
.subscribe(
function(d){ console.log(d);},
function(e){ console.log(e);},
function(){ console.log("done");}
)
