使用RSocket与JWT实现身份认证时ReactiveSecurityContextHolder为空如何解决

解决方案 #

根因说明 #

RSocket的Spring Security上下文基于Reactor的响应式上下文传播机制实现，上下文仅在绑定的响应流链路中有效，你遇到的上下文为空、被标记为discard的问题，本质是业务逻辑的流脱离了安全认证的处理链路，导致上下文丢失。

修复步骤 #

1. 修正SecurityConfig的JWT认证管理器注入方式
   你当前配置中直接调用方法创建JwtReactiveAuthenticationManager实例，未使用Spring容器管理的Bean，会导致安全上下文绑定逻辑失效，修改如下：

// 直接注入Spring容器托管的认证管理器
@Bean
PayloadSocketAcceptorInterceptor authorization(RSocketSecurity security, JwtReactiveAuthenticationManager authManager) {
    return security.authorizePayload(authorize ->
                    authorize
                            .setup().permitAll()
                            .anyExchange().authenticated())
            .jwt(jwt -> jwt.authenticationManager(authManager))
            .build();
}

2. 开启响应式上下文自动传播
   在application.yml中添加配置，开启Reactor上下文自动传播：

spring:
  reactor:
    context-propagation: auto

如果使用低于Spring Boot 3.0的版本，需额外引入io.micrometer:context-propagation依赖。
3. 正确在业务代码中获取上下文
禁止在@MessageMapping方法中调用block()获取上下文，必须将上下文获取逻辑合并到响应流链路中，示例写法：

@MessageMapping("chat.send")
public Flux<ChatMessage> handleSendMessage(ChatMessage message) {
    return ReactiveSecurityContextHolder.getContext()
            .map(SecurityContext::getAuthentication)
            .flatMapMany(auth -> {
                // 此处可正常拿到认证信息
                String userId = auth.getName();
                message.setSenderId(userId);
                return chatService.broadcastMessage(message);
            });
}

4. 检查自定义线程池配置
   如果业务逻辑中使用了自定义线程池/调度器，需要使用支持上下文传播的调度器，或者通过Mono.deferContextual()手动承接上下文，避免跨线程导致上下文丢失。

内容的提问来源于stack exchange，提问作者HongJeongHyeon