Spring reactor实践

1.首先引入pom文件

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

2.代码结构

3.User是普通的pojo类

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

5.事件处理器 eventHandler

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

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