Programmiererforum

@Service
public class TokenFilter {
public TokenFilter(WebClient.Builder webClientBuilder, RequestCache requestCache) {
this.webClientBuilder = webClientBuilder;
this.requestCache = requestCache;
}

public ExchangeFilterFunction renewTokenFilter() {
return (request, next) -> {

LOG.info("outbound request path: {}", request.url().getPath());
// I do some processing here.  What is the way to get the inbound request?

return processTokenFilter(request, next);

};
}
}

< /code>
Die Klasse ist wie folgt mit einem Webclient -Builder verdrahtet: < /p>
@Configuration
public class WebClientFilterConfig {
private static final Logger LOG = LoggerFactory.getLogger(WebClientFilterConfig.class);

@Autowired
private WebClient.Builder webClientBuilder;

@Autowired
private TokenFilter tokenFilter;

@PostConstruct
public void addFilterToWebClient() {
LOG.info("configure the renewTokenFilter only once in this config");
webClientBuilder.filter(tokenFilter.renewTokenFilter()).build();
}
}

Ich habe eine TokenFilter -Klasse mit einer Methode, die eine ExchangeFilterFunction in meiner API zurückgibt, die SpringFramework verwendet. In der Methode enthält eine Anforderung Variable für die ausgehende Anforderung, in der ich einen OAuth2-Acccess in einen Autorisierungsheader einlasse. [url=viewtopic.php?t=14917]Ich möchte[/url] jedoch auf die eingehende Anfrage zugreifen, die einen ausgehenden HTTP -Aufruf mit einem Webclient auslöst und die Methode des TokenFilter RenewTokenFilter aufgerufen wird. Das Folgende ist ein Beispiel meines Codes: < /p>
[code]@Service
public class TokenFilter {
public TokenFilter(WebClient.Builder webClientBuilder, RequestCache requestCache) {
this.webClientBuilder = webClientBuilder;
this.requestCache = requestCache;
}

public ExchangeFilterFunction renewTokenFilter() {
return (request, next) -> {

LOG.info("outbound request path: {}", request.url().getPath());
// I do some processing here. What is the way to get the inbound request?

return processTokenFilter(request, next);

};
}
}

< /code>
Die Klasse ist wie folgt mit einem Webclient -Builder verdrahtet: < /p>
@Configuration
public class WebClientFilterConfig {
private static final Logger LOG = LoggerFactory.getLogger(WebClientFilterConfig.class);

@Autowired
private WebClient.Builder webClientBuilder;

@Autowired
private TokenFilter tokenFilter;

@PostConstruct
public void addFilterToWebClient() {
LOG.info("configure the renewTokenFilter only once in this config");
webClientBuilder.filter(tokenFilter.renewTokenFilter()).build();
}
}
[/code]