一文搞懂响应式编程( 四 ) _编程

stringFlux = Flux.fromStream(IntStream.range(1,6).mapToObj(i ->{mySleep(1);//表示睡1秒return "java north flux" + i + "date time: " +LocalDateTime.now();}));System.out.println("thread : " + Thread.currentThread().getName()+ " ===" + LocalDateTime.now() + "==========Flux function complete=========");return stringFlux;}此次使用谷歌浏览器请求此服务：
可以发现每隔一秒就会有一条消息被生产出来。

文章插图

后台完成时间同样是在一开始就完成整个方法：

文章插图

通过上述对Flux 与 Mono的例子，可以好好体会一下响应式编程。
总结本篇回顾了函数式编程，Stream操作等，然后再举例讲了Java中的Reactive编程示例，同时也给处理Reactor三方库的Flux于Mono的示例。
最后使用了SpringBoot WebFlux 创建简单的响应式web服务。希望能让大家更好的理解响应式编程。