212. Spring Boot WebFlux：响应式Spring Data之MongoDB

Posted 2021-04-28 SpringBoot

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了212. Spring Boot WebFlux：响应式Spring Data之MongoDB相关的知识，希望对你有一定的参考价值。

【视频&交流平台】

SpringBoot视频：http://t.cn/R3QepWG

Spring Cloud视频：http://t.cn/R3QeRZc

SpringBoot Shiro视频：http://t.cn/R3QDMbh

SpringBoot交流平台：http://t.cn/R3QDhU0

SpringBoot 2.0 SpringData和JPA视频：

http://t.cn/R1pSojf

说明

（1）JDK版本：1.8

（2）Spring Boot 2.0.5

需求缘起

在上一篇博客中我们对于WebFlux编写了一个简单的Hello World，然而绝大多数系统免不了要与数据库进行交互，所以我们也需要响应式的持久层API和支持异步的数据库驱动。

各个数据库都开始陆续推出异步驱动，目前SpringData支持的可以进行响应式数据访问的数据库有MongoDB、Redis、Apache Cassandra和CouchDB。今天我们用MongoDB来写一个响应式demo。

一、响应式Spring Data之MongoDB

本例子是基于上一篇文章的例子进行编码。

1.1 添加依赖

在POM中增加Spring Data Reactive Mongo的依赖：

<dependency>

     <groupId>org.springframework.boot</groupId>

             <artifactId>spring-boot-starter-data-mongodb-reactive</artifactId>

</dependency>

1.2 创建实体类

我们创建一个User实体类，这里使用@Document注解，使用@Id标注这是一个主键。

@Document

public class User {



    @Id

    private String id;

    private String phone;

    private String email;

    private String name;

    public String getId() {

       return id;

    }

     //省略setter and getter…

}

1.3 创建Repository

与非响应式Spring Data的CrudReposity对应的，响应式的Spring Data也提供了相应的Repository库：ReactiveCrudReposity，当然，我们也可以使用它的子接口ReactiveMongoRepository。

public interface UserRepository extends ReactiveCrudRepository<User, String> {



}

1.4 创建Service

由于业务逻辑几乎为零，只是简单调用了DAO层：

@Service
public class UserService {
    @Autowired
    private UserRepository userRepository;


     public Mono<User> save(User user) {
         return userRepository.save(user); 
     }

    public Mono<Void> deleteById(String id) {
        return userRepository.deleteById(id);
    }

    public Mono<User> findById(String id) {
        return userRepository.findById(id);
    }

    public Flux<User> findAll() {
        return userRepository.findAll();
    }

}

1.5 创建Controller

Controller层是直接调用了Service层代码，也比较简单：

@RestController
@RequestMapping("/user")
public class UserController {
    @Autowired
    private UserService userService;

    @GetMapping("/save")
    public Mono<User> save(User user) {
        return this.userService.save(user);
    }

    @GetMapping("/deleteById")
    public Mono<Void> deleteById(String id) {
        return this.userService.deleteById(id);
    }

    @GetMapping("/findById")
    public Mono<User> findById(String id) {
        return this.userService.findById(id);
    }

    @GetMapping("/findAll")
    public Flux<User> findAll() {
        return this.userService.findAll();
    }
}