官术网_书友最值得收藏!

The flow control problem

On the one hand, the preceding explanation may have taught us that the central reason to embrace the PUSH model was the optimization of the overall processing time by decreasing the amount of asking to the very minimum. That is why the RxJava 1.x and similar libraries were designed for pushing data, and that is why streaming became a valuable technique for communication between components within a distributed system.

On the other hand, in combination with only the PUSH model, that technique has its limitations. As we might remember from Chapter 1Why Reactive Spring?, the nature of message-driven communication assumes that as a response to the request, the service may receive an asynchronous, potentially infinite stream of messages. That is the tricky part because if a producer disrespects the consumer's throughput possibility it may affect the overall system stability in ways described in the following two sections.

主站蜘蛛池模板: 婺源县| 建宁县| 吉隆县| 江津市| 宜都市| 顺义区| 横峰县| 乌苏市| 宿松县| 德格县| 屏边| 虞城县| 清原| 乾安县| 鹤壁市| 得荣县| 阿拉尔市| 凯里市| 蛟河市| 慈利县| 姚安县| 麻栗坡县| 正定县| 陵川县| 运城市| 云林县| 雷波县| 谷城县| 浦城县| 松原市| 吉木乃县| 泾川县| 永嘉县| 永和县| 内丘县| 肃南| 平远县| 库伦旗| 井研县| 卢湾区| 安西县|