filter filter，过滤。能把原来流里的元素按照一定的规则过滤出来，然后组成一个新流。 Flux.just (1,2,3,4) .log () .filter (i -> i % 2 == 0) .subscribe (); 执行结果： flatMap …
响应式编程总结： 底层：基于数据缓冲队列 + 消息驱动模型 + 异步回调机制（事件驱动） 编码：流式编程 + 链式调用 + 声明式 API 效果：优雅全异步 + 消息实时处理 + 高吞吐量 + 占用少量资源 响应式编程准备 在 reactor 文档中看一下如何使用 R…