|
|
|
@ -16,12 +16,12 @@ |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
package org.springblade.gateway.filter; |
|
|
|
package org.springblade.gateway.filter; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
import com.alibaba.nacos.common.utils.StringUtils; |
|
|
|
import com.fasterxml.jackson.core.JsonProcessingException; |
|
|
|
import com.fasterxml.jackson.core.JsonProcessingException; |
|
|
|
import com.fasterxml.jackson.databind.ObjectMapper; |
|
|
|
import com.fasterxml.jackson.databind.ObjectMapper; |
|
|
|
import io.jsonwebtoken.Claims; |
|
|
|
import io.jsonwebtoken.Claims; |
|
|
|
import lombok.AllArgsConstructor; |
|
|
|
import lombok.AllArgsConstructor; |
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
import org.apache.commons.lang.StringUtils; |
|
|
|
|
|
|
|
import org.springblade.core.jwt.JwtUtil; |
|
|
|
import org.springblade.core.jwt.JwtUtil; |
|
|
|
import org.springblade.core.jwt.props.JwtProperties; |
|
|
|
import org.springblade.core.jwt.props.JwtProperties; |
|
|
|
import org.springblade.core.launch.constant.TokenConstant; |
|
|
|
import org.springblade.core.launch.constant.TokenConstant; |
|
|
|
@ -36,6 +36,7 @@ import org.springframework.core.io.buffer.DataBuffer; |
|
|
|
import org.springframework.http.HttpStatus; |
|
|
|
import org.springframework.http.HttpStatus; |
|
|
|
import org.springframework.http.server.reactive.ServerHttpResponse; |
|
|
|
import org.springframework.http.server.reactive.ServerHttpResponse; |
|
|
|
import org.springframework.stereotype.Component; |
|
|
|
import org.springframework.stereotype.Component; |
|
|
|
|
|
|
|
import org.springframework.util.AntPathMatcher; |
|
|
|
import org.springframework.web.server.ServerWebExchange; |
|
|
|
import org.springframework.web.server.ServerWebExchange; |
|
|
|
import reactor.core.publisher.Flux; |
|
|
|
import reactor.core.publisher.Flux; |
|
|
|
import reactor.core.publisher.Mono; |
|
|
|
import reactor.core.publisher.Mono; |
|
|
|
@ -54,6 +55,7 @@ public class AuthFilter implements GlobalFilter, Ordered { |
|
|
|
private final AuthProperties authProperties; |
|
|
|
private final AuthProperties authProperties; |
|
|
|
private final ObjectMapper objectMapper; |
|
|
|
private final ObjectMapper objectMapper; |
|
|
|
private final JwtProperties jwtProperties; |
|
|
|
private final JwtProperties jwtProperties; |
|
|
|
|
|
|
|
private final AntPathMatcher antPathMatcher = new AntPathMatcher(); |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) { |
|
|
|
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) { |
|
|
|
@ -89,8 +91,11 @@ public class AuthFilter implements GlobalFilter, Ordered { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
private boolean isSkip(String path) { |
|
|
|
private boolean isSkip(String path) { |
|
|
|
return AuthProvider.getDefaultSkipUrl().stream().map(url -> url.replace(AuthProvider.TARGET, AuthProvider.REPLACEMENT)).anyMatch(path::startsWith) |
|
|
|
return AuthProvider.getDefaultSkipUrl().stream().anyMatch(pattern -> antPathMatcher.match(pattern, path)) |
|
|
|
|| authProperties.getSkipUrl().stream().map(url -> url.replace(AuthProvider.TARGET, AuthProvider.REPLACEMENT)).anyMatch(path::startsWith); |
|
|
|
|| authProperties.getSkipUrl().stream().anyMatch(pattern -> antPathMatcher.match(pattern, path)) |
|
|
|
|
|
|
|
|| authProperties.getAuth().stream().anyMatch(auth -> antPathMatcher.match(auth.getPattern(), path)) |
|
|
|
|
|
|
|
|| authProperties.getBasic().stream().anyMatch(basic -> antPathMatcher.match(basic.getPattern(), path)) |
|
|
|
|
|
|
|
|| authProperties.getSign().stream().anyMatch(sign -> antPathMatcher.match(sign.getPattern(), path)); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
private Mono<Void> unAuth(ServerHttpResponse resp, String msg) { |
|
|
|
private Mono<Void> unAuth(ServerHttpResponse resp, String msg) { |
|
|
|
|
smallchill
3 years ago