update 优化 将web相关的过滤器改为使用WebFilter接口实现

dev
疯狂的狮子Li 10 months ago
parent 35f141b001
commit ba477a944b

@ -1,24 +1,24 @@
package org.dromara.gateway.filter; package org.dromara.gateway.filter;
import org.dromara.gateway.utils.WebFluxUtils; import org.dromara.gateway.utils.WebFluxUtils;
import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.cloud.gateway.support.ServerWebExchangeUtils; import org.springframework.cloud.gateway.support.ServerWebExchangeUtils;
import org.springframework.core.Ordered; import org.springframework.core.Ordered;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange; import org.springframework.web.server.ServerWebExchange;
import org.springframework.web.server.WebFilter;
import org.springframework.web.server.WebFilterChain;
import reactor.core.publisher.Mono; import reactor.core.publisher.Mono;
/** /**
* body * body
* *
* @author Lion Li * @author Lion Li
*/ */
@Component @Component
public class GlobalCacheRequestFilter implements GlobalFilter, Ordered { public class WebCacheRequestFilter implements WebFilter, Ordered {
@Override @Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) { public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
// 只缓存json类型请求 // 只缓存json类型请求
if (!WebFluxUtils.isJsonRequest(exchange)) { if (!WebFluxUtils.isJsonRequest(exchange)) {
return chain.filter(exchange); return chain.filter(exchange);

@ -20,7 +20,7 @@ import reactor.core.publisher.Mono;
* @author Lion Li * @author Lion Li
*/ */
@Component @Component
public class GlobalCorsFilter implements WebFilter, Ordered { public class WebCorsFilter implements WebFilter, Ordered {
/** /**
* header * header

@ -1,13 +1,13 @@
package org.dromara.gateway.filter; package org.dromara.gateway.filter;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.context.i18n.LocaleContextHolder; import org.springframework.context.i18n.LocaleContextHolder;
import org.springframework.context.i18n.SimpleLocaleContext; import org.springframework.context.i18n.SimpleLocaleContext;
import org.springframework.core.Ordered; import org.springframework.core.Ordered;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange; import org.springframework.web.server.ServerWebExchange;
import org.springframework.web.server.WebFilter;
import org.springframework.web.server.WebFilterChain;
import reactor.core.publisher.Mono; import reactor.core.publisher.Mono;
import java.util.Locale; import java.util.Locale;
@ -19,10 +19,10 @@ import java.util.Locale;
*/ */
@Slf4j @Slf4j
@Component @Component
public class GlobalI18nFilter implements GlobalFilter, Ordered { public class WebI18nFilter implements WebFilter, Ordered {
@Override @Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) { public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
String language = exchange.getRequest().getHeaders().getFirst("content-language"); String language = exchange.getRequest().getHeaders().getFirst("content-language");
Locale locale = Locale.getDefault(); Locale locale = Locale.getDefault();
if (language != null && language.length() > 0) { if (language != null && language.length() > 0) {
Loading…
Cancel
Save