Spring Cloud Gateway添加标头，使用响应WebClient

Question

我正在开发一个带有Spring Cloud的网关，我需要拦截消耗Oauth的请求，然后获取响应并添加带有jwt值的标头（Ouath的响应）

我的筛选代码：

@Autowired
private IConsumoInstrospectService consumoIntrospect;

@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {

    Mono<ResponseIntrospectDTO> rep = consumoIntrospect
            .callInstrospect("firmaCnLlavePrivada", "getAccessToken()","getScope()", "IN");
    // How Can I get the value?
    String token=rep.block().getJwt();
    
    //String token="x";
    
    log.info("token "+token);
    String authHeader = "Bearer " +token ;

    ServerHttpRequest mutatedRequest = exchange.getRequest().mutate().header(HttpHeaders.AUTHORIZATION, authHeader)
            .build();
    exchange = exchange.mutate().request(mutatedRequest).build();
    return chain.filter(exchange);
}

我的服务：

@Value("${endPoint}")
private String endPoint;

@Bean
public WebClient getWebClient() {
    return WebClient.builder().build();
}

@Override
public Mono<ResponseIntrospectDTO> callInstrospect(String Jwt, String AccessToken, String Scope, String tipoAccessToken) {
    HttpHeaders headers = new HttpHeaders();
    headers.add("Content_Type", "application/x-www-form-urlencoded");
    headers.add(AUTHORIZATION, "Bearer " + Jwt);
    headers.add("need-jwt", "yes");

    LinkedMultiValueMap<String, String> body = new LinkedMultiValueMap<String, String>();
    body.add("token", AccessToken);
    body.add("token_type_hint", "access_token");
    body.add("iss", Scope);

    Mono<ResponseIntrospectDTO> respService= getWebClient().post()
            .uri(endPoint)
            .accept(MediaType.APPLICATION_JSON)
            .body(BodyInserters.fromFormData(body))
            .headers(x -> x.addAll(headers))
            .acceptCharset(StandardCharsets.UTF_8)
            .retrieve()
            .bodyToMono(ResponseIntrospectDTO.class);
    return respService;
}

完整代码Gitlab

错误：

java.lang.IllegalStateException：块（）/块第一（）/块最后（）被阻塞，线程reactor-超文本传输协议-nio-3不支持

当我使用String token=rep.block（）时。getJwt（）；

Answer 1

Reactor不允许在并行调度程序中使用块。试着让你的代码反应。

下面是一个从过滤器中的身份验证令牌中提取属性并将其添加到标头的示例

   @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        return ReactiveSecurityContextHolder.getContext()
                .filter(c -> c.getAuthentication() != null)
                .flatMap(c -> {
                    JwtAuthenticationToken jwt = (JwtAuthenticationToken) c.getAuthentication();

                    String tokenTenant = (String) jwt.getTokenAttributes().get("tenant");
                    if (Strings.isNullOrEmpty(tokenTenant)) {
                        return Mono.error(
                                new AccessDeniedException("Invalid token. Tenant is not present in token.")
                        );
                    }

                    ServerHttpRequest request = exchange.getRequest().mutate()
                            .header("x-tenant", tokenTenant).build();

                    return chain.filter(exchange.mutate().request(request).build());
                })
                .switchIfEmpty(chain.filter(exchange));
    }