分层开发与响应式编程

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

分层开发


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月前
|
消息中间件 运维 数据库
架构设计之解析CQRS架构模式!
架构设计之解析CQRS架构模式!
架构设计之解析CQRS架构模式!
|
5月前
|
开发框架 开发者 数据库管理
模块化开发和传统开发的优缺点有哪些
【8月更文挑战第26天】模块化开发和传统开发的优缺点有哪些
167 2
|
5月前
|
C# 微服务 Windows
模块化革命:揭秘WPF与微服务架构的完美融合——从单一职责原则到事件聚合器模式,构建高度解耦与可扩展的应用程序
【8月更文挑战第31天】本文探讨了如何在Windows Presentation Foundation(WPF)应用中借鉴微服务架构思想,实现模块化设计。通过将WPF应用分解为独立的功能模块,并利用事件聚合器实现模块间解耦通信,可以有效提升开发效率和系统可维护性。文中还提供了具体示例代码,展示了如何使用事件聚合器进行模块间通信,以及如何利用依赖注入进一步提高模块解耦程度。此方法不仅有助于简化复杂度,还能使应用更加灵活易扩展。
117 0
|
8月前
|
存储 监控 微服务
微服务和单体架构是两种不同的软件架构风格,每种都有其自身的优缺点
【1月更文挑战第1天】微服务和单体架构是两种不同的软件架构风格,每种都有其自身的优缺点
120 0
|
8月前
深入.net平台的分层开发
深入.net平台的分层开发
|
消息中间件 存储 程序员
CQRS架构简介
CQRS架构简介
1307 1
CQRS架构简介
|
容器
【系统架构】组件与(模块化和应用集成)的区别
【系统架构】组件与(模块化和应用集成)的区别
346 0
【系统架构】模块化开发方法
【系统架构】模块化开发方法
191 0
|
芯片
驱动设计思想_面向对象_分层_分离
驱动设计思想_面向对象_分层_分离
167 0
|
存储 设计模式 缓存
响应式编程的复杂度和简化
响应式系统不是今天的主题,我们要讨论更具体的话题,即响应式代码的编写会有哪些复杂度,应该如何简化。
190 0
响应式编程的复杂度和简化

热门文章

最新文章