Java9第四篇-Reactive Stream API響應式程式設計
阿新 • • 發佈：2020-10-17
我計劃在後續的一段時間內，寫一系列關於java 9的文章，雖然java 9 不像Java 8或者Java 11那樣的核心java版本，但是還是有很多的特性值得關注。期待您能關注我，我將把java 9 寫成一系列的文章，大概十篇左右。
* [java9第一篇-可以在interface中定義私有方法了](http://www.zimug.com/java/java9-%e5%8f%af%e4%bb%a5%e5%9c%a8interface%e4%b8%ad%e5%ae%9a%e4%b9%89%e7%a7%81%e6%9c%89%e6%96%b9%e6%b3%95%e4%ba%86/.html)
* [java9第二篇-Java9改進try-with-resources語法](http://www.zimug.com/java/java9%e6%94%b9%e8%bf%9btry-with-resources%e8%af%ad%e6%b3%95/.html)
* [java9第三篇-支援多JDK版本下執行的Jar檔案打包方式](http://www.zimug.com/java/java9/%e6%94%af%e6%8c%81%e5%a4%9ajdk%e7%89%88%e6%9c%ac%e4%b8%8b%e8%bf%90%e8%a1%8c%e7%9a%84jar%e6%96%87%e4%bb%b6%e6%89%93%e5%8c%85%e6%96%b9%e5%bc%8f/.html)
Java 9的 Reactive Streams是對非同步流式程式設計的一種實現。它基於非同步釋出和訂閱模型，具有非阻塞“背壓”資料處理的特點。
**Non-blocking Back Pressure(非阻塞背壓)：它是一種機制，讓釋出訂閱模型中的訂閱者避免接收大量資料（超出其處理能力），訂閱者可以非同步通知釋出者降低或提升資料生產釋出的速率。它是響應式程式設計實現效果的核心特點！**
## 一、Java9 Reactive Stream API
Java 9提供了一組定義響應式流程式設計的介面。所有這些介面都作為靜態內部介面定義在`java.util.concurrent.Flow`類裡面。
下面是Java 響應式程式設計中的一些重要角色和概念，先簡單理解一下
* 釋出者（Publisher）是潛在的無限數量的有序資料元素的生產者。 它根據收到的需求(subscription)向當前訂閱者釋出一定數量的資料元素。
* 訂閱者（Subscriber）從釋出者那裡訂閱並接收資料元素。與釋出者建立訂閱關係後，釋出者向訂閱者傳送訂閱令牌（subscription），訂閱者可以根據自己的處理能力請求釋出者釋出資料元素的數量。
* 訂閱令牌（subscription）表示訂閱者與釋出者之間建立的訂閱關係。 當建立訂閱關係後，釋出者將其傳遞給訂閱者。 訂閱者使用訂閱令牌與釋出者進行互動，例如請求資料元素的數量或取消訂閱。
## 二、Java響應式程式設計四大介面
### 2.1.Subscriber Interface（訂閱者訂閱介面）
~~~
public static interface Su