对于Reactor的理解

1.Reactor集合了观察者模式和迭代器模式,观察者模式体现在Publisher和Subscriber两个接口之间的回调,迭代器模式体现在

Subscriber的onNext等方法。

2.Reactor三大接口Publisher,Subscriber以及Subscription接口,以常用的Flux类作为例子,各个Flux类型的数据源(FluxArray,FluxMap等)都实现了Publisher接口,是数据来源,Subscriber是数据订阅者,Subscription是Publisher和Subscriber直接的数据桥梁,定义为如何从Publisher获取数据以及如何进行迭代。以FluxArray为例,FluxArray是Publisher,ArraySubscription是Subscription,LambdaSubscriber是常用的封装了Lambda表达式的Subscription。FluxArray通过在

subscribe(Subscriber<? super T> s)中回调Subscriber的onSubscribe(Subscription s)接口将Subscription传递给Subscriber。

 

3.Flux三种典型的数据产生模式,just方式直接产生固定的数据源,Flux.just().map()方法数据源的前后传递流动,以及Flux.generate方式数据源的动态产生。

 

另外分享一个超级好的关于这方面的博客,以上理解皆来自于此博客:https://blog.51cto.com/liukang/2090163

上一篇:常用设计模式


下一篇:Java小白翻身-Excel教程