spring - Spring WebFlux 中的 ReactiveSecurityContextHolder 为空
问题描述
我正在尝试将 ReactiveSecurityContextHolder 与 Spring WebFlux 一起使用。不幸的是,SecurityContext 是空的:
@Configuration
public class Router {
@Bean
public RouterFunction<ServerResponse> routes(Handler handler) {
return nest(
path("/bill"),
route(
GET("/").and(accept(APPLICATION_JSON)), handler::all));
}
@Component
class Handler {
Mono<ServerResponse> all(ServerRequest request) {
ReactiveSecurityContextHolder.getContext()
.switchIfEmpty(Mono.error(new IllegalStateException("ReactiveSecurityContext is empty")))
.map(SecurityContext::getAuthentication)
.map(Authentication::getName)
.flatMap(s -> Mono.just("Hi " + s))
.subscribe(
System.out::println,
Throwable::printStackTrace,
() -> System.out.println("completed without a value")
);
return ok().build();
}
}
}
此代码总是抛出 IllegalStateException。
如果我添加一个如下所示的subscriberContext:
Authentication authentication = new TestingAuthenticationToken("admin", "password", "ROLE_ADMIN");
ReactiveSecurityContextHolder.getContext()
.switchIfEmpty(Mono.error(new IllegalStateException("ReactiveSecurityContext is empty")))
.map(SecurityContext::getAuthentication)
.map(Authentication::getName)
.flatMap(s -> Mono.just("Hi " + s))
.subscriberContext(ReactiveSecurityContextHolder.withAuthentication(authentication))
.subscribe(
System.out::println,
Throwable::printStackTrace,
() -> System.out.println("completed without a value")
);
它工作正常并打印“嗨管理员”。但这不是重点,文章说“在 WebFlux 应用程序subscriberContext
中自动设置使用ReactorContextWebFilter
”。所以我应该能够获取登录的用户。
我有这个配置:
@EnableWebFluxSecurity
@EnableReactiveMethodSecurity
public class SecurityConfig {
@Bean
public SecurityWebFilterChain securityWebFilterChain(ServerHttpSecurity http) {
return http.authorizeExchange()
.anyExchange().authenticated()
.and().formLogin()
.and().build();
}
@Bean
public MapReactiveUserDetailsService userDetailsService() {
UserDetails user = User.withDefaultPasswordEncoder()
.username("user")
.password("password")
.roles("USER")
.build();
UserDetails admin = User.withDefaultPasswordEncoder()
.username("admin")
.password("password")
.roles("ADMIN")
.build();
return new MapReactiveUserDetailsService(user, admin);
}
}
我在这里错过了什么吗?如果我在 ReactorContextWebFilter 中放置断点,我可以看到它在每个请求之前被正确调用。但我的 ReactiveSecurityContextHolder 总是空的......
解决方案
您必须返回要在其中访问ReactiveSecurityContextHolder的流。您不允许在另一个流中订阅,或者您必须手动执行 Reactor 上下文切换。
@Component
class Handler {
Mono<ServerResponse> all(ServerRequest request) {
return ReactiveSecurityContextHolder.getContext()
.switchIfEmpty(Mono.error(new IllegalStateException("ReactiveSecurityContext is empty")))
.map(SecurityContext::getAuthentication)
.map(Authentication::getName)
.flatMap(s -> Mono.just("Hi " + s))
.doOnNext(System.out::println)
.doOnError(Throwable::printStackTrace)
.doOnSuccess(s -> System.out.println("completed without value: " + s))
.flatMap(s -> ServerResponse.ok().build());
}
}
推荐阅读
- wordpress - WordPress.org 添加低级代码/添加外部 API?
- c++ - C++:constexpr 对变量暗示隐式 const 不适用于引用
- python - 关系字段Many2one和One2many中的AttributeError
- google-apps-script - 在谷歌应用脚本中的特定行之间添加行
- django - Django,模板。无法在 if 语句中传递变量
- javascript - 我在哪里为我的网站上传套接字 io 服务器 javascript 文件?
- ssh - 将 SSH 端口 22 更改为 800
- python - Series.str.split 返回 NaN 和意外的数据类型
- wordpress - 更改某个 WooCommerce 产品(ID)的“商店基地”标签
- javascript - Selenium IDE Chrome 替代 echo || javascript{警报('文本')}