BV1sC4y1K7ET
笔记地址-语雀
代码地址
.
Reactive Streams
响应式宣言
Reactor-快速开始
第一部分:响应式
1 | 命令式编程 => 响应式编程 stream流编排 |
1 | 全阻塞模式 |
一切皆为流处理
发布、消费、处理、订阅关系
1 | 响应式编程(线程池+缓冲区): |
jdk9 发布订阅 - 代码
1 | package java.util.concurrent; |
1 | 高并发:缓存、异步、队排好 |
第二部分:Reactor
1 | 哲学: |
1 | * 响应式编程核心:看懂文档弹珠图; |
1 | 并发流 parallel |
第三部分:WebFlux
组件对比
1 | Mono: 返回0|1 数据流 |
1 | Repository:Publisher |
main方法,创建服务器
1 | public static void main(String[] args) throws IOException { |
WebFlux Controller:Mono、Flux、sse
1 | //现在推荐的方式 |
1 | Mybatis ResultMap |