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控制器。

依赖及配置

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-data-mongodb-reactive</artifactId>
</dependency>
<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-webflux</artifactId>
</dependency>

配置文件

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<Users, Long> {
}

服务类

@Service
public class UsersService {

  @Resource
  private ReactiveMongoTemplate template ;
  @Resource
  private UsersRepository ur ;
  // 保存数据
  public Mono<Users> save(Users user) {
    return ur.save(user) ;
  }
  // 更新信息
  public Mono<UpdateResult> updateInfo(Users user) {
    return template.updateFirst(query(where("id").is(user.getId())), update("email", user.getEmail()).set("username", user.getUsername()), Users.class) ;
  }
  // 删除数据
  public Mono<Void> remove(Long id) {
    return ur.deleteAll(ur.findById(id)) ;
  }
  // 模糊查询
  public Flux<Users> queryUsersLike(String keyword) {
    Pattern pattern = Pattern.compile("^.*" + keyword + ".*#34;) ;
    return template.find(query(where("username").regex(pattern)), Users.class) ;
  }
  // 查询所有数据
  public Flux<Users> queryUsers() {
    return ur.findAll() ;
  }
  // 分页查询数据
  public Flux<Users> 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<Users> save(@RequestBody Users users) {
  return us.save(users) ;
}
@PostMapping("update")
public Mono<UpdateResult> update(@RequestBody Users user) {
  return us.updateInfo(user) ;
}
@GetMapping("/remove/{id}")
public Mono<Void> remove(@PathVariable("id")Long id) {
  return us.remove(id) ;
}
@GetMapping("query")
public Flux<Users> query() {
  return us.queryUsers() ;
}
@GetMapping("/queryLike") 
public Flux<Users> queryLike(String keyword) {
  return us.queryUsersLike(keyword) ;
}
@GetMapping("/queryPager") 
public Flux<Users> queryPager(Integer page, Integer size) {
  return us.queryPager(page, size) ;
}