SpringBootWebFlux整合MongoDB实现CRUD及分页功能
环境:Springboot2.5.8
请先阅读:
Reactor响应式编程(Flux、Mono)基本用法
Spring WebFlux入门实例并整合数据库实现基本的增删改查MongoDB介绍
MongoDB 是由C++语言编写的,是一个基于分布式文件存储的开源数据库系统。
在高负载的情况下,添加更多的节点,可以保证服务器性能。
MongoDB 旨在为WEB应用提供可扩展的高性能数据存储解决方案。
MongoDB 将数据存储为一个文档,数据结构由键值(key=>value)对组成。MongoDB 文档类似于 JSON 对象。字段值可以包含其他文档,数组及文档数组。
特点:MongoDB 是一个面向文档存储的数据库,操作起来比较简单和容易。 你可以在MongoDB记录中设置任何属性的索引 (如:FirstName="Sameer",Address="8 Gandhi Road")来实现更快的排序。 你可以通过本地或者网络创建数据镜像,这使得MongoDB有更强的扩展性。 如果负载的增加(需要更多的存储空间和更强的处理能力) ,它可以分布在计算机网络中的其他节点上这就是所谓的分片。 Mongo支持丰富的查询表达式。查询指令使用JSON形式的标记,可轻易查询文档中内嵌的对象及数组。 MongoDb 使用update命令可以实现替换完成的文档(数据)或者一些指定的数据字段 。 Mongodb中的Map/reduce主要是用来对数据进行批量处理和聚合操作。 Map和Reduce。Map函数调用emit(key,value)遍历集合中所有的记录,将key与value传给Reduce函数进行处理。 Map函数和Reduce函数是使用Javascript编写的,并可以通过db.runCommand或mapreduce命令来执行MapReduce操作。 GridFS是MongoDB中的一个内置功能,可以用于存放大量小文件。 MongoDB允许在服务端执行脚本,可以用Javascript编写某个函数,直接在服务端执行,也可以把函数的定义存储在服务端,下次直接调用即可。 WebFlux介绍
Spring框架中包含的原始web框架Spring Web MVC是专门为ServletAPI和Servlet容器构建的。反应式堆栈web框架Spring Web Flux后来在5.0版中添加。它是完全非阻塞的,支持反应流背压(由消费者控制生产者的速度),并在Netty、Undertow和Servlet 3.1+容器等服务器上运行。
这两个web框架都反映了它们的源模块(Spring Web MVC和Spring Web Flux)的名称,并在Spring框架中共存。每个模块都是可选的。应用程序可以使用一个或另一个模块,在某些情况下,可以同时使用这两个模块 — 例如,带有反应式WebClient的Spring MVC控制器。依赖及配置 org.springframework.boot spring-boot-starter-data-mongodb-reactive org.springframework.boot spring-boot-starter-webflux
配置文件spring: data: mongodb: uri: mongodb://localhost:27017/demo --- logging: level: "[org.springframework.data.mongodb.core]": debug 实体类 & Repository@Document(collection = "c_users") public class Users { // 主键,对应到mongodb的_id字段 @Id private Long id ; private String username ; private String password ; private Integer age ; private String email ; }public interface UsersRepository extends ReactiveSortingRepository { }服务类@Service public class UsersService { @Resource private ReactiveMongoTemplate template ; @Resource private UsersRepository ur ; // 保存数据 public Mono save(Users user) { return ur.save(user) ; } // 更新信息 public Mono updateInfo(Users user) { return template.updateFirst(query(where("id").is(user.getId())), update("email", user.getEmail()).set("username", user.getUsername()), Users.class) ; } // 删除数据 public Mono remove(Long id) { return ur.deleteAll(ur.findById(id)) ; } // 模糊查询 public Flux queryUsersLike(String keyword) { Pattern pattern = Pattern.compile("^.*" + keyword + ".*#34;) ; return template.find(query(where("username").regex(pattern)), Users.class) ; } // 查询所有数据 public Flux queryUsers() { return ur.findAll() ; } // 分页查询数据 public Flux queryPager(Integer page, Integer size) { Pageable pageable = PageRequest.of(page, size) ; Query query = new Query() ; return template.find(query.with(pageable), Users.class) ; } }Controller接口@Resource private UsersService us ; @PostMapping("save") public Mono save(@RequestBody Users users) { return us.save(users) ; } @PostMapping("update") public Mono update(@RequestBody Users user) { return us.updateInfo(user) ; } @GetMapping("/remove/{id}") public Mono remove(@PathVariable("id")Long id) { return us.remove(id) ; } @GetMapping("query") public Flux query() { return us.queryUsers() ; } @GetMapping("/queryLike") public Flux queryLike(String keyword) { return us.queryUsersLike(keyword) ; } @GetMapping("/queryPager") public Flux queryPager(Integer page, Integer size) { return us.queryPager(page, size) ; }Repository支持的查询语法
查询类
完毕!!!
求个关注
Spring Cloud 中断路器 Circuit Breaker的应用
Spring Cloud Gateway应用详解1之谓词
SpringCloud Feign实现原理源分析
SpringCloud Nacos 服务动态配置
SpringCloud Hystrix实现资源隔离应用
SpringCloud zuul 动态网关配置
Spring Cloud全链路追踪SkyWalking及整合Elasticsearch