0

0

Spring WebFlux 如何处理返回 Mono 的控制器方法?

聖光之護

聖光之護

发布时间:2026-01-05 20:01:25

|

546人浏览过

|

来源于php中文网

原创

Spring WebFlux 如何处理返回 Mono 的控制器方法?

spring webflux 在控制器方法返回 mono 后,并不会立即执行其内部逻辑,而是将 mono 交由 webflux 基础设施在请求生命周期的后续阶段(如响应写入前)自动订阅;此时真正的异步链才被触发,因此手动调用 `.tofuture().get()` 会因未订阅而返回 null。

在 Spring WebFlux 中,控制器方法返回 Mono 或 Flux 并非表示“立刻获取值”,而是一种声明式契约:你承诺将在某个时刻(通常是响应准备就绪时)提供一个 T 类型的值(或完成信号)。整个响应流程基于 Reactor 的背压与惰性执行模型——所有操作符(如 map、filter、doOnNext)仅在订阅发生后才逐级触发

以你的示例为例:

@GetMapping("/test")
public Mono test() {
    Mono mono = ReactiveSecurityContextHolder.getContext()
        .map(ctx -> (Jwt) ctx.getAuthentication().getPrincipal());

    // ❌ 错误:强制提前阻塞订阅,但此时 Mono 尚未被 WebFlux 订阅
    Jwt jwtFromMono = mono.toFuture().get(); // 可能为 null 或抛出异常(如 TimeoutException)
    System.out.println("jwt value is " + jwtFromMono); // 输出 null

    return mono; // ✅ 正确:返回未订阅的 Mono,交由 WebFlux 处理
}

此处 mono.toFuture().get() 失败的根本原因在于:

  • ReactiveSecurityContextHolder.getContext() 返回的是一个依赖于当前线程绑定的 Mono
  • 在 WebFlux 的非阻塞线程模型中,该上下文仅在 WebFlux 的请求处理线程(如 event loop 线程)中有效且可访问
  • 而 .toFuture().get() 是同步阻塞调用,可能在任意线程(甚至主线程)执行,此时 SecurityContext 尚未传播或已失效,导致 getPrincipal() 返回 null。

✅ 正确做法是完全拥抱响应式编程范式,将副作用(如日志、转换、校验)嵌入到响应式链中:

DubbingX智声云配
DubbingX智声云配

多情绪免费克隆AI音频工具

下载
@GetMapping("/test")
public Mono test() {
    return ReactiveSecurityContextHolder.getContext()
        .switchIfEmpty(Mono.error(new IllegalStateException("Security context is empty")))
        .map(ctx -> {
            Authentication auth = ctx.getAuthentication();
            Object principal = auth != null ? auth.getPrincipal() : null;
            if (!(principal instanceof Jwt)) {
                throw new IllegalArgumentException("Expected Jwt principal, got: " + principal);
            }
            return (Jwt) principal;
        })
        .doOnNext(jwt -> System.out.println("✅ JWT received: " + jwt.getTokenValue()))
        .doOnError(error -> System.err.println("❌ JWT resolution failed: " + error.getMessage()));
}

? WebFlux 背后的关键机制包括

  • 自动订阅:DispatcherHandler 在写出响应体前,对返回的 Mono 调用 subscribe();
  • 线程上下文传播:ReactorContext 与 SecurityContext 通过 Context 与 Hooks 在订阅链中透明传递;
  • 错误统一处理:未捕获异常会自动转为 HTTP 500 响应(可通过 @ControllerAdvice 自定义);
  • 序列化委托:最终值交由 HttpMessageWriter(如 Jackson2JsonEncoder)序列化为 JSON。

⚠️ 注意事项:

  • 切勿在 WebFlux 控制器中调用 .block()、.toFuture().get() 或其他阻塞 API——这会破坏响应式优势,导致线程饥饿与性能坍塌;
  • 若需调试流中值,优先使用 doOnNext()、doOnSubscribe()、log() 等非阻塞钩子;
  • 安全上下文访问必须在 Mono 链内完成,不可脱离响应式流提取原始值。

总之,Spring WebFlux 的“幕后工作”本质是:延迟订阅 + 上下文感知执行 + 声明式错误传播。开发者只需返回纯净的 Mono/Flux,其余均由框架在恰当的时机、线程和上下文中安全完成。

相关专题

更多
spring框架介绍
spring框架介绍

本专题整合了spring框架相关内容,想了解更多详细内容,请阅读专题下面的文章。

101

2025.08.06

json数据格式
json数据格式

JSON是一种轻量级的数据交换格式。本专题为大家带来json数据格式相关文章,帮助大家解决问题。

404

2023.08.07

json是什么
json是什么

JSON是一种轻量级的数据交换格式,具有简洁、易读、跨平台和语言的特点,JSON数据是通过键值对的方式进行组织,其中键是字符串,值可以是字符串、数值、布尔值、数组、对象或者null,在Web开发、数据交换和配置文件等方面得到广泛应用。本专题为大家提供json相关的文章、下载、课程内容,供大家免费下载体验。

531

2023.08.23

jquery怎么操作json
jquery怎么操作json

操作的方法有:1、“$.parseJSON(jsonString)”2、“$.getJSON(url, data, success)”;3、“$.each(obj, callback)”;4、“$.ajax()”。更多jquery怎么操作json的详细内容,可以访问本专题下面的文章。

308

2023.10.13

go语言处理json数据方法
go语言处理json数据方法

本专题整合了go语言中处理json数据方法,阅读专题下面的文章了解更多详细内容。

74

2025.09.10

c语言中null和NULL的区别
c语言中null和NULL的区别

c语言中null和NULL的区别是:null是C语言中的一个宏定义,通常用来表示一个空指针,可以用于初始化指针变量,或者在条件语句中判断指针是否为空;NULL是C语言中的一个预定义常量,通常用来表示一个空值,用于表示一个空的指针、空的指针数组或者空的结构体指针。

231

2023.09.22

java中null的用法
java中null的用法

在Java中,null表示一个引用类型的变量不指向任何对象。可以将null赋值给任何引用类型的变量,包括类、接口、数组、字符串等。想了解更多null的相关内容,可以阅读本专题下面的文章。

435

2024.03.01

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

476

2023.08.10

漫蛙2入口地址合集
漫蛙2入口地址合集

本专题整合了漫蛙2入口汇总,阅读专题下面的文章了解更多详细内容。

162

2026.01.06

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
React 教程
React 教程

共58课时 | 3.4万人学习

国外Web开发全栈课程全集
国外Web开发全栈课程全集

共12课时 | 0.9万人学习

React核心原理新老生命周期精讲
React核心原理新老生命周期精讲

共12课时 | 1万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号