GateWay部分接口理解之GatewayFilter、GlobalFilter
1 public interface GlobalFilter { 2 Monofilter(ServerWebExchange exchange, GatewayFilterChain chain); 3 }
全局过滤器
当网关模块,我们定义filter时,首先需要实现上述接口,并加入到spring容器中 ,filter按自己业务是否需要 @Order/接口形式来指定执行的顺序,数字越小,优先级越高。
@Component
public class IPCheckFilter implements GlobalFilter, Ordered {
@Override
public int getOrder() {
return 0;
}
@Override
public Mono filter(ServerWebExchange exchange, GatewayFilterChain chain) {
// 获取请求头
HttpHeaders headers = exchange.getRequest().getHeaders();
// 根据ip来进行对比
if (getIp(headers).equals("黑名单ip")) {
ServerHttpResponse response = exchange.getResponse();
ResponseData data = new ResponseData();
data.setCode(401);
data.setMessage("非法请求,请联系管理员");
byte[] datas = JsonUtils.toJson(data).getBytes(StandardCharsets.UTF_8);
DataBuffer buffer = response.bufferFactory().wrap(datas);
response.setStatusCode(HttpStatus.UNAUTHORIZED);
response.getHeaders().add("Content-Type", "application/json;charset=UTF-8");
return response.writeWith(Mono.just(buffer));
}
return chain.filter(exchange);
}
}
-----------------------------------------------------------------------------------------------------------
public interface GatewayFilter extends ShortcutConfigurable {}
一般是结合AbstractGatewayFilterFactory来做部分模块自定义过滤的
public class ValidateCodeFilter extends AbstractGatewayFilterFactory
spring:
cloud:
gateway:
routes:
# 认证中心
- id: ruoyi-auth
uri: lb://ruoyi-auth
predicates:
- Path=/auth/**
filters:
# 验证码处理
- CacheRequestFilter
- ValidateCodeFilter
- StripPrefix=1
此项目学习,参考的若依框架!!!