初识Spring Webflux，新的web系统框架，不熟悉的抓紧学习

初识Spring Webflux，新的web系统框架，不熟悉的抓紧学习

我们知道传统的Web框架，比如说：struts2，springmvc等都是基于Servlet API与Servlet容器基础之上运行的，在Servlet3.1之后才有了异步非阻塞的支持。而WebFlux是一个典型非阻塞异步的框架，它的核心是基于Reactor的相关API实现的。相对于传统的web框架来说，它可以运行在诸如Netty，Undertow及支持Servlet3.1的容器上，因此它的运行环境的可选择行要比传统web框架多的多。

Webflux

首先看下与传统web框架的对的比：

对比角度	MVC	Webflux
阻塞模式	阻塞synchronous blocking i/o	nio（non-blocking）
容器	netty，servlet	servlet
数据库	关系型+非关系型	非关系型数据库
优势		非阻塞，性能提升

架构扩展思路：

基于Webflux，我们可以将原有业务先垂直扩展，改为Webflux，然后在水平扩展业务。

同步servlet

就是传统意义的servlet，参考如下demo：

// ServletConfig
@Configuration
public class ServletConfig {
    @Bean
    public ServletRegistrationBean servletRegistrationBean(){
        return new ServletRegistrationBean(new ServletTest(),"/servletkk");
    }
}
//ServletTest 定义一个同步servlet
public class ServletTest extends HttpServlet {
    @Override
    protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
        long t1 = System.currentTimeMillis();

        dosomething(resp);
        System.out.println("sycn_use:"+(System.currentTimeMillis()-t1));
    }

    private void dosomething(HttpServletResponse resp) throws IOException {
        try {
            TimeUnit.SECONDS.sleep(5);} catch (InterruptedException e) {e.printStackTrace();}//阻塞5秒
        resp.getWriter().append("哈哈");
    }

    @Override
    protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
        super.doPost(req, resp);
    }
}

测试后发现，后台输出延迟了5秒钟

sycn_use:5001

这就是传统的同步阻塞的示例。

异步servlet

public class AsyncServlet extends HttpServlet {
    @Override
    protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
        long t1 = System.currentTimeMillis();
        //开启异步
        AsyncContext asyncContext = req.startAsync();
        //执行业务代码
        CompletableFuture.runAsync(()-> {
            try {
                dosomething(asyncContext,(HttpServletResponse) asyncContext.getResponse());
            } catch (IOException e) {
                e.printStackTrace();
            }
        });
        System.out.println("sycn_use:"+(System.currentTimeMillis()-t1));
    }

    private void dosomething(AsyncContext asyncContext, HttpServletResponse resp) throws IOException {
        try {
            TimeUnit.SECONDS.sleep(5);} catch (InterruptedException e) {e.printStackTrace();}
        System.out.println("sync_use");
        resp.getWriter().append("haha ");
        //通知上下文 执行结束
        asyncContext.complete();
    }

    @Override
    protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
        super.doPost(req, resp);
    }
}

测试后发现没有延迟。

webflux 编码

我们创建一个RestController来体验一下mono和普通的rest请求的区别

@RestController
@Slf4j
public class WebFluxController {
    @GetMapping("/common")
    public String common(){
        log.info("开始");
        String str = createStr();
        log.info("结束");
        return str;
    }

    private String createStr() {
        try {
            TimeUnit.SECONDS.sleep(5);} catch (InterruptedException e) {e.printStackTrace();}
        return "哈哈";
    }

    @GetMapping("/mono")
    public Mono<String> webfluxdemo() {
        log.info("开始");
        Mono<String> mono = Mono.fromSupplier(() -> createStr());
        log.info("结束");
        return mono;
    }
}