国产一级牲交视频播放在线观看_中文字幕日韩高清dvd_在线观看日韩免费黄色视频_91在线国自产拍_国产成人精品优优av_色又黄又爽18禁免费网站现观看_久久久亚洲AV无码精夜夜嗨_免费日本A级黄色片_两个人www高清免费视频_欧美极品少妇作爱在线

時(shí)魚科技

咨詢熱線

咨詢熱線

0755-23223151

您當(dāng)前的位置:首頁 >> 新聞動(dòng)態(tài) >> 騰訊云TVP李智慧:同程藝龍響應(yīng)式架構(gòu)實(shí)踐

騰訊云TVP李智慧:同程藝龍響應(yīng)式架構(gòu)實(shí)踐

發(fā)布時(shí)間:2019-11-06 來源:深圳市時(shí)魚科技有限公司 瀏覽次數(shù):1,328次

10月19日,云+社區(qū)開發(fā)者大會(huì)(北京站)圓滿落幕。本次開發(fā)者大會(huì)的主題為“5G探索:核心技術(shù)與挑戰(zhàn)”,邀請(qǐng)了騰訊內(nèi)部及業(yè)內(nèi)行業(yè)大咖就5G場(chǎng)景下應(yīng)該如何面對(duì)新業(yè)務(wù)與挑戰(zhàn)?大型網(wǎng)站的技術(shù)應(yīng)該如何進(jìn)化?如何真正理解萬物互聯(lián)?5G有哪些值得探索與實(shí)踐的方向?5G對(duì)應(yīng)用發(fā)展的影響有哪些?等問題進(jìn)行了深度探討。同時(shí),在圓桌論壇環(huán)節(jié),各位技術(shù)專家也與到場(chǎng)的開發(fā)者們展開了開放式對(duì)話,精彩不斷。下邊是李智慧老師關(guān)于反應(yīng)式框架 Flower 的架構(gòu)設(shè)計(jì)原理與思想及落地實(shí)踐與效果的分享。

講師介紹:李智慧,騰訊云TVP,同程藝龍交通首席架構(gòu)師。長(zhǎng)期從事大數(shù)據(jù)、大型網(wǎng)站架構(gòu)的研發(fā)工作,曾擔(dān)任阿里技術(shù)專家、Intel亞太研發(fā)中心架構(gòu)師、宅米和WiFi萬能鑰匙CTO。Apache Spark源代碼貢獻(xiàn)者,著有暢銷書《大型網(wǎng)站技術(shù)架構(gòu):核心原理與案例分析》,極客時(shí)間《從零開始學(xué)大數(shù)據(jù)》專欄作者。現(xiàn)擔(dān)任同程藝龍交通首席架構(gòu)師。

我分享的題目叫“反應(yīng)式編程在同程藝龍的實(shí)踐?!边@個(gè)話題跟5G也有關(guān)系,當(dāng)5G的速度越來越快,終端跟服務(wù)器之間的通訊變得越來越密集,計(jì)算量越來越大的時(shí)候,我們的編程是什么樣子?我不知道今天各位同學(xué)來聽5G,有多少是做后臺(tái)技術(shù)開發(fā)的?5G時(shí)代對(duì)編程的影響是什么樣子?會(huì)使用什么樣的技術(shù)解決這些問題?我大概分享這些東西。

我個(gè)人的背景,現(xiàn)在在同程藝龍交通做首席架構(gòu)師,以前在阿里巴巴任技術(shù)專家,在Intel亞太研發(fā)中心做大數(shù)據(jù)架構(gòu)師,主要參與Apache Spark和Hive開發(fā),后來做過創(chuàng)業(yè),寫過一本書。接下來我們進(jìn)入正題,高并發(fā)是如何導(dǎo)致程序崩潰的?互聯(lián)網(wǎng)應(yīng)用包括將來的物聯(lián)網(wǎng),物聯(lián)網(wǎng)其實(shí)比互聯(lián)網(wǎng)大數(shù)據(jù)更大。典型的特征高并發(fā)大數(shù)據(jù)請(qǐng)求量特別大,數(shù)據(jù)量特別大,這種情況下開發(fā)一個(gè)單人應(yīng)用的系統(tǒng),比如說開發(fā)一個(gè)新浪微博可能幾天就開發(fā)出來,如果給幾億人使用,這個(gè)系統(tǒng)跟幾個(gè)人使用完全不一樣,這個(gè)大家可以理解。

新浪微博每一次技術(shù)進(jìn)步出來后他們做分享的時(shí)候,總是說現(xiàn)在新浪微博技術(shù)架構(gòu)的改進(jìn),可以支撐多少個(gè)人半夜發(fā)布他的信息,這樣去宣傳他的技術(shù)。就是因?yàn)橐坏┝看罅酥?,整個(gè)技術(shù)體系完全不一樣,造成的影響就是典型新浪微博這樣子的。當(dāng)明星們發(fā)布發(fā)一條爆炸性消息的時(shí)候,新浪微博的服務(wù)器就掛掉了,為什么會(huì)掛掉?因?yàn)閹浊f人在轉(zhuǎn)發(fā)這條消息,這些數(shù)據(jù)會(huì)對(duì)服務(wù)器造成很大的壓力,系統(tǒng)會(huì)崩潰。像剛才提到的數(shù)據(jù)量會(huì)呈現(xiàn)幾倍、幾十倍的增加,用戶的應(yīng)用場(chǎng)景也會(huì)更加的復(fù)雜,這個(gè)時(shí)候服務(wù)器如何應(yīng)對(duì)?編程方式是不是也有革命性的變化。

未來究竟什么樣子?連5G本身還在探索的過程中,這個(gè)編程怎么樣?為時(shí)尚早。今天更多分享一下我的看法和實(shí)踐。

高并發(fā)是如何導(dǎo)致程序崩潰的?程序怎么就崩潰了?高并發(fā)的時(shí)候到底發(fā)生了什么?我們看一下后端服務(wù)器的具體架構(gòu)大概這樣子,用戶并發(fā)請(qǐng)求進(jìn)入到服務(wù)器,前面要經(jīng)過負(fù)載均衡,負(fù)載均衡之后進(jìn)入到服務(wù)器,在服務(wù)器里面運(yùn)行著一個(gè)Web容器,Java開發(fā)的話可能就是一個(gè)Tomcat。當(dāng)一個(gè)用戶請(qǐng)求進(jìn)來以后,容器如何去處理這個(gè)請(qǐng)求?寫的程序如何去處理請(qǐng)求?這個(gè)里面有一個(gè)關(guān)鍵點(diǎn)會(huì)被經(jīng)常忽略掉,這個(gè)工作是由Web容器去做的,Web容器去監(jiān)聽80端口,監(jiān)聽80端口以后收到一個(gè)用戶請(qǐng)求,容器就會(huì)為這個(gè)用戶請(qǐng)求創(chuàng)建一個(gè)計(jì)算線程,這個(gè)線程負(fù)責(zé)用戶請(qǐng)求的操作處理,一直到處理完之后返回響應(yīng),每一個(gè)請(qǐng)求進(jìn)來以后都創(chuàng)建一個(gè)線程,里面的線程數(shù)是有限的,現(xiàn)在是200個(gè)線程,創(chuàng)建200個(gè)線程以后如果有更多的用戶請(qǐng)求進(jìn)來怎么辦?就拒絕的,用戶這個(gè)時(shí)候就看到自己的請(qǐng)求失敗了。如果不拒絕,請(qǐng)求繼續(xù)進(jìn)來。進(jìn)入等待隊(duì)列會(huì)消耗資源,服務(wù)器的壓力非常大。如果更多用戶的請(qǐng)求都接受進(jìn)來,服務(wù)器的壓力會(huì)逐漸的增大,超過系統(tǒng)可用資源就會(huì)崩潰。為每一個(gè)用戶獨(dú)占一個(gè)線程造成資源的消耗,這個(gè)線程如果處理結(jié)束都好辦,如果處理來不及,這個(gè)時(shí)候有可能會(huì)導(dǎo)致系統(tǒng)巨大的負(fù)載增加,最后導(dǎo)致系統(tǒng)崩潰,這是一個(gè)點(diǎn)。為什么會(huì)特別慢呢?如果快速處理完釋放了線程,下一個(gè)用戶的請(qǐng)求可以繼續(xù)處理,如果不釋放的話就會(huì)堆積在這里,為什么會(huì)堆積在這里?因?yàn)榫€程被阻塞了,線程為什么被阻塞了?線程不僅僅在當(dāng)?shù)刈鲆恍〤PU處理的計(jì)算,還會(huì)跟外部服務(wù)資源進(jìn)行通信,還要調(diào)用一些其他的微服務(wù),還要訪問數(shù)據(jù)庫,還有其他的東西,這個(gè)時(shí)候線程請(qǐng)求微服務(wù)進(jìn)行遠(yuǎn)程調(diào)用或者是訪問數(shù)據(jù)庫都有可能,當(dāng)請(qǐng)求遠(yuǎn)程操作的時(shí)候,請(qǐng)求是被阻塞了的,如果遠(yuǎn)程這些資源訪問的話快速響應(yīng)過來,也都還好。如果這個(gè)時(shí)候數(shù)據(jù)庫里面有個(gè)表,因?yàn)槭裁丛蝽憫?yīng)特別的慢,這個(gè)時(shí)候線程遲遲不能釋放,它不能釋放別的請(qǐng)求就沒有線程可用,就回到剛才所說的場(chǎng)景系統(tǒng)就崩潰了。這還是現(xiàn)在,就經(jīng)常會(huì)遇到這種崩潰的情況。如果到5G時(shí)代,請(qǐng)求會(huì)更加的頻繁和密集,計(jì)算量會(huì)越來越大。這種情況下,我們的系統(tǒng)崩潰的會(huì)更加頻繁,我認(rèn)為就是要面對(duì)這種問題。

解決方案,反應(yīng)式編程大家都知道,有一些比較主流的解決方案。我們這邊自己搞了一個(gè)編程框架叫Flower,我們看一下Flower怎么解決這些問題的?請(qǐng)求還是并發(fā)進(jìn)入容器,容器就要監(jiān)聽那個(gè)端口,這個(gè)時(shí)候我們看看Flower是怎么解決這個(gè)問題的?Flower又是如何實(shí)現(xiàn)的?分為兩步:

第一步,請(qǐng)求進(jìn)入容器以后,每一個(gè)請(qǐng)求不再占據(jù)一個(gè)線程,把它異步化。每一個(gè)請(qǐng)求進(jìn)來以后,容器還會(huì)啟動(dòng)一個(gè)線程,啟動(dòng)線程之后把傳輸過來的二進(jìn)制流轉(zhuǎn)換成對(duì)象,轉(zhuǎn)換成對(duì)象以后,容器的工作就結(jié)束了,這個(gè)容器線程工作就結(jié)束了,把這個(gè)請(qǐng)求交給后面,想象一下容器只要啟動(dòng)一個(gè)線程。做這件事情可以是亞毫秒級(jí)的,1毫秒以內(nèi)就可以完成這個(gè)協(xié)議的處理,因?yàn)樗蛔鲇?jì)算,只是把協(xié)議處理完就可以,這個(gè)時(shí)候如果還是200個(gè),300個(gè)、500個(gè)都沒有關(guān)系,幾百個(gè)并發(fā)請(qǐng)求一秒鐘過來,它的處理是亞毫秒級(jí)的,一秒鐘可以處理1000以上的請(qǐng)求,一個(gè)線程處理幾百個(gè)請(qǐng)求都是綽綽有余的,因?yàn)樗]有做太多的事情,只是把請(qǐng)求分發(fā)出去,一個(gè)線程就可以做這么多的事情,處理所有的請(qǐng)求。請(qǐng)求進(jìn)來之后,這個(gè)時(shí)候就不會(huì)被拒絕,以前200個(gè)線程300個(gè)線程就沒有了,現(xiàn)在2000個(gè)請(qǐng)求進(jìn)來之后,一個(gè)線程全部處理了,所有數(shù)據(jù)全都處理了。然后這個(gè)請(qǐng)求就交給后面的處理,我們有一個(gè)Flower自己的運(yùn)行環(huán)境,理論上講也可以是只用一個(gè)線程。200個(gè)請(qǐng)求進(jìn)來以后,變成200個(gè)請(qǐng)求對(duì)象,或者更多個(gè)請(qǐng)求,2000個(gè)請(qǐng)求對(duì)象,2000個(gè)請(qǐng)求對(duì)象交給我們的Service去處理,2000個(gè)請(qǐng)求進(jìn)來可以迅速的把2000個(gè)請(qǐng)求都算完,計(jì)算只有零點(diǎn)零幾毫秒,幾毫秒可能就有2000個(gè)請(qǐng)求,而且只有一個(gè)線程。大家可以想象一個(gè)線程可以同時(shí)處理2000個(gè)請(qǐng)求,它處理完之后再交給下一個(gè)Service處理,這個(gè)里面是做一些預(yù)處理、參數(shù)校驗(yàn),后面真正的做邏輯計(jì)算,把它的處理交給下一個(gè)Service,下一個(gè)Service也可以復(fù)用剛才的線程,因?yàn)閯偛诺木€程算了ServiceA,也可以繼續(xù)算ServiceB,只需要一個(gè)線程就可以把所有的請(qǐng)求整個(gè)處理邏輯全部處理完。理論上可以這樣做到,處理完以后訪問數(shù)據(jù)庫,訪問數(shù)據(jù)庫的時(shí)候給數(shù)據(jù)庫發(fā)一個(gè)請(qǐng)求,同步數(shù)據(jù)庫處理的時(shí)候線程會(huì)處于阻塞狀態(tài),等到數(shù)據(jù)庫有了返回以后,線程就會(huì)被喚醒,喚醒以后它去執(zhí)行。從異步的方式來講,把這個(gè)請(qǐng)求發(fā)過去以后,查數(shù)據(jù)庫的SQL發(fā)出去以后,線程就沒事了,可以繼續(xù)處理Service,不用等。等到數(shù)據(jù)庫真正有響應(yīng)結(jié)果以后,我們想象以下有個(gè)ServiceC,有了結(jié)果以后變成消息了,都是消息啟動(dòng),返回來的消息就是數(shù)據(jù)庫返回來的結(jié)果集,交給ServiceC,ServiceC又有消息等著處理,它也是獨(dú)立的。ServiceC有消息處理的時(shí)候,這個(gè)線程還可以回到ServiceC,處理完之后返回到結(jié)果,就可以把ServiceC拿到的結(jié)果返回回去。通過這樣的方式,利用一個(gè)線程就把整個(gè)業(yè)務(wù)全部處理了。這個(gè)里面有一個(gè)線程專門做業(yè)務(wù)邏輯的處理,有一個(gè)線程專門做請(qǐng)求的接入,阻塞式編程200個(gè)線程就是200個(gè)請(qǐng)求,任何一種打破平衡都會(huì)導(dǎo)致系統(tǒng)失效宕機(jī)了。但是Flower利用這種方式只用幾個(gè)線程可以解決2000個(gè)請(qǐng)求。解決方案核心點(diǎn)是這樣的,如果處理的速度足夠快,資源比較平衡的話,可能處理更多的并發(fā)請(qǐng)求,系統(tǒng)算力會(huì)變得更加的強(qiáng)大。當(dāng)5G來臨用戶請(qǐng)求更多的時(shí)候,可以支持更大的算力。

這是Flower,它的工作原理是這樣子去提高性能。這是真實(shí)在同程藝龍做的一個(gè)重構(gòu),紅色是重構(gòu)后的,綠色是重構(gòu)前的,做了一次Flower重構(gòu)。左側(cè)是吞吐量TPS,綠色是重構(gòu)前的,紅色是重構(gòu)后的,重構(gòu)前是200TPS,重構(gòu)以后是450TPS,現(xiàn)在提升了1倍多。右邊是響應(yīng)時(shí)間,紅色是重構(gòu)后的,綠色是重構(gòu)前的。經(jīng)過重構(gòu)以后發(fā)現(xiàn)響應(yīng)時(shí)間特性表現(xiàn)的更好一點(diǎn),特別是在高并發(fā)情況下。

Flower究竟怎么實(shí)現(xiàn)的?剛才提到一個(gè)消息驅(qū)動(dòng)。Flower自己沒有運(yùn)行時(shí)環(huán)境,剛才這樣一套都有自己的運(yùn)行時(shí)環(huán)境。Flower底層利用Akka的Actor,我們看一下在Actor進(jìn)行通訊的時(shí)候怎么做的?為什么理想情況下,用一個(gè)線程就完成所有的服務(wù)計(jì)算?在傳統(tǒng)的編程里面服務(wù)調(diào)用、方法調(diào)用,當(dāng)A方法調(diào)B方法的時(shí)候,A方法的代碼行里面加了一行調(diào)用B方法的代碼,B方法執(zhí)行的時(shí)候,A方法下一行代碼一定是不執(zhí)行,傳統(tǒng)的方法調(diào)用是這樣子,都是阻塞式的編程,所謂阻塞似的編程當(dāng)你調(diào)用別的計(jì)算時(shí),當(dāng)前執(zhí)行一定是阻塞的,調(diào)用其他的方法執(zhí)行,執(zhí)行完了再返回,所有的執(zhí)行都是在由一個(gè)線程串起來,我們的代碼可以寫A方法,團(tuán)隊(duì)合作的時(shí)候那個(gè)團(tuán)隊(duì)實(shí)現(xiàn)A方法,另外一個(gè)團(tuán)隊(duì)實(shí)現(xiàn)B方法,但是我們可以在A里面調(diào)B。但是運(yùn)行期都是由一個(gè)線程執(zhí)行的,A執(zhí)行進(jìn)入B方法以后由B方法去執(zhí)行,執(zhí)行完了返回繼續(xù)執(zhí)行A方法,這是阻塞式編程。

在Actor模型里面,所有的計(jì)算都是以Actor為單位進(jìn)行,Actor之間的調(diào)用沒有延時(shí)和阻塞,由Actor調(diào)用另外一個(gè)Actor,是直接給另外一個(gè)Actor發(fā)個(gè)消息,發(fā)完消息可以繼續(xù)做別的,如果有消息的話可以繼續(xù)處理,Actor是通過消息傳輸進(jìn)行計(jì)算調(diào)用的,而不是直接的方法依賴調(diào)用的。

這個(gè)里面不同點(diǎn)有兩點(diǎn),他們之間沒有依賴和耦合,前面我們說一個(gè)公司有兩個(gè)團(tuán)隊(duì)在工作,一個(gè)團(tuán)隊(duì)寫了A方法,一個(gè)團(tuán)隊(duì)寫了B方法。A團(tuán)隊(duì)用A方法調(diào)B方法的時(shí)候,一定要依賴B方法的代碼,一定要知道B方法的簽名是什么樣子,即使通過接口定義的話,一定要依賴這個(gè)接口,方法簽名必須要知道,要知道它才能去調(diào)用,這是一種耦合。

第二,他們之間調(diào)用是阻塞的,我去調(diào)用B方法的時(shí)候,一旦調(diào)用B方法,B方法返回之前一定不能執(zhí)行下一行代碼,這是強(qiáng)耦合的阻塞。Actor將這兩點(diǎn)都解決了,當(dāng)兩個(gè)Actor進(jìn)行通信的時(shí)候,不需要去阻塞,也不需要依賴你,我就是把我的消息發(fā)送給你就可以,你能夠去處理我的消息就可以,大家基于中間消息協(xié)議進(jìn)行編程,不是基于方法依賴進(jìn)行編程。發(fā)送者也是Actor,發(fā)送者要給另外一個(gè)Actor發(fā)個(gè)消息讓他進(jìn)行處理的時(shí)候,和A方法調(diào)B方法一回事,我調(diào)一個(gè)B方法,其實(shí)是讓B方法幫忙我去處理,這跟我給他發(fā)一個(gè)消息處理也是一樣子,邏輯上是一回事。當(dāng)Actor給另外一個(gè)Actor發(fā)消息的時(shí)候,這個(gè)過程其實(shí)是持有另外一個(gè)Actor的Ref,這個(gè)Ref就是一個(gè)路徑,只要找到Actor就可以。知道Actor以后,就通過ActorRef發(fā)消息,ActorRef把消息推到郵箱里面,然后Actor立刻返回,你什么時(shí)候處理我不管,發(fā)送完之后自己可以做別的。另外一個(gè)Actor檢查郵箱里面是否有消息,如果有消息取出消息進(jìn)行處理,處理完之后要調(diào)別的Actor消息發(fā)出去,自己也結(jié)束了。在這個(gè)里面一方面Actor之間沒有依賴和耦合,我不需要知道你在哪里,這個(gè)Actor可能在一個(gè)機(jī)器里,也可能在天邊,都沒有關(guān)系,只要能把這個(gè)消息投遞進(jìn)去就可以,可以遠(yuǎn)程投遞。另外沒有阻塞,發(fā)給你以后你什么時(shí)候處理不管你,發(fā)給你以后我就結(jié)束了,可以繼續(xù)做我的事情。

最終產(chǎn)生的效果,由一個(gè)線程去掃描所有的Actor郵箱里有沒有消息,有消息就把消息拿出來讓另外一個(gè)Actor處理,處理完以后看其他的Actor是否也有消息,一個(gè)線程可以掃描所有Actor。線程是很重的,但是Actor可以創(chuàng)建幾百萬個(gè)都沒有關(guān)系,可以輕量的創(chuàng)建,如果沒有消息大家都很安靜,如果有了消息就取消息進(jìn)行處理。理想情況下,一個(gè)線程可以掃描幾百萬,只用一個(gè)線程就可以做到,資源更省,調(diào)用更加的低耦合,操作更加的異步,無需阻塞。剛才提到的一些特性都是Actor提供給我們的。如果大家自己寫Actor發(fā)送這些消息,去找這些消息或者是處理消息之類,這些是很痛苦的一件事情,我自己在英特爾時(shí)用Actor做過大數(shù)據(jù)的程序,有點(diǎn)小亂。如果日常用Actor進(jìn)行開發(fā)還是有點(diǎn)痛苦,我們要做的Flower把Actor分裝成Service,像傳統(tǒng)的編程Service一樣,只需要寫Service代碼后編排一下流程,這個(gè)Service結(jié)束以后下一個(gè)Service怎么樣處理?在編程應(yīng)用流程做一個(gè)包裝。

使用這個(gè)框架做異步開發(fā)非常的簡(jiǎn)單,5分鐘就開發(fā)完。第一步寫個(gè)Service,進(jìn)來以后總是一個(gè)個(gè)操作,比如說我們利用一個(gè)Service調(diào)用一個(gè)Service,寫Service服務(wù)就好了,寫服務(wù)用框架提供的Service接口,做的就是輸入一個(gè)消息輸出一個(gè)消息,這個(gè)Service要處理的消息是什么樣?拿到消息以后在里面進(jìn)行處理,這個(gè)時(shí)候Service就完成。要用多個(gè)Service去完成的話,我們其實(shí)提倡Service的粒度越小、功能越單一,越能夠復(fù)用。整個(gè)的處理過程拆分成很小的Service,把這些Service串聯(lián)起來就好,串聯(lián)成一個(gè)流程在系統(tǒng)里自動(dòng)的完成,串聯(lián)成流程也非常的簡(jiǎn)單,可以編輯流程。Service寫的時(shí)候并不知道下一個(gè)Service如何處理,但是寫完以后變成流程,上手5分鐘就可以。

這是Flower的可視化,可以通過編程的方式把ServiceABC編成一個(gè)流程,也可以用更復(fù)雜一點(diǎn)的,最好用可視化的脫拽方式進(jìn)行編程,同時(shí)調(diào)用Service2和Service3,處理完以后交給Service5處理,Service交給Service4處理,Service4再返回Service3,最后匯總計(jì)算,用這樣的方式完成編排,提供可視化。當(dāng)然現(xiàn)在可以用文本編寫進(jìn)行編輯,要實(shí)現(xiàn)什么功能拖進(jìn)來就好,當(dāng)你要修改編碼的時(shí)候,中間處理的時(shí)候請(qǐng)用戶驗(yàn)證,加一個(gè)驗(yàn)證,也不需要去修改代碼,需要加一個(gè)Service拖到流程里面多一個(gè)驗(yàn)證,代碼完全不用修改。

如果用Spring編程的話,這個(gè)里是Spring調(diào)用的框架。

這是異步數(shù)據(jù)庫的訪問,系統(tǒng)會(huì)自動(dòng)把結(jié)果拿回來交給下一個(gè)Service處理,中間不會(huì)等待數(shù)據(jù)庫返回,不會(huì)停在那里。這個(gè)我們?cè)?jīng)遇到過一個(gè)案例,其中數(shù)據(jù)庫里面一張表特別慢,也不是系統(tǒng)崩潰,系統(tǒng)崩潰還好,系統(tǒng)崩潰一旦連接失敗后就失效,失效就返回。這個(gè)時(shí)候沒有崩潰,發(fā)一個(gè)請(qǐng)求過去還能響應(yīng),響應(yīng)5s、10s、20s這個(gè)時(shí)候就痛苦了,APP連接就超時(shí)了,這個(gè)時(shí)候一直給你一種慢查詢,占據(jù)線程,線程一直不能釋放。我們通過網(wǎng)關(guān)調(diào)用微服務(wù),微服務(wù)訪問數(shù)據(jù)庫然后調(diào)用其他第三方服務(wù)。微服務(wù)訪問這一張表里面就是特別慢,用了幾十秒,微服務(wù)全部被阻塞。因?yàn)榫W(wǎng)關(guān)也是調(diào)的微服務(wù),網(wǎng)關(guān)跟微服務(wù)之間也是同樣,因?yàn)樗鼪]有響應(yīng),所以網(wǎng)關(guān)跟微服務(wù)之間的消息全都是延遲,導(dǎo)致網(wǎng)關(guān)的線程全部被微服務(wù)阻塞。網(wǎng)關(guān)被微服務(wù)阻塞以后,線程都被微服務(wù)占滿,一張表導(dǎo)致所有的網(wǎng)關(guān)線程全部被鎖死,所有請(qǐng)求都進(jìn)不來,最后整個(gè)系統(tǒng)宕機(jī)了。這個(gè)微服務(wù)失效,對(duì)系統(tǒng)僅僅影響一些不太重要的業(yè)務(wù)場(chǎng)景,但是最后導(dǎo)致全部的服務(wù)停止。如果用Flower異步架構(gòu)的話,不會(huì)出現(xiàn)這種問題,不占用任何線程,你失效以后失去響應(yīng)了,頂多延遲的話用戶通訊延遲,不會(huì)阻塞整個(gè)線程,導(dǎo)致整個(gè)系統(tǒng)崩潰。

遠(yuǎn)程怎么辦?剛才提到遠(yuǎn)程通訊的異步微服務(wù)解決方案,服務(wù)是可編排的,這些Service可以跟網(wǎng)關(guān)應(yīng)用程序放在一起,也可以分布式編排。分布式編排微服務(wù)有一個(gè)注冊(cè)中心,在注冊(cè)中心進(jìn)行流程編排,第一個(gè)服務(wù)處理完之后下一個(gè)服務(wù)進(jìn)行處理,然后進(jìn)行可視化的編排。編排完以后,我要使用哪個(gè)流程進(jìn)行請(qǐng)求數(shù)據(jù)?這是根據(jù)URL綁定的請(qǐng)求,請(qǐng)求進(jìn)來以后就知道我通過哪個(gè)流程處理請(qǐng)求,到注冊(cè)中心把請(qǐng)求拉下來,看看哪個(gè)服務(wù)需要,把請(qǐng)求發(fā)送給它,底層是Actor通訊,底層給到它之后,自己自動(dòng)結(jié)束,處理下一個(gè)請(qǐng)求,我就發(fā)給它,然后到下一個(gè)Service,也會(huì)很好的異步化處理,處理完之后交給下一個(gè)Service,也可能是個(gè)遠(yuǎn)程的,可以通過Actor遠(yuǎn)程通信發(fā)送過去。一旦完成這個(gè)消息的投遞本身就結(jié)束了,結(jié)束之后就可以繼續(xù)處理。

這種情況下的遠(yuǎn)程編排變得更加的簡(jiǎn)單,因?yàn)檎{(diào)用之間沒有任何的依賴?,F(xiàn)在的編程依賴還是一個(gè)比較大的問題,一旦有了依賴,如果接口變化整個(gè)編程會(huì)非常的痛苦。而如果沒有任何的依賴你,這個(gè)里面前一個(gè)請(qǐng)求是下一個(gè)流程,下一個(gè)請(qǐng)求又走到另外一個(gè)Actor的Service去了,非常輕松。場(chǎng)景就算比較復(fù)雜,有這樣開發(fā)的功能,真正靈活用起來,我個(gè)人覺得還是比較憧憬。

為什么選擇Flower?現(xiàn)在已經(jīng)有一些反應(yīng)式編程框架,總的來說Flower是反應(yīng)式編程框架,Actor本身的編程有點(diǎn)不友好,對(duì)人們的編程習(xí)慣有些挑戰(zhàn),所以我們的技術(shù)用Flower這樣的編程框架。它為什么不用Web Flux和RxJava,如果我不想要函數(shù)式編程,用反應(yīng)式編程是被綁架的。其實(shí)你可以不用,反應(yīng)式編程無阻塞的及時(shí)響應(yīng)就可以了,我們可以很好的及時(shí)響應(yīng)。還有個(gè)消息驅(qū)動(dòng),沒有消息緩存,如果有大量的請(qǐng)求進(jìn)來系統(tǒng)崩潰怎么辦?MailBox是有溢出機(jī)制的,MailBox接收10個(gè)消息和20個(gè)消息,系統(tǒng)不會(huì)崩潰的。以前系統(tǒng)架構(gòu)一個(gè)解決方案處理不了那么多的請(qǐng)求怎么辦?那就限流,限流在請(qǐng)求的時(shí)候拒絕,到底什么時(shí)候拒絕我不知道,現(xiàn)在來說我們用MailBox任何一個(gè)Service處理不過來的時(shí)候,它自動(dòng)就溢出了,溢出就把消息丟棄了,也可以不丟棄,放在一個(gè)什么地方,重新走一個(gè)通道繼續(xù)處理也可以,而且非常的靈活,消息驅(qū)動(dòng)。更好的性能和更低的成本,更高的可能性。成本非常低,如果用的話幾分鐘能搞定,用起來好用,不需要自己搞一套比較痛苦的東西。

分享到:

在線客服

成為騰訊云VIP客戶

客服電話

0755-23223151

13923757411

微信同步