Reactive 响应式编程03 Spring Reactor 01-CFANZ编程社区

Spring reactor实践

1.首先引入pom文件

<dependency>
                <groupId>org.projectreactor</groupId>
                <artifactId>reactor-spring</artifactId>
                <version>1.0.1.RELEASE</version>
            </dependency>

2.代码结构

Reactive 响应式编程03 Spring Reactor 01_初始化

3.User是普通的pojo类

Reactive 响应式编程03 Spring Reactor 01_spring_02

4.初始化reactor的配置，通过spring boot启动

Reactive 响应式编程03 Spring Reactor 01_spring_03

5.事件处理器 eventHandler

Reactive 响应式编程03 Spring Reactor 01_代码结构_04

5.配置下服务的依赖注入

Reactive 响应式编程03 Spring Reactor 01_spring_05

6.最后写个单测，发送reactor事件

Reactive 响应式编程03 Spring Reactor 01_代码结构_06