webflux入门（webflux快速入门）

Spring WebFlux是一个异步非阻塞式的WEB框架，它能够充分利用多核CPU的硬件资源去处理大量的并发请求，而Spring MVC是构建于Servlet API之上，使用的是同步阻塞式I/O模型，即每一个请求对应一个线程去处理。

异步非阻塞： WebFlux 基于反应式编程模型，支持非阻塞 I/O，能够充分利用多核 CPU 资源，并且在高并发场景下具有更好的性能表现，因为它不会为每个请求分配独立的线程，从而避免了线程上下文切换带来的开销。
响应式编程： WebFlux 使用 Project Reactor（或者 RxJava 作为备选）提供的 Mono 和 Flux 类型来表示可能零个、一个或多个事件的异步序列，使得开发者可以编写异步数据处理逻辑。
无需 Servlet API：尽管可以在 Servlet 容器上运行，但它不直接依赖 Servlet API，能在非阻塞服务器（如 Netty、Undertow 等）上运行。
函数式编程风格：除了提供类似于 Spring MVC 的注解式编程模型外，WebFlux 还支持函数式编程模型，允许通过 RouterFunction 等方式进行更灵活的路由配置。

同步阻塞： Spring MVC 基于传统的 Servlet API，每个 HTTP 请求通常都会绑定到一个单独的线程直到请求处理完成并发送响应为止。
线程模型：在默认情况下，Spring MVC 应用中，每个请求会创建或从线程池获取一个线程，处理完成后释放回线程池。这种模式在请求处理复杂度较高或线程池大小受限时，可能会影响系统的并发能力。
依赖 Servlet 容器： Spring MVC 必须部署在支持 Servlet API 的容器中运行（如：Tomcat、Jetty、Undertow、Weblogic等）。
API 和编程模型： Spring MVC 主要采用注解驱动的方式组织控制器和处理请求响应，例如通过 @Controller、@RequestMapping 等注解。

响应式和非阻塞并不是总能让应用跑的更快，况且将代码构建为非阻塞的执行方式本身还会带来少量的成本。但是在类似于WEB应用这样的高并发、少计算且I/O密集的应用中，响应式和非阻塞往往能够发挥出价值。对比SpringMVC使用的Servlet模型，增加Servlet容器处理请求的线程数量可以缓解这一问题，但是增加线程是有成本的，JVM中默认情况下在创建新线程时会分配大小为1M的线程栈，所以更多的线程意味着需要更多的内存；更多的线程会带来更多的线程上下文切换成本。

实验目的：使用webflux方式编写程序

<!-- WebFlux --><dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-webflux</artifactId></dependency>

第一种 springmvc注解方式

package com.et.webflux;
import lombok.extern.slf4j.Slf4j;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController;import reactor.core.publisher.Flux;import reactor.core.publisher.Mono;
import javax.annotation.Resource;

@Slf4j@RestController@RequestMapping("/demo")public class DemoController {
 @Resource private DemoService demoService;

 @GetMapping("/monoTest") public Mono<Object> monoTest() { // method one// String data = getOneResult("monoTest()");// return Mono.just(data);
 // method two return Mono.create(cityMonoSink -> { String data = demoService.getOneResult("monoTest()"); cityMonoSink.success(data); }); }

 @GetMapping("/fluxTest") public Flux<Object> fluxTest() { // method one// List<String> list = getMultiResult("fluxTest()");// return Flux.fromIterable(list);
 // method two return Flux.fromIterable(demoService.getMultiResult("fluxTest()")); }
}

第二种 Java 8 Lambda函数式编程。

@Bean public RouterFunction<ServerResponse> routes() { // 下面的操作相当于 @RequestMapping return RouterFunctions.route(POST("/addUser"), handler::addUser) .andRoute(GET("/userList"), handler::userList) .andRoute(GET("/findUserById/{id}"), handler::findUserById); }

package com.et.webflux;
import java.util.List;
public interface DemoService {

 String getOneResult(String methodName);

 List<String> getMultiResult(String methodName);
 User addUser(User user);
 List<User> findAllUser();
 User findUserById(Long id);
}

package com.et.webflux;

import org.springframework.stereotype.Service;
import java.util.ArrayList;import java.util.List;

@Servicepublic class DemoServiceImpl implements DemoService {
 @Override public String getOneResult(String methodName) {
 return String.format("%s invoker success", methodName); }
 @Override public List<String> getMultiResult(String methodName) { List<String> list = new ArrayList<>(3); for (int i = 0; i < 3; i++) { list.add(String.format("%s invoker success， %d ", methodName, i + 1)); } return list; }
 @Override public User addUser(User user) { user.setId(1L); return user; }
 @Override public List<User> findAllUser() {
 List<User> list = new ArrayList<>(); for (int i = 0; i < 3; i++) { int no = i + 1; list.add(new User((long) no, "USER_" + no, "PWD_" + no, 18 + no)); } return list; }
 @Override public User findUserById(Long id) {
 return new User(id, "USER_" + id, "PWD_" + id, 18); }}

以上只是一些关键代码，所有代码请参见下面代码仓库

https://github.com/Harries/springboot-demo

启动springboot工程
访问地址http://localhost:8088/demo/fluxTest
访问http://localhost:8088/demo/monoTest

http://www.liuhaihua.cn/archives/710420.html
https://howtodoinjava.com/spring-webflux/spring-webflux-tutorial/
https://blog.csdn.net/_/article/details/

到此这篇webflux入门（webflux快速入门）的文章就介绍到这了,更多相关内容请继续浏览下面的相关推荐文章，希望大家都能在编程的领域有一番成就！

上一篇： py文件打包成exe执行出错（py文件怎么打包成可执行文件）

下一篇：高血压危险分层图片（高血压危险分级标准表图片）

版权声明：
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如若内容造成侵权、违法违规、事实不符，请将相关资料发送至xkadmin@xkablog.com进行投诉反馈，一经查实，立即处理！

转载请注明出处，原文链接：https://www.xkablog.com/bcyy/37999.html

相关文章：