- 当前位置：首页 >数据库 >用 WebFlux 写个 CURD 是什么体验？
用 WebFlux 写个 CURD 是什么体验？
发布时间：2025-11-04 12:40:02 来源：技术快报 作者：域名
今天我们继续来搞 WebFlux！用W验
WebFlux 最为人所诟病的什体是数据库的支持问题，毕竟数据是用W验一个应用的生命，我们接触的什体大部分应用程序都是有数据库的，而 WebFlux 在这一方面的用W验支持行一直比较弱，这也是什体大家总是吐槽它的原因。
不过从 Spring5 开始，用W验这一问题得到了一定程度的什体缓解。
Spring 官方在 Spring5 发布了响应式 Web 框架 Spring WebFlux 之后急需能够满足异步响应的用W验数据库交互 API，不过由于缺乏标准和驱动，什体Pivotal 团队开始自己研究响应式关系型数据库连接 Reactive Relational Database Connectivity，用W验并提出了 R2DBC 规范 API 用来评估可行性并讨论数据库厂商是什体否有兴趣支持响应式的异步非阻塞驱动程序。最早只有 PostgreSQL 、用W验H2、什体MSSQL 三家数据库厂商，用W验不过现在 MySQL 也加入进来了，这是一个极大的亿华云利好。目前 R2DBC 的最新版本是 0.9.0.RELEASE。
松哥在接下来的文章中将会和大家演示 R2DBC 的用法，但是今天我们还是先来看看 WebFlux+MongoDB 的用法，毕竟这是 WebFlux 较早支持的数据库之一，各种 API 都比较成熟，我们一步一步来。
1.项目创建
方便起见，我们这里就直接创建 Spring Boot 项目，首先创建一个 Spring Boot 项目，引入 MongoDB 依赖和 WebFlux 依赖，如下：
图片
注意我们这里选择的 MongoDB 依赖是 Spring Data Reactive MongoDB，千万别选错了。
项目创建完成后，我们先在 application.properties 中对 MongoDB 进行简单配置，如下（如果小伙伴们尚不熟悉 MongoDB 的操作，可以在公众号底部菜单找到松哥原创的 MongoDB 教程）：
复制spring.data.mongodb.port=27017 spring.data.mongodb.host=127.0.0.1 spring.data.mongodb.username=madmin spring.data.mongodb.password=m123 spring.data.mongodb.database=test spring.data.mongodb.authentication-database=admin1.2.3.4.5.6.多说一句，在之前的 Spring Boot 视频教程中，松哥对 MongoDB 也有过介绍，b2b信息网感兴趣的小伙伴戳这里：Spring Boot+Vue+微人事视频教程。
配置完 MongoDB 后，我们的准备工作就算完成了。
2.实体类与 Dao
接下来我们需要准备一个操作的实体类，这些都是 JPA 的基本操作，松哥就不再赘述，如果小伙伴们不熟悉的话，可以公号后台回复 666 查看原创的 Spring Boot 教程，里边有涉及到，实体类如下：
复制@Document public class User { @Id private String id; private String username; private String address; public String getId() { return id; } public void setId(String id) { this.id = id; } public String getUsername() { return username; } public void setUsername(String username) { this.username = username; } public String getAddress() { return address; } public void setAddress(String address) { this.address = address; } }1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.29.30.31.接下来我们再提供一个实体类操作的接口，如下：
复制@EnableMongoRepositories public interface UserDao extends ReactiveMongoRepository<User,String> { }1.2.3.自定义一个空的接口继承自 ReactiveMongoRepository，里边什么都不用写，这套路就和松哥之前视频中介绍的 JPA 的用法如出一辙（毕竟都是 Spring Data 家族），所以这块就没啥好说的，不赘述。
3.测试接口
接下来我们来看看测试接口。
3.1 添加
首先我们来看看添加数据。
复制@RestController @RequestMapping("/user") public class UserController { @Autowired UserDao userDao; @PostMapping("/") public Mono<User> addUser(@RequestBody User user) { return userDao.save(user); } }1.2.3.4.5.6.7.8.9.10.11.添加完成后，返回刚刚添加成功的对象。b2b供应网save 方法的返回值就是 Mono。
我们来看看测试效果：
图片
3.2 查询
再来看看查询效果：
复制@GetMapping("/") public Flux<User> getAll() { return userDao.findAll(); } @GetMapping(value = "/stream/all", produces = MediaType.TEXT_EVENT_STREAM_VALUE) public Flux<User> streamGetAll() { return userDao.findAll(); }1.2.3.4.5.6.7.8.我们提供了两个查询接口，一个就是返回 Flux，里边包含多个对象，还有一个我设置了响应的 Content-Type 为 text/event-stream，通过响应式流返回数据，具体参见【服务端推送数据，除了 WebSocket 你还能想到啥？】一文。
我们来看看查询效果：
图片
图片
可以看到两种不同的查询方式返回的数据格式也有差异。前者是以数组形式一次性返回数据，后者是以 SSE 的形式多次返回数据。
3.3 删除
再来看看删除。
按照 RESTful 规范，如果删除成功请求响应码就是 200，如果删除失败请求响应码就是 404，因此，我们开发出来的接口如下：
复制@DeleteMapping("/{id}") public Mono<ResponseEntity<Void>> deleteUser(@PathVariable String id) { return userDao.findById(id) .flatMap(user -> userDao.delete(user).then(Mono.just(new ResponseEntity<Void>(HttpStatus.OK)))) .defaultIfEmpty(new ResponseEntity(HttpStatus.NOT_FOUND)); }1.2.3.4.5.6.首先从数据库中查询出相关的数据，然后调用 flatMap，在 flatMap 中对数据进行删除处理，删除完成后，给出一个 200 的响应码，如果查询的时候没有查询到数据，就给一个 404 响应码。
可以看到，删除成功后，响应码为 200：
图片
删除失败后，响应码为 404：
图片
3.4 修改
再来看看修改，和前面的删除类似，先查询，再修改：
复制@PutMapping("/") public Mono<ResponseEntity<User>> updateUser(@RequestBody User user) { return userDao.findById(user.getId()) .flatMap(u -> userDao.save(user)) .map(u->new ResponseEntity<User>(u,HttpStatus.OK)) .defaultIfEmpty(new ResponseEntity(HttpStatus.NOT_FOUND)); }1.2.3.4.5.6.7.
图片
如果修改的数据不存在的话，就会给出一个 404 响应：
图片
3.5 自定义查询方法
松哥之前的 Spring Data Jpa 中讲的一些查询 API，这里同样是适用的（公号后台回复 666 获取之前的教程）。
例如我们可以在 UserDao 中自定义一个查询方法：
复制@EnableMongoRepositories public interface UserDao extends ReactiveMongoRepository<User,String> { Flux<User> findUserByUsernameContaining(String name); }1.2.3.4.然后添加一个接口调用该方法：
复制@GetMapping("/byname") public Flux<User> getUserByName(String name) { return userDao.findUserByUsernameContaining(name); }1.2.3.4.这样该接口就可以查询名字中包含某关键字的所有用户了。
其他关于 JPA 的用法这里都是适用的，因为在之前的文章中讲过，松哥这里就不再赘述了。
4.小结
好啦，今天我们就用 WebFlux 写了一个简单的 CURD，大家先来感受下 WebFlux 的基本用法，后面的文章松哥将和大家分享 WebFlux 如何连接关系型数据库，敬请期待。
- 电脑加密显示参数错误的原因及解决方法（深入分析加密显示参数错误，保护个人信息安全）
- 如何打开和处理bin文件（简单易懂的操作指南）
- Win10大白菜安装教程（教你轻松安装Win10大白菜系统，让电脑焕发新生）
- 联想笔记本电脑DVD重装系统教程（详细步骤图文教程，轻松重装你的笔记本电脑）
- 体验SkullcandyInkd耳机的音质和舒适度（探索这款耳机的优缺点并提供全面评价）
- 老毛教你如何安装Win8系统（以老毛挑安装Win8教程为主题的详细教学）
- 华为笔记本BIOS教程（学习华为笔记本BIOS设置，提升您的电脑使用体验）
- 老毛桃系统教程（用老毛桃系统教你如何开启自然智慧之门）
- 探索LGUF6800电视的功能与特点（一款高性能的智能电视体验）
- 使用U盘安装Win7系统教程（通过U盘轻松更换操作系统，让你的电脑焕然一新）
- 电脑计算器输入数字错误的问题（探讨计算器输入数字错误的原因和解决方法）
- 联想X220的性能及用户体验（一款经典商务笔记本的全面评测与分析）
- 电脑文档打不开的解决方法（应对电脑文档无法打开的常见问题与解决办法）
- u精灵一键装机教程——让电脑安装轻松无忧（一键装机工具u精灵的使用方法及注意事项）
- 清华同方N768教程（一键开启科技新时代，解锁清华同方N768的神秘功能）
- 华硕ROG笔记本GFX71JY的性能和功能介绍（一款强劲的游戏笔记本，满足你的高性能需求）
- 探索MAX702D的全新功能与性能（一台引领时代的创新之作）
- 老毛桃PE安装教程（教你轻松创建老毛桃PE，让电脑维修更高效）
- U盘装双系统教程（简单易行的U盘装双系统方法）
- 揭秘电器串货利润暴利现象（深入探究电器行业串货的利益链条与风险）
随便看看
- Copyright © 2025 Powered by 用 WebFlux 写个 CURD 是什么体验？,技术快报 滇ICP备2023006006号-46sitemap