search

FS1360472174 / nosql-mongo

mongo knowledge
4 stars 4 forks source link

响应式编程 #48

Open FS1360472174 opened 6 years ago

FS1360472174 commented 6 years ago

reactive-spring-mongo

https://dzone.com/articles/reactive-streams-with-spring-data-and-mongodb

FS1360472174 commented 6 years ago

Flux:0-N个元素的异步序列 包含三种类型的消息通知: 正常的，序列结束，序列出错

订阅者订阅onNext(),onComplete(),onError()

Mono:包含0或者1个元素的异步序列

Mono -> Flux: 两个Mono序列合并到一起，得到一个Flux对象 Flux-> Mono: 对Flux序列计数，得到一个Mono对象

FS1360472174 commented 6 years ago

响应式编程就是将之前的拉模式改成推模式。

但是考虑到producer 的消息很多的时候，消费不过来，又提供了 request的方法，这样可以推拉结合

FS1360472174 commented 6 years ago

https://www.ibm.com/developerworks/cn/java/j-cn-with-reactor-response-encode/index.html