您好，我是湘王，這是我的博客園，歡迎您來，歡迎您再來～

十年的嵐皋網(wǎng)站建設(shè)經(jīng)驗(yàn)，針對(duì)設(shè)計(jì)、前端、開發(fā)、售后、文案、推廣等六對(duì)一服務(wù)，響應(yīng)快，48小時(shí)及時(shí)工作處理。營銷型網(wǎng)站建設(shè)的優(yōu)勢(shì)是能夠根據(jù)用戶設(shè)備顯示端的尺寸不同，自動(dòng)調(diào)整嵐皋建站的顯示方式，使網(wǎng)站能夠適用不同顯示終端，在瀏覽器中調(diào)整網(wǎng)站的寬度，無論在任何一種瀏覽器上瀏覽網(wǎng)站，都能展現(xiàn)優(yōu)雅布局與設(shè)計(jì)，從而大程度地提升瀏覽體驗(yàn)。成都創(chuàng)新互聯(lián)公司從事“嵐皋網(wǎng)站設(shè)計(jì)”,“嵐皋網(wǎng)站推廣”以來，每個(gè)客戶項(xiàng)目都認(rèn)真落實(shí)執(zhí)行。

前面把Java函數(shù)式編程的由來和最主要的核心知識(shí)點(diǎn)講完了。包括比較難懂的Lambda表達(dá)式是怎么演變而來的也全部都擼了一遍。Lambda表達(dá)式這種編程方式的確是讓人不太習(xí)慣，尤其是之前那種純面向?qū)ο缶幊痰乃季S模式一旦建立起來之后，想要再接受這種比較奇怪的語法和編程模式，確實(shí)是非常困難。但Lambda表達(dá)式和流式編程的出現(xiàn)，又催生了另一門新的技術(shù)：反應(yīng)式編程。

《三國演義》中說：“天下大勢(shì)，分久必合，合久必分”。在科技領(lǐng)域也是一樣。之前沒有科學(xué)的時(shí)候，由占星術(shù)、煉金術(shù)、神學(xué)等催生出了一系列的自然科學(xué)，像什么物理、化學(xué)、數(shù)學(xué)等等。等到這些學(xué)科演變的差不多了之后，又開始了逐步的融合。

反應(yīng)式編程就和這有點(diǎn)類似，它是融合了Lambda表達(dá)式、流式編程和觀察者模式的一種新的編程范式。

就像很多反應(yīng)式編程的技術(shù)書、官網(wǎng)和資料里面說的，“一切皆是流”，比如我們其實(shí)無時(shí)不刻都在呼吸對(duì)吧，而且吸入和呼出的都是空氣，也就是氣流，這個(gè)很好理解哈～然后我們的嘴巴會(huì)去吃東西，就是食物吧，它也會(huì)變成食物流，其他的也是一樣，像我們看到的外部的風(fēng)景啊、人物啊、抖音里面的視頻啊，都是視覺流，還有我們和其他人之間的談話、聊天什么的，都是語音流，而且這種視覺流和語音流很多都是持續(xù)的，源源不斷的。就像這樣：

而且這些流就是我們生活中每天都需要面對(duì)的各種各樣的事情，比如吃了東西，呼吸了新鮮空氣，就會(huì)讓我們獲得能量，就不會(huì)覺得餓或者沒力氣了，或者看到外面漂亮的風(fēng)景，小哥哥小姐姐，以及美食，或者說和朋友談話、聊天之后就會(huì)覺得很愉快，就能引起心理和生理反應(yīng)，或者說比如和誰一起吃工作餐談話，談的不愉快就直接結(jié)束，所以這里有個(gè)紅叉叉，正常結(jié)束的話就是一個(gè)豎線，比如這段時(shí)間對(duì)吃的、帥哥美女、聊天或者抖音都沒啥興趣，走冷淡風(fēng)，就不再對(duì)這些外部事件產(chǎn)生反應(yīng)了，所謂的反應(yīng)式編程里面所說的反應(yīng)，其實(shí)就是一種對(duì)行為的響應(yīng)。

如果把代碼想象成一個(gè)人的話，那么那些外部的事情用計(jì)算機(jī)專業(yè)的話來說叫事件，比如用戶點(diǎn)擊頁面按鈕發(fā)送消息、鍵盤輸入、物聯(lián)網(wǎng)設(shè)備不斷地發(fā)送信號(hào)等等，都是各種輸入流，而且程序需要對(duì)這些各種事件都做出響應(yīng)，或者反應(yīng)，而且要及時(shí)。用以前的方式也是可以的，不過如果這種事件很多，涉及的線程、回調(diào)就會(huì)很多，所以就需要一種新的編程方式來處理這種叫做mashup的混合式Web應(yīng)用開發(fā)。關(guān)于反應(yīng)式編程的一種正式的描述可以看反應(yīng)式編程官方的《反應(yīng)式宣言》：

剛才說的只是反應(yīng)式編程一些概念性或者是感性的認(rèn)識(shí)，真正要了解反應(yīng)式編程，還是要看代碼：

public static void main(String[] args) {

  Person person= new Person("zhangsan", 18);

// 數(shù)據(jù)怎么來就怎么處理，處理完后就結(jié)束
  Observable.just("1", 2, true, 0.618, person, new String("haha"))
    .subscribe(System.out::println);

}