forgetest5
/
ifffff
mirror of https://gitee.com/maxjhandsome/pig
1
0
Fork 0
Code Issues Releases Wiki Activity

🎨 Improving structure / format of the code. 格式化代码符合工程规范

This commit is contained in:
lbw 2021-07-13 18:23:35 +08:00
parent 62a216571a
commit 3070c084a3
2 changed files with 11 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pig-common/pig-common-log/src/main/java/com/pig4cloud/pig/common/log/util/SysLogUtils.java
View File

@ -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();
}
}

13
pig-gateway/src/main/java/com/pig4cloud/pig/gateway/filter/ApiLoggingFilter.java
View File

@ -16,8 +16,7 @@ import java.util.List;
* <p>
* 全局拦截器，作用所有的微服务
* <p>
* 1. 对请求的API调用过滤，记录接口的请求时间，方便日志审计、告警、分析等运维操作
* 2. 后期可以扩展对接其他日志系统
* 1. 对请求的API调用过滤，记录接口的请求时间，方便日志审计、告警、分析等运维操作 2. 后期可以扩展对接其他日志系统
* <p>
*/
@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需要配置
@Override
public Mono<Void> 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,7 +43,8 @@ public class ApiLoggingFilter implements GlobalFilter, Ordered {
List<String> 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);