我正在嘗試使用自定義過濾器使用 Spring Cloud Gateway 創(chuàng)建網(wǎng)關(guān)代理路由器。當以阻塞和命令的方式覆蓋屬性時，一切都按預期工作。exchange.getAttributes().put(GATEWAY_REQUEST_URL_ATTR, URI.create("https://" + newTargetURLHost + )字符串變量 newTargetURLHost 是通過使用獲得的：newTarget = serviceReturnsMono.getServerMapping(id).block().getHost();我是 Webflux 的新手，但上面這行代碼對我來說已經(jīng)是一種代碼味道了。進一步閱讀后，這不是使用反應式的最佳方法。我試圖以更具功能性/反應性的方式重寫，但未能讓反應流發(fā)出所需的值。Mono.just(serviceReturnsMono.getServerMapping(id))                    .flatMap(flat -> flat)                    .subscribeOn(Schedulers.immediate())                    .map(server -> exchange.getAttributes().put(GATEWAY_REQUEST_URL_ATTR, URI.create("https://" + server.getHost() ))                    .subscribe();當上面的代碼執(zhí)行時，exchange 屬性不會發(fā)生變化。我也嘗試了以下但沒有成功：            serverMappingMono                   .map(serverMapping -> exchange.getAttributes().put(GATEWAY_REQUEST_URL_ATTR, URI.create("https://" + serverMapping.getHost() ))                    .subscribe();作為測試，當我修改下面的代碼進行故障排除時，下面確實發(fā)出了一個硬編碼字符串并且交換屬性發(fā)生了變化。                    .map(server -> exchange.getAttributes().put(GATEWAY_REQUEST_URL_ATTR, URI.create("https://" + "testHostName" ))                    .subscribe();任何想法或指示將不勝感激。更新：過濾代碼如下：    private ReturnsMonoServerMappingService returnsMonoServerMappingService;    @Override    public int getOrder() {        return 10001;    }    @Override    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {        final String id = exchange.getRequest().getHeaders().getFirst("reference");        return chain.filter(exchange).then(Mono.fromRunnable(() -> {            Mono<ServerMapping> serverMapping = returnsMonoServerMappingService.getServerMapping(id);            serverMapping                    .map(server -> exchange.getAttributes().put(GATEWAY_REQUEST_URL_ATTR, URI.create("https://" + server.getHost()  )))                    .subscribe();        }));    }}我忽略的缺失部分是“doOnSuccess”，因為 returnsMonoServerMappingService 已經(jīng)返回一個單聲道。然后通過“then”鏈接交換以委托給鏈中的下一個過濾器。