本文主要是介绍Reactor 3 (4): 监控与副作用 doOn 系列方法,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
在Publisher使用subscribe()方法的时候,Subscriber触发回触发一系列的on方法,如onSubscribe();为了更好的监控以及观测异步序列的传递情况,设置了一系列的doOn方法,在触发on方法的时候作behavior的副作用发生用于监控行为的运行情况
常见doOn方法
-
doOnEach(): 对每一个元素对应的single对象进行监控
-
doOnSubscribe(): 用以监控onSubscribe()方法的执行
-
doOnRequest:对request行为监控产生副作用
-
doOnNext:onNext副作用
-
doOnError:出现error时的副作用,用于监控报错,可以通过错误类型进行筛选
-
doOnComplete:完成时触犯
-
doOnCancel:取消时触发
-
doOnTerminate:终止时触发,无论是成功还是出现异常
一下为部分代码实现:
@Testpublic void doOnWithMono () {Mono.just("ffzs").map(String::toUpperCase).doOnSubscribe(subscription -> log.info("test do on subscribe")).doOnRequest(longNumber -> log.
这篇关于Reactor 3 (4): 监控与副作用 doOn 系列方法的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!