springboot webflux demo

package com.carlos.webflux.Handler; import com.carlos.webflux.Entity.User; import com.carlos.webflux.Service.UserService; import lombok.extern.slf4j.Slf4j; import org.slf4j.Logger; import org.slf4j.spi.LocationAwareLogger; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import org.springframework.web.reactive.function.server.ServerRequest; import org.springframework.web.reactive.function.server.ServerResponse; import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; /** *<p> * UserHandler 解释器 *</p> *@Author: Carlos *@Date:2018/7/26 - 下午2:59 */ @Component @Slf4j public class UserHandler { @Autowired UserService userService; public Mono<ServerResponse> getUserList(ServerRequest request) { //Lambda 匿名参数 Flux<User> userFlux = userService.findUserList(); return ServerResponse.ok().body(userFlux,User.class); } public Mono<ServerResponse> getUser(ServerRequest request) { String userId = request.pathVariable("userId"); Mono<User> userMono = userService.findUserById(userId); userMono.subscribe(user -> log.info(user.toString())); return ServerResponse.ok().body(userMono,User.class); } }