web響應式流的生命周期是什么

這篇文章主要講解了“web響應式流的生命周期是什么”，文中的講解內容簡單清晰，易于學習與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學習“web響應式流的生命周期是什么”吧！

總的來說就是三個階段。組裝時、訂閱時、運行時。其中組裝時是代碼的靜態表達，訂閱時、運行時描述的是響應式流程序運行起來時所設計的邏輯。

組裝時

這個階段就是我們建立處理模型的階段。基本上是解決了下面三個方面的問題。

1）定義這個 reactive stream 的數據來源是什么。Publisher

這個階段我們通過使用諸如 just(), range(), fromArray(), push(), create(), generate()等方法來設置數據源頭。

2）這個數據流的最終訂閱者是誰？Subscriber

我們在最下游 publisher 上通過調用 subscribe()方法把 subscriber 從下游到上游依次傳遞到最上游的包含數據源的 publisher。

3）數據到達最終訂閱者那里時需要做哪些轉換、處理？Operator

以上兩個調用解決了數據來源于哪里、被誰最終接收的問題。但是在數據從上游被傳遞到下游的過程中，我們往往需要對數據做各種處理。這個階段就各種 operator 大顯身手的地方，比如 map(), flatMap(), filter(), reduce(), scan(), concatMap(), usingWhen()… …
實際上每經歷一個 operator，就生成了一個新的中間級別的 publisher，這就是 reactive stream 的不可變性。

組裝時基本就是我們寫出的代碼定義出的靜態邏輯這部分。
程序運行起來，才會進入下面的兩個階段：訂閱時、運行時，所以說這兩個階段是程序的動態表現。

訂閱時

通過組裝時我們定義了什么數據(publisher)經過怎樣的處理(operator)最后傳遞給誰(subscriber)。而訂閱時這個階段，解決的問題是如何把調用下游 publisher 時傳入的 subscriber 依次傳遞給上游的的 publisher。可以想象 Project Reactor 在傳遞 subscriber 的時候是依次進行封裝之后傳遞的而不會是直接把下游的 subscriber 傳遞上去，因為以 operator 串聯起來的各個 publisher 都需要“自己”的 subscriber。可以體會下這里“Subscriber 鏈”的概念。
這個傳遞過程很重要，因為 subscriber 中的 onSubscribe(Subscription s)提供了上游 publisher 把 Subscription 傳遞給下游 Subscriber 的機制。
因為 Subscriber 只有通過 subsciption 的 request 方法才能啟動數據的流動。

運行時

經過組裝時、訂閱時，數據流已經“一觸即發”。我們只要通過上游傳遞給我們的 Subscription 調用 request()方法就可以觸發數據的流動了。
通過在 Subscirberd 的 onSubscription(), onNext()被回調時，向 Subscription 的 request()傳入不同的數字，我們分別可以實現拉模型、推模型、拉-推模型。
響應式流的所謂運行時狹義的講就是這種 Publisher 和 Subscriber 之間的信號交換，廣義的講也包括operator對數據個各種轉換、處理。

感謝各位的閱讀，以上就是“web響應式流的生命周期是什么”的內容了，經過本文的學習后，相信大家對web響應式流的生命周期是什么這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是億速云，小編將為大家推送更多相關知識點的文章，歡迎關注！