webflux入门（webflux web）

科技前沿 • 2025-05-15 07:35 • 阅读 39
大家好，我是讯享网，很高兴认识大家。
import org.springframework.http.MediaType;
import org.springframework.http.server.reactive.HttpHandler;
import org.springframework.http.server.reactive.ReactorHttpHandlerAdapter;
import org.springframework.web.reactive.function.BodyInserters;
import org.springframework.web.reactive.function.server.*;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import reactor.netty.http.server.HttpServer;


public class UserHandler {

 private final UserService userService;

 public UserHandler(UserService userService) {
 this.userService = userService;
 }

 // 根据id查询
 public Mono&lt;ServerResponse&gt; getById(ServerRequest request){
 // 获取id值
 String id = request.pathVariable(“id”);
 // 空值处理
 Mono&lt;ServerResponse&gt; notFound = ServerResponse.notFound().build();

 // 调用Service方法得到数据
 Mono&lt;User&gt; userMono = userService.getById(Integer.parseInt(id));
 // 把userMono进行转换返回
 return userMono.flatMap(user -&gt;
 ServerResponse
 .ok()
 .contentType(MediaType.APPLICATION_JSON)
 .body(BodyInserters.fromValue(userMono))
 .switchIfEmpty(notFound)
 );
 }

 // 查询多个
 public Mono&lt;ServerResponse&gt; getAll(ServerRequest request){
 // 调用Service得到结果
 Flux&lt;User&gt; users = userService.getAll();
 return ServerResponse.ok().contentType(MediaType.APPLICATION_JSON).body(users, User.class);

 }

 // 保存
 public Mono&lt;ServerResponse&gt; save(ServerRequest request){
 // 获取User对象
 Mono&lt;User&gt; userMono = request.bodyToMono(User.class);
 return ServerResponse.ok().build(userService.save(userMono));
 }


 public static void main(String[] args) {
 // 创建对象
 UserService userService = new UserService();
 UserHandler userHandler = new UserHandler(userService);
 // 创建路由
 RouterFunction&lt;ServerResponse&gt; route = RouterFunctions
 .route(RequestPredicates.GET(“/user/{id}”).and(RequestPredicates.accept(MediaType.APPLICATION_JSON)), userHandler::getById)
 .andRoute(RequestPredicates.GET(“/users”).and(RequestPredicates.accept(MediaType.APPLICATION_JSON)), userHandler::getAll);
 // 路由和handler适配
 HttpHandler httpHandler = RouterFunctions.toHttpHandler(route);
 ReactorHttpHandlerAdapter adapter = new ReactorHttpHandlerAdapter(httpHandler);
 // 创建服务器
 HttpServer httpServer = HttpServer.create();
 httpServer.handle(adapter).bindNow();
 }
}
讯享网
webflux入门（webflux web）

相关推荐
