当前使用的镜像是bijukunjummen/rabbitmq-server:3.7.0，docker-compose文件配置的账号密码为myuser/mypass

序 本文主要展示一下如何使用reactor-kafka maven {代码...} 准备 启动zookeeper {代码...} 启动kafka {代码...} 创建topic {代码...} 实例 producer {代码...} consumer {代码...} 小结 reactor-kafka对kafka的api进行封装，改造为reactive streams模式，这样用起来更为顺手，熟悉reactor的开发人员可以轻车熟路。 doc ...

reactor-core-3.1.5.RELEASE-sources.jar!/reactor/core/publisher/Flux.java

序 本文主要研究下Flux的compose与flatMap操作 compose {代码...} 输出如下： {代码...} 可以看到compose executed只打印一次 flatMap {代码...} 输出如下： {代码...} 可以看到flatMap executed在每次onNext的时候都打印一次 小结 compose操作是将整个flux作为一个整体输入一次性转换，而flatMap是针对flux的每个item作...

reactor-netty-0.7.6.RELEASE-sources.jar!/reactor/ipc/netty/NettyConnector.java

主要是创建NioEventLoopGroup，以及该group下面的workerCount个NioEventLoop(这里涉及两个参数，一个是worker thread count，一个是selector thread count)

在传统的请求/应答同步模式中，使用threadlocal来传递上下文变量是非常方便的，可以省得在每个方法参数添加公用的变量，比如当前登录用户。但是业务方法可能使用了async或者在其他线程池中异步执行，这个时候threadlocal的作用就失效了。

reactor-netty-0.7.3.RELEASE-sources.jar!/reactor/ipc/netty/tcp/TcpClient.java

reactor-netty-0.7.3.RELEASE-sources.jar!/reactor/ipc/netty/tcp/TcpClient.java

reactor-netty-0.7.3.RELEASE-sources.jar!/reactor/ipc/netty/tcp/TcpClient.java

reactor-netty-0.7.3.RELEASE-sources.jar!/reactor/ipc/netty/http/client/HttpClient.java

reactor-core-3.1.3.RELEASE-sources.jar!/reactor/core/publisher/FluxSink.java

spring-webflux-5.0.2.RELEASE-sources.jar!/org/springframework/web/reactive/function/client/DefaultWebClientBuilder.java

reactor-core-3.1.3.RELEASE-sources.jar!/reactor/core/publisher/FluxSink.java

reactor-core-3.1.3.RELEASE-sources.jar!/reactor/core/publisher/FluxInterval.java

这里使用ReactiveHttpOutputMessage的writeWith(Publisher<? extends DataBuffer> body)方法，实现边准备数据边导出等待十几秒就弹下载框，之后就server端一边输出，浏览器一边下载，100秒左右下载完毕

利用reactor extra项目中的Retry帮助类，可以轻松指定高级重试策略，比如fixedBackoff，亦或是exponentialBackoff等

序 本文主要研究一下flux的map与flatMap的区别 map {代码...} 这里头的map是纯元素转换 输出 {代码...} flatMap {代码...} 这里的flatMap，将元素转为Mono或Flux，转换操作里头还可以进行异步操作 输出 {代码...} 小结 flatMap的转换Function要求返回一个Publisher，这个Publisher代表一个作用于元素的异步的转换操作；...

env的默认配置从reactor-core-2.0.8.RELEASE.jar!/META-INF/reactor/reactor-environment.properties中读取