作者回复: 因为publishOn里实际是执行了Flux.publishOn(Scheduler scheduler, int prefetch),prefetch是Queues.SMALL_BUFFER_SIZE,这里的SMALL_BUFFER_SIZE是256
作者回复: 用了reactor就是希望用少量、有限个数的线程来满足高负载的需要,关于Web,后面我们会讲到Webflux。如果你无限制地创建线程,不管用哪个框架都会有问题的。
作者回复: 这个地方并不是指我range(1,6)里的值,而是我请求多少个值,可以看LambdaSubscriber.onSubscribe()方法里,就是写死了s.request(Long.MAX_VALUE)
作者回复: 没用过Kotlin,这个问题只能留给熟悉Kotlin的同学帮你解答了……
作者回复: 以后用Spring的时候基本都会是连着Spring Boot一起的,这大大提升了开发的效率,算是一种趋势吧。所以我们从一开始就直接用Spring Boot。如果你去看最新的Spring in Action第五版,你会发现也是一样的。
作者回复: 简单来说,每次Flux和Mono上.xxx操作,其实都会返回一个Flux和Mono,一层包一层,所有的操作都是在subscribe后才开始执行的,执行的是否一层层反过来执行,这时顺序的差异就体现出来了。
作者回复: 还真是0..1和0..N的区别,我还特地去搜了下,发现有人也在问类似的问题,比如:https://stackoverflow.com/questions/47988433/mono-vs-flux-in-reactive-stream
作者回复: 看了你的代码,你在代码有异常时会返回-1,10/(3-3)时就会报错,然后就是-1了,结束了,不会输出 Publisher COMPLETE 1
作者回复: 就跟正常的调整日志配置是一样的,如果你是用的Log4J2.x或者LogBack,就提供对应配置文件,然后在里面设置日志格式,如果要输出到控制台,就在里面配置日志输出到ConsoleAppender就好了。
作者回复: 生产和消费是可以在不同的线程里的,所以也不是在一个线程里自产自销。另外,其实它的每个操作都是一个lambda,就看个人感觉了,不管是什么,写的长了都是地狱