分层开发与响应式编程

简介: 分层开发与响应式编程

分层开发


1.MVC


应用程序的分层开发模式—MVC模式


MVC是Model(模型)、View(视图)、Controller(控制器)的简写


  • Model:是Java的实体Bean,代表存取数据的对象或者POJO,作用是在内存中暂时存储数据,并在数据发生变化的时候更新控制器(如果需要持久化,就把它写入数据库或者磁盘文件)
  • View:主要用来解析、处理、显示内容
  • Controller:主要用来处理视图中的响应,它决定了如何调用Model中的实体Bean,如何调用业务层的数据业务操作以及如何将结果返回视图


2. 三层架构


三层架构,就是将整个应用程序划分为表现层(UI)、业务逻辑层(Service)、数据访问层(DAO\Repository)


  • 表现层:用于展示界面,对用户的请求进行接受、处理,并且进行数据的返回
  • 业务逻辑层:负责业务逻辑处理,主要是调用DAO层对数据进行增删改查等操作
  • 数据访问层:与数据库交互的持久层,被Service调用


DAO层的工作是存取对象,而Repository层的工作是存取和管理对象


所以Repository=管理对象+DAO


3. 实现MVC模式


创建一个SpringBoot项目,添加web、thymeleaf、lombok依赖

实体类


package com.example.demo3.Bean;
import lombok.Data;
@Data
public class User {
    // 用户id
    private long id;
    // 用户姓名
    private String name;
    //用户年龄
    private int age;
}
复制代码


Controller


package com.example.demo3.Controller;
import com.example.demo3.Bean.User;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.ModelAndView;
@RestController
public class MVCDemoController {
    @RequestMapping("/mvcdemo")
    public ModelAndView hello(){
        User user=new User();
        user.setName("test11");
        user.setAge(100);
        ModelAndView modelAndView=new ModelAndView("mvcdemo");
        modelAndView.addObject("user",user);
        return modelAndView;
    }
}
复制代码

页面

<!DOCTYPE html>
<!--thymeleaf模板支持-->
<html lang="en" xmlns:th="http://www.thymeleaf.org">
<head>
    <meta charset="utf-8">
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
</head>
<body>
<div>
    <!-- 显示由控制器传递过来的实体user的值-->
    <div th:text="|姓名:${user.name}|"></div>
    <div th:text="|年龄:${user.age}|">年龄</div>
</div>
</body>
</html>
复制代码


启动服务


image.png


响应式编程


WebFlux是响应式框架,这就意味着它可以在资源有限的情况下提高系统的吞吐量和伸缩性。


Spring MVC采用命令式编程的方式,代码是一句一句执行的;WebFlux则是基于异步响应式编程。


工作方式对比:


  1. MVC
    主线程接收请求—->准备数据—–>返回数据
  2. WebFlux
    主线程接收请求—->立刻返回数据与函数的组合—->开启一个新的work去实现任务(业务操作)—->work线程完成工作—–>返回用户真实数据

打一个很简单的例子,在MVC模式下就好比于餐厅没有了叫号机和前台服务员,当里面位置满了之后再来的顾客就只能换一家吃;而在WebFlux下,就是拥有了前台和叫号机,这样后面来的客户有了排队号,只用等待有空位置出来。虽然来再多的人都能立马排号,但是就餐这个业务依然还是堵塞的。所以对比之下,请求量就比传统的MVC高出很多,对于一些I/O密集的服务,就可以选择使用WebFlux实现。


Mono和Flux


MonoFlux是Reactor中的两个基本概念


  • Mono和Flux属于事件发布者,为消费者提供订阅接口。当有事件发生时,Mono或Flux会回调消费者的相应方法,然后通知消费者相应的事件
  • Mono和Flux用于处理异步数据流,不是直接返回String或者List,而是将异步数据流封装为Mono或者Flux对象


二者的区别


  1. Flux可以发送很多item,并且这些item可以经过若干operators后才被订阅,而Mono只能发送一个item
  2. Mono主要用于返回单个数据,而Flux用于返回多个数据
  3. Mono表示包含0或1个元素的异步序列,Flux包含0到N个异步序列。序列中可以包含三种消息通知:正常的包含元素的消息、序列结束的消息、序列出错的消息,分别对应OnNext()、OnComplete()、OnError()三种方法
  4. 二者之间可以进行相互转换,对Flux序列进行计数操作时得到一个Mono<Long>对象;多个Mono序列合并在一起,得到一个Flux对象。


WebFlux例子

创建时添加响应式依赖


image.png


这部分主要是使用函数式编程

Handler


package com.example.webfluxdemo;
import org.springframework.http.MediaType;
import org.springframework.stereotype.Component;
import org.springframework.web.reactive.function.BodyInserters;
import org.springframework.web.reactive.function.server.ServerRequest;
import org.springframework.web.reactive.function.server.ServerResponse;
import reactor.core.publisher.Mono;
@Component
public class Handler {
    public Mono<ServerResponse> Hi(ServerRequest request) {
        return ServerResponse.ok().contentType(MediaType.TEXT_PLAIN).body(Mono.just("This is WebFlux demo"), String.class);
    }
}
复制代码

Router


package com.example.webfluxdemo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.MediaType;
import org.springframework.web.reactive.function.server.RequestPredicates;
import org.springframework.web.reactive.function.server.RouterFunction;
import org.springframework.web.reactive.function.server.RouterFunctions;
import org.springframework.web.reactive.function.server.ServerResponse;
import static org.springframework.web.reactive.function.server.RequestPredicates.GET;
import static org.springframework.web.reactive.function.server.RouterFunctions.route;
@Configuration
public class Router {
    @Autowired
    private Handler handler;
    @Bean
    public RouterFunction<ServerResponse> routeHi(Handler hiHandler) {
        return RouterFunctions.route(RequestPredicates.GET("/hello"), handler::Hi);
    }
}
复制代码


启动服务,在/hello将看到

image.png

目录
相关文章
|
3天前
|
JavaScript Java 持续交付
构建高效微服务架构:后端开发的新范式
【5月更文挑战第3天】 在现代软件开发的浪潮中,微服务架构以其灵活性、可扩展性和技术多样性而受到重视。本文深入探讨了如何构建一个高效的微服务系统,包括关键的设计原则、技术选型、以及实现细节。我们将通过分析微服务的核心概念,提供一套实用的步骤和最佳实践,以指导开发者构建出既健壮又易于维护的分布式系统。文章将重点讨论如何在保证系统性能和稳定性的前提下,实现服务的解耦与独立部署,从而推动后端开发工作流的优化和创新。
|
8月前
|
存储 中间件 Java
一种基于事件驱动思想的 SAP 系统集成二次开发方法介绍
一种基于事件驱动思想的 SAP 系统集成二次开发方法介绍
87 0
|
12月前
|
消息中间件 存储 程序员
CQRS架构简介
CQRS架构简介
1015 0
CQRS架构简介
|
消息中间件 运维 JavaScript
架构设计30-架构模式03-事件驱动架构模式
架构设计30-架构模式03-事件驱动架构模式
174 0
架构设计30-架构模式03-事件驱动架构模式
|
存储 设计模式 缓存
响应式编程的复杂度和简化
响应式系统不是今天的主题,我们要讨论更具体的话题,即响应式代码的编写会有哪些复杂度,应该如何简化。
135 0
响应式编程的复杂度和简化
|
JSON 数据处理 数据格式
MockServer 服务框架设计
MockServer 服务框架设计
|
缓存 运维 架构师
架构之道:分离业务逻辑和技术细节
架构之道:分离业务逻辑和技术细节
440 1
架构之道:分离业务逻辑和技术细节
|
10月前
|
XML 前端开发 Java
Android极简MVVM,从一个基类库谈起
这篇文章,主要详细介绍如何封装一个MVVM的基类库,以及MVVM架构模式在实际业务中的用法,最后会把实际的封装代码开源,并提供远程依赖。
115 0
|
开发框架 前端开发 JavaScript
我对组件化概念的理解
我对组件化概念的理解
我对组件化概念的理解
|
开发者 索引
Aggregations|学习笔记
快速学习 Aggregations。
252 0
Aggregations|学习笔记