无法使用webclient调用响应在映射中设置值

Question

在进行web客户端调用并使用前一个Mono的响应后，我无法在映射中获得填充值。以下是我所尝试的代码。parameters.size（）的值为零。无法获得该值未被文件化的原因。我基本上希望从该方法返回年龄（而不是单对象）。使用block给出一个错误block()/blockfirst（）/blocklast（）是blocking，这在thread Reactor-http-nio-3中是不支持的。

Map<String, String> parameters = new HashMap<String,String>();
 Mono<Person> obj = webClient
    .post()
    .uri("dummy url")
    .accept(MediaType.APPLICATION_JSON, MediaType.APPLICATION_XML)
    .retrieve()
    .bodyToMono(Person.class)
 .flatMap(resp -> {
 parameters.put("name", resp.getName());
 parameters.put("age", resp.getAge());
 return Mono.just(new Person(resp.getName(),resp.getAge()));        
 }

     );

system.out.println（parameters.size（））；

请建议哪里我是错误的和解决办法，以修复相同。

Answer 1

因为这是关于收集和使用从以前的HTTP调用中收集的某种令牌，所以最好的办法是将所有这些委托给ExchangeFilterFunction。

ExchangeFilterFunction是在客户端为每个传出请求执行的筛选器。下面是这样一个过滤器的一个非常非常幼稚的实现：

class TokenFilterFunction implements ExchangeFilterFunction {

    private final AtomicReference<String> token = new AtomicReference<>();

    @Override
    public Mono<ClientResponse> filter(ClientRequest req, ExchangeFunction next) {
        if (this.token.get() == null) {
            return fetchToken(next).then(sendRequest(req, next));
        }
        else {
            return sendRequest(req, next);
        }
    }

    private Mono<ClientResponse> sendRequest(ClientRequest req, ExchangeFunction next) {
        ClientRequest request = ClientRequest.from(req)
                .header("Token", this.token.get()).build();
        return next.exchange(request);
    }

    private Mono<Void> fetchToken(ExchangeFunction next) {
        ClientRequest tokenRequest = ClientRequest.create(HttpMethod.GET,
                URI.create("https://example.com/token")).build();
        return next.exchange(tokenRequest).doOnNext(res -> {
            this.token.set(res.headers().header("Token").get(0));
        }).then();
    }
}

这可以在需要时自动调用令牌endpoint来获取令牌，并直接与您首先请求的请求链接在一起。同样，这样的实现应该比处理域、错误等复杂得多。

如果您正在使用某种身份验证技术，这样的过滤器可能已经在Spring Security中以更好的方式实现了。

您可以在构建阶段在客户机上配置它，例如：

WebClient webClient = WebClient.builder().filter(new TokenFilterFunction()).build();