资讯专栏INFORMATION COLUMN

WebFlux 集成MongoDb

n7then / 1303人阅读

摘要:上一篇文章中我们已经简单搭建了的框架,今天就集成完成一个用户管理系统。如果的就直接下一步,下一步按要求安装就好了。目录下的是的查询客户端,可以执行查询操作。我上面的删除旧出现了无法删除的问题,最后使用的完成的,这是个同步操作。

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

直接去官网下载安装包:

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

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

zip启动方式:

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

mongod.exe --dbpath C:Toolsmongodbdb

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

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

2.集成mogodb

pom文件依赖:

        
            org.springframework.boot
            spring-boot-starter-data-mongodb-reactive
        

配置连接:

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{

}

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 saveOrUpdateUser(User user){
        return userDao.save(user);
    }
    
    public Mono findById(String id){
        return userDao.findById(id);
    }
    
    public Flux 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 u = userService.saveOrUpdateUser(user);
         model.addAttribute("user", u);
         return "redirect:/users";
    }
    
    @GetMapping("/user/find/{id}")
    @ResponseBody
    public Mono find(@PathVariable("id") String id){
        return userService.findById(id);
    }
    
    @GetMapping("/users")
    public String findAll(final Model model){
        Flux 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完成的,这是个同步操作。为什么会出现这样的问题呢?这就是响应式编程的坑,如果你不理解就会出现问题。增删改查完了,但是没有页面展示,写一篇写页面。

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/19539.html

相关文章

  • Spring Boot 2 快速教程:WebFlux 集成 Mongodb(四)

    摘要:在配置下上面启动的配置数据库名为账号密码也为。突出点是,即非阻塞的。四对象修改包里面的城市实体对象类。修改城市对象,代码如下城市实体类城市编号省份编号城市名称描述注解标记对应库表的主键或者唯一标识符。 摘要: 原创出处 https://www.bysocket.com 「公众号:泥瓦匠BYSocket 」欢迎关注和转载,保留摘要,谢谢! 这是泥瓦匠的第104篇原创 文章工程: JDK...

    Corwien 评论0 收藏0
  • webflux 用户管理界面

    摘要:一个简单的用户管理的已经完成,现在我们需要在页面上展示,方便用户管理。创建首页页面首页欢迎页面首页实战课程你想学点啥上班摸鱼下班充电案例上手本课程是一个系列基础教程,目标是带领读者上手实战,课程以新版本的核心概念作为主线。 一个简单的用户管理的CRUD已经完成,现在我们需要在页面上展示,方便用户管理。尽管现在已经流行前后分离开发,但是在一些小公司做的项目并不需要前端开发人员,页面也是后...

    dmlllll 评论0 收藏0
  • Spring Boot 2.x 系列教程:WebFlux 系列教程大纲(一)

    摘要:使用则需要及以上版本。开发使用框架七系列教程目录系列教程大纲快速入门实践实践整合整合中和实践整合中实现缓存中实现通信集成测试及部署实战图书管理系统 WebFlux 系列教程大纲 一、背景 大家都知道,Spring Framework 是 Java/Spring 应用程序跨平台开发框架,也是 Java EE(Java Enterprise Edition) 轻量级框架,其 Spring ...

    jone5679 评论0 收藏0
  • 华为官方首发Spring响应式微服务,Spring+Boot+Cloud三管齐下

    摘要:今天小编就来分享一份华为刚刚首发的响应式微服务实战这份主要包含响应式微服务架构实现过程中所应具备的技术体系和工程实践,在组织结构上分如下篇。 今天小编就来分享一份华为刚刚首发的Spring响应式微服务(Spring Boot 2+Spring 5+Spring Cloud实战)! 这份PDF...

    cangck_X 评论0 收藏0
  • Spring Boot 2 快速教程:WebFlux 快速入门(二)

    摘要:响应式编程是基于异步和事件驱动的非阻塞程序,只是垂直通过在内启动少量线程扩展,而不是水平通过集群扩展。三特性常用的生产的特性如下响应式编程模型适用性内嵌容器组件还有对日志消息测试及扩展等支持。 摘要: 原创出处 https://www.bysocket.com 「公众号:泥瓦匠BYSocket 」欢迎关注和转载,保留摘要,谢谢! 02:WebFlux 快速入门实践 文章工程: JDK...

    gaara 评论0 收藏0

发表评论

0条评论

n7then

|高级讲师

TA的文章

阅读更多
最新活动
阅读需要支付1元查看
<