精选留言(22)

• 
  咯噔咯噔咯噔蹬

  2019-03-19

  老师，讲课的时候语气能不能有些起伏，感觉您全程都是一个口气，让我抓不住重点而且容易困

   1

   23
• 
  克里斯

  2019-09-20

  讲希望老师了解一下知识诅咒。你有10年工作经验，你根本不了解别人希望从你这里了解什么。对于懂的人来说，你讲的就是api，没有太大意义。对于不懂的人来说，需要先懂概念，需求
  ，实战也是建立在实际需求背景上的。其他老师将技术理解的用于现实需求，而不是基于一个新的专业术语来解释一个概念。其实重点是从老师这里学到一些思路和思考，深入api中，而不知道这个架构的思路，也不是你希望看到的吧。

  

   12
• 
  你说的灰

  2019-06-09

  这一章简直不好怎么评价，没有基于任何场景，就来一堆代码。对于完全不熟悉响应式的太不友好了、而且都是示例，然后注释下，来，，，我们看下效果。。。

  

   9
• 
  霧

  2019-04-05

  老师，这章感觉实在太难了，几乎一点儿没明白，您看，能不能从基础再详细说说这“响应式”？

  

   7
• 
  WL

  2019-03-08

  请问一下老师, 为什么加了.publishOn(Schedulers.elastic()) 时n 是 256, 不加的时候 n 就是long的最大值, 这个原理和机制是什么, 这里不是很明白.

  作者回复: 因为publishOn里实际是执行了Flux.publishOn(Scheduler scheduler, int prefetch)，prefetch是Queues.SMALL_BUFFER_SIZE，这里的SMALL_BUFFER_SIZE是256

   1

   6
• 
  羊大王

  2019-08-14

  觉得消化不了的可以看一下IBM的文章，讲的比较全，感觉看完再继续往下学比较好
  
  https://www.ibm.com/developerworks/cn/java/j-cn-with-reactor-response-encode/index.html

   1

   5
• 
  湮汐

  2019-03-15

  哎！这一章开始有点看不懂了，不太了解响应式编程

  

   5
• 
  晴天

  2019-03-08

  web服务如果大量方法里都使用reactor，并另外创建n个线程，会不会影响到服务器性能呢？比如把内存占满了

  作者回复: 用了reactor就是希望用少量、有限个数的线程来满足高负载的需要，关于Web，后面我们会讲到Webflux。如果你无限制地创建线程，不管用哪个框架都会有问题的。

  

   5
• 
  碧雪天虹

  2019-04-23

  这种写法主要是为了消除回调地狱, 使用声明式语法来编写, 但也有不足的地方就是声明的顺序和实际执行的顺序不一致, 容易给人造成混乱.

  

   2
• 
  🤒

  2019-04-22

  老师您好，我在执行.subscribeOn(Schedulers.single()) 时，在kotlin中出现了 kotlin 不能 执行，kotlin使用.subscribeOn(Schedulers.newSingle("")) 可执行 ，这是为什么呢

  作者回复: 没用过Kotlin，这个问题只能留给熟悉Kotlin的同学帮你解答了……

  

   2
• 
  韩

  2019-03-19

  当初深切体会过自己Android里写的CallBack Hell，才找到了好用的RxJava😂
  纯后端童鞋可能体会不到那种痛😏

  

   2
• 
  进击的大神

  2019-03-06

  我有一个疑问spring全家桶为什么不从spring 开始讲 而是从spring boot开始呢，不是应该从基础开始讲吗？

  作者回复: 以后用Spring的时候基本都会是连着Spring Boot一起的，这大大提升了开发的效率，算是一种趋势吧。所以我们从一开始就直接用Spring Boot。如果你去看最新的Spring in Action第五版，你会发现也是一样的。

  

   2
• 
  ck

  2019-05-12

  清问下, 为什么这里会产生long 的最大值?
          Flux.range(1, 6)
                  .doOnRequest(n -> log.info("Request {} number", n))

  作者回复: 这个地方并不是指我range(1,6)里的值，而是我请求多少个值，可以看LambdaSubscriber.onSubscribe()方法里，就是写死了s.request(Long.MAX_VALUE)

  

   1
• 
  懒懒想睡觉

  2019-09-05

  有两点没理解：
  1. 推送和订阅写在一起，是要自产自销吗？
  2. 看到onComplete感觉这回调地狱还在嘛。

  作者回复: 生产和消费是可以在不同的线程里的，所以也不是在一个线程里自产自销。另外，其实它的每个操作都是一个lambda，就看个人感觉了，不管是什么，写的长了都是地狱

  

  
• 
  null

  2019-06-20

  老师，您好！
  Flux 和 Mono 有啥区别，就只是 [0~n] 和 [0或1] 的区别么？如果是这样，Flux 就能满足 Mono 的使用场景，为什么还要设计出 Mono 呢？
  谢谢老师！！

  作者回复: 还真是0..1和0..N的区别，我还特地去搜了下，发现有人也在问类似的问题，比如：https://stackoverflow.com/questions/47988433/mono-vs-flux-in-reactive-stream

  

  
• 
  那又如何。

  2019-06-09

  我也不明白doonrequest那里为什么会是long最大值，也看不明白老师说的不是range(1，6)的值，是请求多少个值的解释，我是不是没救了

  作者回复: 我在第31和32讲的留言中有答复过类似问题了，你可以看下其他留言后的答复哈

  

  
• 
  Longerian

  2019-05-28

  直接使用RxJava做是不是也可以？或者说使用reactor库在spring里有什么优势

  作者回复: Project Reactor是Pivotal开发的，Spring也是Pivotal开发的，So，你觉得呢:-)

  

  
• 
  心猿

  2019-04-30

  老师您好， 我有个问题可能是我没理解到位。
  subscribeOn(Schedulers.single())的时候为什么subscribe的操作还是在publishOn(Schedulers.elastic())的线程里面，你不是说subscribe应该是单独的一个线程执行吗？日志打印出来他们的线程是一样的。

   1

  
• 
  兔2🐰🍃

  2019-04-19

  Publish Thread[elastic-2,5,main],1
  Subscribe Thread[elastic-2,5,main] : -5
  Publish Thread[elastic-2,5,main],2
  Subscribe Thread[elastic-2,5,main] : -10
  Publish Thread[elastic-2,5,main],3
  Exception java.lang.ArithmeticException: / by zero
  异常演示时，异常出现之前的2次Subscribe的值 ， 为什么是 -5， -10

  展开

  作者回复: 1；10/(1-3)=-5
  2；10/(2-3)=-10

  

  
• 
  兔2🐰🍃

  2019-04-19

  .publishOn(Schedulers.elastic())
  这里发布在线程elastic上，为什么Publisher Complete 1是在single-1线程上的？
  还有.subscribeOn(Schedulers.single())订阅在线程single上的，后面的Subscribe1~6都是在elastic线程上？

  

  