上一篇文章中我们已经简单搭建了 webflux 的框架，今天就集成 mongodb 完成一个用户管理系统。

1. 安装 MongoDb

• 直接去官网下载安装包：

https://www.mongodb.com/downl…

• 选择对应的操作系统，我的是 windows，然后选择 zip，还是 msi。我下载的 zip 也就是绿色免安装。如果 msi 的就直接下一步，下一步按要求安装就好了。
• zip 启动方式：

到 bin 目录下打开 cmd 命令窗口 运行：

mongod.exe --dbpath C:\Tools\mongodb\db

dbpathshi 是设置数据备份目录，必须要设置，否则启动不了。

bin 目录下的 mongo.exe 是 mongodb 的查询客户端，可以执行查询操作。一些查询命令可以直接去官网看。
show dbs: 显示当前所有文档库，相当于数据库
use test：选择 test 库
db.user.find(): 查询所有 user 文档数据
db.user.drop(): 删除所有 user 文档

2. 集成 mogodb

pom 文件依赖：

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

配置连接：

spring.data.mongodb.host=localhost
spring.data.mongodb.database=test
spring.data.mongodb.port=27017

3.dao 层

package com.mike.dao;

import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
import org.springframework.stereotype.Repository;

import com.mike.po.User;

/**
 * The class UserDao.java
 */
@Repository
public interface UserDao extends ReactiveMongoRepository<User, String>{}

ReactiveMongoRepository 已经帮你实现了增删该查，如果需要别的方法，需要自己添加实现接口。具体写法和 JPA 类似

4.service 层

package com.mike.service;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.stereotype.Service;

import com.mike.dao.UserDao;
import com.mike.po.User;

import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

/**
 * The class UserService.java
 */
@Service
public class UserService {
    @Autowired
    private UserDao userDao;
    
    @Autowired
    private MongoTemplate mongoTemplate;
    
    public Mono<User> saveOrUpdateUser(User user){return userDao.save(user);
    }
    
    public Mono<User> findById(String id){return userDao.findById(id);
    }
    
    public Flux<User> findAll(){return userDao.findAll();
    }
    
    public  void deleteById(String id){
        // 使用 mongoTemplate 来做删除   直接使用提供的删除方法不行
        Query query = Query.query(Criteria.where("id").is(id));
        mongoTemplate.remove(query, User.class);
        //userDao.deleteById(id);  这样无法删除, 不知道为什么
    }
}

5.controller 层

package com.mike.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import com.mike.po.User;
import com.mike.service.UserService;

import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

/**
 * The class UserController.java
 */
@Controller
public class UserController {
    @Autowired
    private UserService userService;
    
    @PostMapping("/user")
    public String save(User user,final Model model){Mono<User> u = userService.saveOrUpdateUser(user);
         model.addAttribute("user", u);
         return "redirect:/users";
    }
    
    @GetMapping("/user/find/{id}")
    @ResponseBody
    public Mono<User> find(@PathVariable("id") String id){return userService.findById(id);
    }
    
    @GetMapping("/users")
    public String findAll(final Model model){Flux<User> users= userService.findAll();
        model.addAttribute("users", users);
        return "user";
    }
    
    @GetMapping("/user/delete/{id}")
    public String delete(@PathVariable("id") String id){userService.deleteById(id);
        return "redirect:/users";
    }
}

6.po 层

package com.mike.po;

import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Field;

/**
 * The class User.java
 */
public class User {
    @Id
    @Field("_id")
    private String id;
    private String name;
    private String sex;
    private String job;
    private String address;
    private String phone;
    
    
    /**
     * @return the id
     */
    public String getId() {return id;}
    /**
     * @param id the id to set
     */
    public void setId(String id) {this.id = id;}
    /**
     * @return the name
     */
    public String getName() {return name;}
    /**
     * @param name the name to set
     */
    public void setName(String name) {this.name = name;}
    /**
     * @return the sex
     */
    public String getSex() {return sex;}
    /**
     * @param sex the sex to set
     */
    public void setSex(String sex) {this.sex = sex;}
    /**
     * @return the job
     */
    public String getJob() {return job;}
    /**
     * @param job the job to set
     */
    public void setJob(String job) {this.job = job;}
    /**
     * @return the address
     */
    public String getAddress() {return address;}
    /**
     * @param address the address to set
     */
    public void setAddress(String address) {this.address = address;}
    /**
     * @return the phone
     */
    public String getPhone() {return phone;}
    /**
     * @param phone the phone to set
     */
    public void setPhone(String phone) {this.phone = phone;}
    
    
}

7. 总结

和正常的关系型数据库的操作一样，只不过有些问题想不明白。我上面的删除旧出现了无法删除的问题，最后使用的 mongodbTemplate 完成的，这是个同步操作。为什么会出现这样的问题呢？这就是响应式编程的坑，如果你不理解就会出现问题。增删改查完了，但是没有页面展示，写一篇写页面。