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响应式流的生命周期是什么这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是创新互联,小编将为大家推送更多相关知识点的文章,欢迎关注!
新闻标题:web响应式流的生命周期是什么
网页链接:http://azwzsj.com/article/ggoeej.html