SpringBoot响应式编程 WebFlux入门教程
🍁 作者:知识浅谈,CSDN签约讲师,CSDN博客专家,华为云云享专家,阿里云专家博主
📌 擅长领域:全栈工程师、爬虫、ACM算法
🔥 微信:zsqtcyw 联系我领取学习资料
🤞SpringBoot响应式编程 WebFlux入门教程🤞
- 🎈概述
- 🎈快速入门
- 🎈关键概念
- 🎈配置细节
- 🎈测试方法
- 🍚总结
🎈概述
Spring Boot响应式编程的核心框架之一是WebFlux,它是专为反应式编程设计的Web框架。与传统的Spring MVC相比,WebFlux具有显著的不同:它是异步非阻塞的,这意味着它能够通过较少的线程处理高并发请求。WebFlux底层完全基于Netty、Reactor和Spring Web,利用异步处理、消息队列(内存)和事件回调机制,实现了一套高效的响应式系统。
优点
- 高并发能力:通过异步非阻塞的IO模型,WebFlux能使用少量资源处理大量请求。
- 高效资源利用:在传统的阻塞式编程中,如果请求需要IO操作(如数据库访问或调用第三方服务),线程将阻塞等待操作完成。而在- WebFlux中,线程可以在等待IO操作完成的同时处理其他请求,从而提高资源利用率。
- 实时数据流处理:WebFlux支持反应式数据流,能够实时响应数据变化,适用于实时数据处理和推送场景。
🎈快速入门
- 添加WebFlux依赖
首先,你需要在Spring Boot项目的pom.xml文件中添加WebFlux的依赖:
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-webflux</artifactId>
</dependency>
- 编写响应式控制器
接下来,创建一个响应式控制器来处理HTTP请求。使用@RestController和@RequestMapping注解来定义控制器和路由。使用Flux和Mono来定义异步非阻塞的响应式数据流。
package cn.juwatech.controller;import cn.juwatech.entity.User;
import cn.juwatech.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;@RestController
@RequestMapping("/users")
public class UserController {@Autowiredprivate UserService userService;@GetMapping("/")public Flux<User> getAllUsers() {return userService.getAllUsers();}@GetMapping("/{id}")public Mono<User> getUserById(@PathVariable("id") String id) {return userService.getUserById(id);}@PostMapping("/")public Mono<User> createUser(@RequestBody User user) {return userService.createUser(user);}@PutMapping("/{id}")public Mono<User> updateUser(@PathVariable("id") String id, @RequestBody User user) {return userService.updateUser(id, user);}@DeleteMapping("/{id}")public Mono<Void> deleteUser(@PathVariable("id") String id) {return userService.deleteUser(id);}
}
- 编写响应式服务
在服务层,同样使用Flux和Mono来处理业务逻辑,以保持响应式编程的一致性。
package cn.juwatech.service;import cn.juwatech.entity.User;
import org.springframework.stereotype.Service;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import java.util.HashMap;
import java.util.Map;@Service
public class UserService {private final Map<String, User> userMap = new HashMap<>();public Flux<User> getAllUsers() {return Flux.fromIterable(userMap.values());}public Mono<User> getUserById(String id) {return Mono.justOrEmpty(userMap.get(id));}public Mono<User> createUser(User user) {userMap.put(user.getId(), user);return Mono.just(user);}public Mono<User> updateUser(String id, User user) {userMap.put(id, user);return Mono.just(user);}public Mono<Void> deleteUser(String id) {userMap.remove(id);return Mono.empty();}
}
- 运行和测试
运行Spring Boot应用,并通过浏览器或Postman等工具发送HTTP请求进行测试当然,接下来我将继续深入介绍Spring Boot响应式编程WebFlux的入门教程,包括一些关键概念、配置细节和测试方法。
🎈关键概念
- Reactor
Reactor是Project Reactor的一部分,它是一个用于在JVM上构建响应式应用程序的库。Reactor提供了两种主要的数据类型:Flux和Mono。
- Flux:表示一个包含0到N个元素的异步序列,可以发出三种类型的信号:正常的值、错误信号或完成信号。
- Mono:表示一个包含0或1个元素的异步序列,它同样是响应式类型的,但用于那些最多只需要一个值的场景。
- Netty
Netty是一个高性能、异步事件驱动的NIO框架,它支持快速开发可维护的高性能协议服务器和客户端。WebFlux底层默认使用Netty作为其非阻塞服务器。
🎈配置细节
- 端口配置
在application.properties或application.yml文件中,你可以配置应用的端口号。默认情况下,Spring Boot应用会监听8080端口,但你可以根据需要进行修改。
# application.properties
server.port=8081
- 响应式数据库
虽然WebFlux可以与传统的关系型数据库(如MySQL)一起使用,但为了更好地发挥响应式编程的优势,建议使用响应式数据库,如R2DBC(Reactive Relational Database Connectivity)。
在pom.xml中添加R2DBC的依赖,并配置数据源:
<dependency><groupId>io.r2dbc</groupId><artifactId>r2dbc-h2</artifactId><scope>runtime</scope>
</dependency>
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-r2dbc</artifactId>
</dependency>
然后,在application.properties或application.yml中配置数据库连接:
# application.properties
spring.r2dbc.url=r2dbc:h2:mem:///testdb
spring.r2dbc.username=sa
spring.r2dbc.password=password
🎈测试方法
-
单元测试
使用JUnit和Reactor Test工具进行单元测试。你可以编写测试用例来验证你的响应式方法是否按预期工作。import org.junit.jupiter.api.Test; import reactor.test.StepVerifier;public class UserServiceTest {private final UserService userService = new UserService(); // 假设UserService是无状态的@Testpublic void testGetAllUsers() {// 假设userService.getAllUsers()返回一个包含一些用户的FluxFlux<User> usersFlux = userService.getAllUsers();StepVerifier.create(usersFlux).expectNextMatches(user -> user.getId().equals("1") && user.getName().equals("Alice")).expectNextMatches(user -> user.getId().equals("2") && user.getName().equals("Bob")).verifyComplete();} }
-
集成测试
使用Spring Boot的测试框架进行集成测试,以验证整个应用程序的响应式行为。
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.autoconfigure.web.reactive.WebFluxTest;
import org.springframework.test.web.reactive.server.WebTestClient;@WebFluxTest(UserController.class)
public class UserControllerTest {@Autowiredprivate WebTestClient webTestClient;@Testpublic void testGetAllUsers() {webTestClient.get().uri("/users/").exchange().expectStatus().isOk().expectBodyList(User.class).hasSize(2).contains(user -> user.getId().equals("1") && user.getName().equals("Alice")).contains(user -> user.getId().equals("2") && user.getName().equals("Bob"));}
}
🍚总结
Spring Boot的WebFlux为开发者提供了一个全新的响应式编程模型,用于构建高性能、高扩展性的Web应用程序。通过使用当然,我将继续介绍Spring Boot WebFlux的一些高级特性和最佳实践,帮助你更深入地理解并有效地使用它。
大功告成,撒花致谢🎆🎇🌟,关注我不迷路,带你起飞带你富。
作者:码海浮生
相关文章:
SpringBoot响应式编程 WebFlux入门教程
🍁 作者:知识浅谈,CSDN签约讲师,CSDN博客专家,华为云云享专家,阿里云专家博主 📌 擅长领域:全栈工程师、爬虫、ACM算法 🔥 微信:zsqtcyw 联系我领取学习资料 …...
LeetCode 383. 赎金信
题目 给你两个字符串:ransomNote 和 magazine ,判断 ransomNote 能不能由 magazine 里面的字符构成。 如果可以,返回 true ;否则返回 false 。 magazine 中的每个字符只能在 ransomNote 中使用一次。 示例 1: 输入&…...
python绘制电路图
要在 Python 中实现电路图,你可以使用一些专门的库来创建和可视化电路图。一个常用的库是 schemdraw,它可以用来绘制电路图,并支持多种电气组件和符号。 下面是一个使用 schemdraw 库绘制简单电路图的示例: 安装 schemdraw 库&am…...
Vue3 Suspense 和 defineAsyncComponent 结合使用方法
Suspense:用于协调对组件树中嵌套的异步依赖的处理。 defineAsyncComponent:定义一个异步组件,它在运行时是懒加载的。参数可以是一个异步加载函数,或是对加载行为进行更具体定制的一个选项对象。 异步组件的好处:使…...
GitHub中Codespace怎么使用;LLM模拟初始化;MLP:全连接神经网络的并行执行
目录 PyUnit unittest是什么 unittest怎么使用 GitHub中Codespace怎么使用 测试常用功能 LLM模拟初始化 参数解释 类属性设置 总结 MLP:全连接神经网络的并行执行 假设 代码解释 注意事项 PyUnit unittest是什么 unittest是Python的内置单元测试框架,原名PyUn…...

【rh】rh项目部署
【fastadmin】 1、项目先clone到本地,其中web为h5前端使用(gitclone后,把web内容放进去再提交),其余为项目后端使用 2、安装本地环境,项目跑起来,步骤如下: 1)查春.git 和 composer,json 版本信…...

VoxelNet: End-to-End Learning for Point Cloud Based 3D Object Detection
VoxelNet: End-to-End Learning for Point Cloud Based 3D Object Detection Abstract 摘要部分,作者首先指出了3D点云中目标检测的重要性,在自动驾驶导航、家政机器人以及增强现实和虚拟现实等多个领域有重要的作用。然后,提到了现有方法的…...

结构开发笔记(三):solidworks软件(二):小试牛刀,绘制一个立方体
若该文为原创文章,转载请注明原文出处 本文章博客地址:https://hpzwl.blog.csdn.net/article/details/141122350 长沙红胖子Qt(长沙创微智科)博文大全:开发技术集合(包含Qt实用技术、树莓派、三维、OpenCV…...

LLM 量化算法AutoRound 0.3 发布及原理浅析
这里写自定义目录标题 AutoRound V0.3 特性原理浅析其他工作AutoRound 原理 AutoRound(https://github.com/intel/auto-round)在Llama3.1-8B-Instruct上效果明显优于AWQ/GPTQ等方法,在10个任务的平均准确率上我们以63.93%由于AWQ的63.15%和GP…...

汽车免拆诊断案例 | 2013款北京现代悦动车发动机偶尔无法起动
故障现象 一辆2013款北京现代悦动车,搭载G4FC发动机,累计行驶里程约为13.9万km。车主反映,发动机偶尔无法起动着机,断开点火开关,等待一会儿又可以起动着机。 故障诊断 接车后反复试车,当发动机无法起动着…...
React、AntD,封装动态表单
在React中使用Ant Design(简称AntD)来封装动态表单是一个常见的需求,特别是在需要灵活配置表单字段的场景下。以下是一个基本的步骤和示例代码,展示如何使用React和AntD来封装一个动态表单。 步骤 1: 安装必要的库 首先,确保你的项目中已经安装了react和antd。如果还没有…...

【Linux基础】Linux中的开发工具(3)--make/makefile和git的使用
目录 前言一,Linux项目自动化构建工具-make/makefile1. 背景2. 依赖关系和依赖方法3. 项目清理4. 使用方法和原理5. .PHONY的作用6. makefile中符号的使用 二,进度条的实现1. 理解回车换行2. 理解行缓冲区3. 版本14. 版本2 三,Linux上git的使…...

过滤了字母、数字、_、$的webshell命令执行技巧
目录 对于php5以上首先要解决的问题有 解决技巧 1.code长度小于35位 2.没有字母、数字、_ 、$ 3.怎么把文件放进服务器 4.怎么执行文件里面的内容 1.执行Linux命令 2.执行文件里面的shell命令 5.构造完整的code参数 6.我们还可以通过修改文件里面shell命令,…...

python-A+B again
[题目描述] 小理有一个非常简单的问题给你,给你两个整数 A 和 B,你的任务是计算 AB。输入格式: 输入共 2∗T1 行。 输入的第一行包含一个整数 T 表示测试实例的个数,然后 2∗T 行,分别表示 A 和 B 两个正整数。注意整数…...

C语言—函数递归
一、递归概念 递归其实是⼀种解决问题的⽅法,在C语⾔中,递归就是函数⾃⼰调⽤⾃⼰。下面举一个例子: 上述就是⼀个简单的递归程序,只不过上⾯的递归只是为了演⽰递归的基本形式,不是为了解决问题,代码最终…...

结构开发笔记(四):solidworks软件(三):绘制36x36方块摄像头示意体
若该文为原创文章,转载请注明原文出处 本文章博客地址:https://hpzwl.blog.csdn.net/article/details/141187797 长沙红胖子Qt(长沙创微智科)博文大全:开发技术集合(包含Qt实用技术、树莓派、三维、OpenCV…...

【机器学习】Caltech-101的基本概念和使用方法以及Caltech-101和ImageNet的联系和区别
引言 Caltech-101数据集是一个广泛用于对象识别任务的数据库,它包含了大约9,000张图像,这些图像来自101个不同的对象类别。每个类别包含的图像数量大约在40到800张之间,大多数类别大约有50张图像。图像的分辨率大致为300200像素 文章目录 引言…...

mysql Ubuntu安装与远程连接配置
一、安装(Ubuntu22环境安装mysql8) 这里使用Xshell链接Ubuntu和mysql windows进行操作,特别提醒:安装之前建议对Ubuntu快照处理备份,避免安装中出错导致Ubuntu崩溃。 查看是否安装的有可以用指令:ps -ef|…...

c语言中比较特殊的输入格式
目录 一.%[ ] 格式说明符 1.基本用法 (1)读取字母字符: (2)读取数字字符: (3)读取所有字符直到遇到空格: (4)读取直到换行符: 2.使用范围和组合: 3.^ 取反操作 4.注意事项 (1). 字符范围的正确表示 (2). 避免字符集中的特殊字符冲突 (3).避免空字符集 (4). 输入长…...

远程命令行控制SSH
第一次接触SSH是ROS小车作为服务端,通过ubuntu电脑客户端访问。因为机器人接键盘和屏幕操作起来不方便,所以使用SSH进行连接,方便对小车的操作。 1.服务端安装 打开终端查看ssh是否安装 sudo service ssh status 如果未安装 sudo apt upd…...

观成科技:隐蔽隧道工具Ligolo-ng加密流量分析
1.工具介绍 Ligolo-ng是一款由go编写的高效隧道工具,该工具基于TUN接口实现其功能,利用反向TCP/TLS连接建立一条隐蔽的通信信道,支持使用Let’s Encrypt自动生成证书。Ligolo-ng的通信隐蔽性体现在其支持多种连接方式,适应复杂网…...
conda相比python好处
Conda 作为 Python 的环境和包管理工具,相比原生 Python 生态(如 pip 虚拟环境)有许多独特优势,尤其在多项目管理、依赖处理和跨平台兼容性等方面表现更优。以下是 Conda 的核心好处: 一、一站式环境管理:…...
synchronized 学习
学习源: https://www.bilibili.com/video/BV1aJ411V763?spm_id_from333.788.videopod.episodes&vd_source32e1c41a9370911ab06d12fbc36c4ebc 1.应用场景 不超卖,也要考虑性能问题(场景) 2.常见面试问题: sync出…...
【决胜公务员考试】求职OMG——见面课测验1
2025最新版!!!6.8截至答题,大家注意呀! 博主码字不易点个关注吧,祝期末顺利~~ 1.单选题(2分) 下列说法错误的是:( B ) A.选调生属于公务员系统 B.公务员属于事业编 C.选调生有基层锻炼的要求 D…...
三体问题详解
从物理学角度,三体问题之所以不稳定,是因为三个天体在万有引力作用下相互作用,形成一个非线性耦合系统。我们可以从牛顿经典力学出发,列出具体的运动方程,并说明为何这个系统本质上是混沌的,无法得到一般解…...
代码随想录刷题day30
1、零钱兑换II 给你一个整数数组 coins 表示不同面额的硬币,另给一个整数 amount 表示总金额。 请你计算并返回可以凑成总金额的硬币组合数。如果任何硬币组合都无法凑出总金额,返回 0 。 假设每一种面额的硬币有无限个。 题目数据保证结果符合 32 位带…...
JavaScript 数据类型详解
JavaScript 数据类型详解 JavaScript 数据类型分为 原始类型(Primitive) 和 对象类型(Object) 两大类,共 8 种(ES11): 一、原始类型(7种) 1. undefined 定…...

android13 app的触摸问题定位分析流程
一、知识点 一般来说,触摸问题都是app层面出问题,我们可以在ViewRootImpl.java添加log的方式定位;如果是touchableRegion的计算问题,就会相对比较麻烦了,需要通过adb shell dumpsys input > input.log指令,且通过打印堆栈的方式,逐步定位问题,并找到修改方案。 问题…...

【Linux手册】探秘系统世界:从用户交互到硬件底层的全链路工作之旅
目录 前言 操作系统与驱动程序 是什么,为什么 怎么做 system call 用户操作接口 总结 前言 日常生活中,我们在使用电子设备时,我们所输入执行的每一条指令最终大多都会作用到硬件上,比如下载一款软件最终会下载到硬盘上&am…...

嵌入式学习之系统编程(九)OSI模型、TCP/IP模型、UDP协议网络相关编程(6.3)
目录 一、网络编程--OSI模型 二、网络编程--TCP/IP模型 三、网络接口 四、UDP网络相关编程及主要函数 编辑编辑 UDP的特征 socke函数 bind函数 recvfrom函数(接收函数) sendto函数(发送函数) 五、网络编程之 UDP 用…...