diff --git a/pig-common/pig-common-log/src/main/java/com/pig4cloud/pig/common/log/util/SysLogUtils.java b/pig-common/pig-common-log/src/main/java/com/pig4cloud/pig/common/log/util/SysLogUtils.java index 432554cd168fd81c9385acbc803092ff71cf2440..da3a6d0b4f132ec561b14d25085ee8053f79e961 100755 --- a/pig-common/pig-common-log/src/main/java/com/pig4cloud/pig/common/log/util/SysLogUtils.java +++ b/pig-common/pig-common-log/src/main/java/com/pig4cloud/pig/common/log/util/SysLogUtils.java @@ -58,7 +58,6 @@ public class SysLogUtils { /** * 获取客户端 - * * @return clientId */ private String getClientId(HttpServletRequest request) { @@ -69,7 +68,8 @@ public class SysLogUtils { } if (authentication instanceof UsernamePasswordAuthenticationToken) { BasicAuthenticationConverter basicAuthenticationConverter = new BasicAuthenticationConverter(); - UsernamePasswordAuthenticationToken usernamePasswordAuthenticationToken = basicAuthenticationConverter.convert(request); + UsernamePasswordAuthenticationToken usernamePasswordAuthenticationToken = basicAuthenticationConverter + .convert(request); if (usernamePasswordAuthenticationToken != null) { return usernamePasswordAuthenticationToken.getName(); } @@ -79,7 +79,6 @@ public class SysLogUtils { /** * 获取用户名称 - * * @return username */ private String getUsername() { @@ -89,4 +88,5 @@ public class SysLogUtils { } return authentication.getName(); } + } \ No newline at end of file diff --git a/pig-gateway/src/main/java/com/pig4cloud/pig/gateway/filter/ApiLoggingFilter.java b/pig-gateway/src/main/java/com/pig4cloud/pig/gateway/filter/ApiLoggingFilter.java index 8a588685b463ff535a32ab86a6e36e59ae101d9f..c8a9059a9c59f0080760298e59e9fc89e8178422 100644 --- a/pig-gateway/src/main/java/com/pig4cloud/pig/gateway/filter/ApiLoggingFilter.java +++ b/pig-gateway/src/main/java/com/pig4cloud/pig/gateway/filter/ApiLoggingFilter.java @@ -16,8 +16,7 @@ import java.util.List; *

* 全局拦截器,作用所有的微服务 *

- * 1. 对请求的API调用过滤,记录接口的请求时间,方便日志审计、告警、分析等运维操作 - * 2. 后期可以扩展对接其他日志系统 + * 1. 对请求的API调用过滤,记录接口的请求时间,方便日志审计、告警、分析等运维操作 2. 后期可以扩展对接其他日志系统 *

*/ @Slf4j @@ -25,15 +24,14 @@ import java.util.List; public class ApiLoggingFilter implements GlobalFilter, Ordered { private static final String START_TIME = "startTime"; - private static final String X_REAL_IP = "X-Real-IP";//nginx需要配置 + + private static final String X_REAL_IP = "X-Real-IP";// nginx需要配置 @Override public Mono filter(ServerWebExchange exchange, GatewayFilterChain chain) { String info = String.format("Method:{%s} Host:{%s} Path:{%s} Query:{%s}", - exchange.getRequest().getMethod().name(), - exchange.getRequest().getURI().getHost(), - exchange.getRequest().getURI().getPath(), - exchange.getRequest().getQueryParams()); + exchange.getRequest().getMethod().name(), exchange.getRequest().getURI().getHost(), + exchange.getRequest().getURI().getPath(), exchange.getRequest().getQueryParams()); if (log.isDebugEnabled()) { log.debug(info); } @@ -45,8 +43,9 @@ public class ApiLoggingFilter implements GlobalFilter, Ordered { List ips = exchange.getRequest().getHeaders().get(X_REAL_IP); String ip = ips != null ? ips.get(0) : null; String api = exchange.getRequest().getURI().getRawPath(); - int code = exchange.getResponse().getStatusCode() != null ? exchange.getResponse().getStatusCode().value() : 500; - //当前仅记录日志,后续可以添加日志队列,来过滤请求慢的接口 + int code = exchange.getResponse().getStatusCode() != null + ? exchange.getResponse().getStatusCode().value() : 500; + // 当前仅记录日志,后续可以添加日志队列,来过滤请求慢的接口 if (log.isDebugEnabled()) { log.debug("来自IP地址:{}的请求接口:{},响应状态码:{},请求耗时:{}ms", ip, api, code, executeTime); }