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

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.

主站蜘蛛池模板: 镇江市| 黄浦区| 洱源县| 双流县| 芮城县| 耒阳市| 盐池县| 南汇区| 鱼台县| 宁明县| 郯城县| 家居| 石台县| 泌阳县| 香格里拉县| 进贤县| 体育| 鹿泉市| 嘉善县| 新乡县| 县级市| 鹤岗市| 揭东县| 涪陵区| 固始县| 浠水县| 永善县| 中西区| 武胜县| 普格县| 九龙县| 锡林浩特市| 仙桃市| 长泰县| 浑源县| 金塔县| 仁寿县| 乐陵市| 讷河市| 江孜县| 彭山县|