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