高并发下响应式流的统一状态码装配应采用mono而非wrapper，在流链路中通过map/onerrorresume/switchifempty提前注入code/msg，结合subscribercontext传递上下文，并提供successmono等工具方法简化使用。
高并发场景下，用流包装配合泛型 Wrapper 实现统一状态码动态装配，关键不是“把流塞进 Wrapper”，而是让 Wrapper 能安全承载异步/流式响应数据，同时在非阻塞流程中完成状态码的上下文感知装配。Spring WebFlux 或 Project Reactor 环境中，Mono<t></t> 和 Flux<t></t> 是主流响应类型，此时 Wrapper 仍为容器，但构造和装配时机需前移至流链路中，而非 Controller 方法返回那一刻。
Wrapper 类本身无需为流特化，但需兼容泛型流元素类型
泛型 Wrapper<t></t> 的 T 可以是 User、List<user></user>，自然也包括 Mono<user></user> 或 Flux<order></order>——只要不破坏泛型语义，就符合设计原则。重点在于：
- 不要把
Wrapper<mono>></mono>当作标准写法（这表示“一个包装了 Mono 的 Wrapper”，语义错位） - 正确做法是：
Mono<wrapper>></wrapper>，即“一个发出 Wrapper 的 Mono”，data 字段仍是User，状态码在流订阅前或 onErrorResume 时注入
在流链路中动态装配状态码，而不是等结果出来再包
不能等到 Mono<user></user> 发出 User 实例后，再调 Wrapper.success(user)。而应在流定义阶段，根据业务逻辑分支提前决定 code/msg，并用 map / onErrorResume / switchIfEmpty 注入：
return userService.findById(id)
.map(user -> Wrapper.success(user)) // 成功路径：200 + data
.switchIfEmpty(Mono.just(Wrapper.fail(404, "用户不存在"))) // 空结果：404
.onErrorResume(UserNotFoundException.class,
e -> Mono.just(Wrapper.fail(e.getCode(), e.getMsg()))) // 业务异常：取枚举码
.onErrorResume(Throwable.class,
t -> Mono.just(Wrapper.fail(500, "系统繁忙，请稍后再试"))); // 兜底
全局响应增强需适配响应式类型，不能照搬 RestControllerAdvice@ResponseBodyAdvice 在 WebFlux 中对应的是 ResponseBodyAdvice 的响应式实现，但 Spring 默认不支持对 Mono<wrapper>></wrapper> 自动增强（因已是 Wrapper）。真正要拦截的是裸 Mono<user></user> 或 Flux<order></order>。因此建议：
- 实现
ResponseBodyAdvice<object></object>时，在supports()中明确排除Mono/Flux类型，避免干扰响应式流 - 对响应式流的统一封装，应由 自定义 WebFilter 或 ExchangeStrategies 配置 承担，或更推荐：封装通用流工具方法
提供流友好的静态工厂与组合工具
在 Wrapper 类中补充响应式支持方法，降低使用门槛：
// 工具方法，返回 Mono<wrapper>>
public static <t> Mono<wrapper>> successMono(Mono<t> source) {
return source.map(Wrapper::success).defaultIfEmpty(Wrapper.success(null));
}
// 失败流：直接生成失败 Wrapper 的 Mono
public static <t> Mono<wrapper>> failMono(int code, String msg) {
return Mono.just(Wrapper.fail(code, msg));
}
// 与业务异常联动
public static <t> Mono<wrapper>> fromBizException(Mono<t> source, Function<bizexception wrapper>> mapper) {
return source.onErrorResume(BizException.class, e -> Mono.just(mapper.apply(e)));
}</bizexception></t></wrapper></t></wrapper></t></t></wrapper></t></wrapper>
这样 Controller 可简洁表达：
@GetMapping("/user/{id}")
public Mono<wrapper>> getUser(@PathVariable Long id) {
return Wrapper.successMono(userService.findById(id))
.onErrorResume(e -> Wrapper.failMono(500, "查询失败"));
}</wrapper>
注意线程上下文与状态码来源的一致性
高并发下，ThreadLocal 不适用于 Reactor 线程切换场景（如 publishOn(Schedulers.boundedElastic())），状态码若依赖请求参数、认证信息等，应通过 ServerWebExchange 或 Mono.subscriberContext() 传递：
return exchange.getPrincipal()
.flatMap(principal -> userService.findByPrincipal(principal))
.map(Wrapper::success)
.switchIfEmpty(Wrapper.failMono(401, "未登录"))
.subscriberContext(ctx -> ctx.put("traceId", exchange.getRequest().getId()));
本质上，高并发流包装不改变 Wrapper 的泛型本质，只改变装配发生的阶段与方式：从“同步返回后包装”，变为“流定义期声明性装配”。状态码动态性来自对流事件（onNext/onError/onComplete）的响应，而非 if-else 分支。
不复杂但容易忽略
