Set X-Forwarded-For header

This commit is contained in:
Francis Dong
2023-02-14 10:55:52 +08:00
parent e9e05f08a9
commit 6e359c5e6b

View File

@@ -134,11 +134,10 @@ public class AggregateFilter implements WebFilter {
Input input = aggregateResource.getInput(); Input input = aggregateResource.getInput();
HttpHeaders hds = request.getHeaders(); HttpHeaders hds = request.getHeaders();
if (CollectionUtils.isEmpty(hds.get(X_FORWARDED_FOR)) && systemConfig.isFizzWebClientXForwardedForEnable()) {
hds.add(X_FORWARDED_FOR, WebUtils.getOriginIp(exchange));
}
Map<String, Object> headers = MapUtil.headerToHashMap(hds); Map<String, Object> headers = MapUtil.headerToHashMap(hds);
if (CollectionUtils.isEmpty(hds.get(X_FORWARDED_FOR)) && systemConfig.isFizzWebClientXForwardedForEnable()) {
headers.put(X_FORWARDED_FOR, WebUtils.getOriginIp(exchange));
}
Map<String, Object> fizzHeaders = (Map<String, Object>) exchange.getAttributes().get(WebUtils.APPEND_HEADERS); Map<String, Object> fizzHeaders = (Map<String, Object>) exchange.getAttributes().get(WebUtils.APPEND_HEADERS);
if (fizzHeaders != null && !fizzHeaders.isEmpty()) { if (fizzHeaders != null && !fizzHeaders.isEmpty()) {
Set<Entry<String, Object>> entrys = fizzHeaders.entrySet(); Set<Entry<String, Object>> entrys = fizzHeaders.entrySet();