如何为WebFlux安全配置2步滤波器链

Question

我需要支持两种类型的auth：

1. 信任系统，其中令牌由自动配置过滤器注入。
2. 像用户类用户一样，我们从内部应用程序获得令牌并测试我们的服务返回的内容。这仅在我们的Corp网络中起作用（如果细节很重要）。

我的任务是以某种方式验证服务器端的令牌，如果两个方法有效，则应允许访问。

我的初始（幼稚）实现的代码证明了该功能：

RemoteAddressSource remoteAddressSource = new WebFluxRemoteAddressSource(exchange);
        return validateNotBlank(token)
                .switchIfEmpty(Mono.defer(() -> iafTokenValidator.validateToken(remoteAddressSource)
                        .onErrorResume(AuthenticationFailedException.class, e -> tfTokenValidator.validateToken(remoteAddressSource))))
                .onErrorResume(AuthenticationFailedException.class, e -> sendErrorResponse(e, exchange))
                .switchIfEmpty(chain);

在工作和否认并允许预期的情况下，这种方法有几个问题：

1. 这对两种形式的身份验证，而不是为他们提供2个类。
2. 如果无效，最终用户总是“查看”后一个错误消息，而它可能源于第一个方法。
3. 我敢肯定，有一种正确配置的过滤链可以做到这一点，尽管我尚未找到这一点。

Answer 1

我想出了一些有效的东西，尽管我对此不满意。

我想要一个解决方案，在该解决方案中，令牌可以通过这两个选项运行，并且如果验证了请求，但是我希望它们完全分开和彼此遗忘，这是我通过Tokenauthmanager部分实现的。

不过，当无信任表格被弃用时，我们需要更改authmanager，而不仅仅是删除此代码。

另外，我不喜欢IF语句，并尝试/捕获/捕获块以与反应式操作员进行例外处理，因此仍然不理想。

至少它是1堂课，所以我们不是在看很多工作：

 @Override
    public Mono<Authentication> authenticate(Authentication authentication) {
        ServiceAuthentication serviceAuthentication = (ServiceAuthentication) authentication;
        String stripped = serviceAuthentication.getCredentials().toString().replaceAll("Bearer ", "").trim();
        try {
            ServicePrincipal principal = stv.validate(stripped, (String) serviceAuthentication.getDetails());
            log.debug("client {} from ip {} allowed", principal.getName(), authentication.getDetails());
            //if this is valid, return
            authentication.setAuthenticated(true);
            return Mono.just(authentication);
        } catch (TokenException e) {
            log.debug("token {} invalid for TF", authentication.getCredentials());
            if (serviceAuthentication.isPureTf()) {
                return Mono.error(new BadCredentialsException("The provided TF token is invalid", e));
            }
            return iafTokenValidator.authenticate(serviceAuthentication);
        }
    }