|
@@ -17,6 +17,7 @@ import org.springframework.core.io.buffer.DataBuffer;
|
|
|
import org.springframework.http.HttpHeaders;
|
|
|
import org.springframework.http.HttpMethod;
|
|
|
import org.springframework.http.HttpStatus;
|
|
|
+import org.springframework.http.MediaType;
|
|
|
import org.springframework.http.server.reactive.ServerHttpResponse;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
import org.springframework.web.server.ServerWebExchange;
|
|
@@ -123,11 +124,13 @@ public class JwtTokenFilter implements GlobalFilter, Ordered {
|
|
|
}
|
|
|
|
|
|
map.put("success", false);
|
|
|
- log.error("认证错误: {}", map.toJSONString());
|
|
|
-
|
|
|
- return authError(resp, map.toJSONString());
|
|
|
+ exchange.getResponse().getHeaders().setContentType(MediaType.APPLICATION_JSON);
|
|
|
+ return exchange.getResponse()
|
|
|
+ .writeWith(Mono.just(exchange.getResponse()
|
|
|
+ .bufferFactory()
|
|
|
+ .wrap(map.toJSONString().getBytes())));
|
|
|
}
|
|
|
- return chain.filter(exchange);
|
|
|
+ return allowChain(exchange, chain);
|
|
|
} catch (ExpiredJwtException e) {
|
|
|
if (e.getMessage().contains("Allowed clock skew")) {
|
|
|
log.error("认证过期", e);
|