Spring WebClient配置Okta OAuth2

Question

我正在构建一个API网关，它使用Spring Webflow、Spring Cloud Gateway、Spring Cloud Security

这是我的RouteLocator，通过它我可以调用我的Foo Microservice。

@Bean
public RouteLocator routeLocator(RouteLocatorBuilder builder, TokenRelayGatewayFilterFactory filterFactory) {
    return builder.routes()
            .route("foo", r ->
                    r.path("/foo")
                            .filters(f -> f
                                    .rewritePath("/foo", "/api/v1/foo")
                                    .filter(filterFactory.apply()))
                            .uri("lb://foo-service")
            )
            .build();
}

这很好用。

然而，由于我需要聚合不同微服务的结果，比如Foo和Bar，我正在创建一个负载平衡的Spring-WebClient bean，可以用来进行http调用：

@Bean
@LoadBalanced
public WebClient.Builder webClientBuilder() {
    return WebClient.builder();
}

我如何配置WebClient，使其以与RouteLocator中TokenRelayGatewayFilterFactory相同的方式在每个请求上传递令牌？

编辑：

这是我更新的WebClient bean：

@Bean
@LoadBalanced
public WebClient.Builder webClientBuilder(ReactiveClientRegistrationRepository clientRegistrations,
                                          ServerOAuth2AuthorizedClientRepository authorizedClients) {
    var oauth = new ServerOAuth2AuthorizedClientExchangeFilterFunction(clientRegistrations, authorizedClients);
    oauth.setDefaultOAuth2AuthorizedClient(true);
    oauth.setDefaultClientRegistrationId("okta");
    return WebClient
            .builder()
            .filter(oauth);
}

现在它似乎正在开发Chrome浏览器。登录Okta后，我可以通过Http GET访问foo微服务上的/foo。虽然当我通过Postman在/foo上尝试Http POST时（在添加授权标头时），我得到了302响应，将我重定向到Okta html页面。

有趣的是，使用RouteLocator我没有得到任何重定向，GET和POST都通过Postman工作。重定向似乎只在使用WebClient时发生。

知道为什么吗？

编辑#2：

我的安全配置文件：

@Configuration
@EnableWebFluxSecurity
class SecurityConfig {

    @Bean
    public SecurityWebFilterChain securityWebFilterChain(ServerHttpSecurity http) {
        return http
                .csrf().disable()
                .authorizeExchange().anyExchange().authenticated()
                .and()
                .oauth2Login()
                .and()
                .oauth2ResourceServer().jwt()
                .and()
                .and().build();
    }

    @Bean
    CorsWebFilter corsWebFilter(){
        CorsConfiguration corsConfig = new CorsConfiguration();
        corsConfig.setAllowedOrigins(List.of("*"));
        corsConfig.setMaxAge(3600L);
        corsConfig.addAllowedMethod("*");
        corsConfig.addAllowedHeader("*");

        UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
        source.registerCorsConfiguration("/**", corsConfig);

        return new CorsWebFilter(source);
    }
}

Answer 1

看看ServletOAuth2AuthorizedClientExchange eFilterFunction（或反应性等价物）本视频更详细地介绍了它：https://youtu.be/v2J32nd0g24?t=2168