Commit ea44ecfe authored by 赵啸非's avatar 赵啸非

网关日志添加

parent c2de36ad
package com.mortals.xhx.base.framework.filter; package com.mortals.xhx.base.framework.filter;
import cn.hutool.core.util.IdUtil;
import com.mortals.framework.service.IAuthTokenService;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.slf4j.MDC; import org.slf4j.MDC;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.util.ObjectUtils;
import org.springframework.web.filter.OncePerRequestFilter; import org.springframework.web.filter.OncePerRequestFilter;
import org.springframework.web.util.ContentCachingRequestWrapper; import org.springframework.web.util.ContentCachingRequestWrapper;
...@@ -23,19 +19,13 @@ import java.io.IOException; ...@@ -23,19 +19,13 @@ import java.io.IOException;
* @author: zxfei * @author: zxfei
* @date: 2022/4/20 14:52 * @date: 2022/4/20 14:52
*/ */
//@Component @Component
@Slf4j @Slf4j
public class RequestFilter extends OncePerRequestFilter implements Filter { public class RequestFilter extends OncePerRequestFilter implements Filter {
@Autowired
private IAuthTokenService authTokenService;
@Override @Override
protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain) throws ServletException, IOException { protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain) throws ServletException, IOException {
try { try {
//每个请求记录一个traceId,可以根据traceId搜索出本次请求的全部相关日志
MDC.put("traceId", IdUtil.fastSimpleUUID().substring(0,12));
setUsername(request);
request = new ContentCachingRequestWrapper(request); request = new ContentCachingRequestWrapper(request);
filterChain.doFilter(request, response); filterChain.doFilter(request, response);
} catch (Exception e) { } catch (Exception e) {
...@@ -47,22 +37,22 @@ public class RequestFilter extends OncePerRequestFilter implements Filter { ...@@ -47,22 +37,22 @@ public class RequestFilter extends OncePerRequestFilter implements Filter {
} }
private void setUsername(HttpServletRequest request) { /*private void setUsername(HttpServletRequest request) {
//通过token解析出username //通过token解析出username
String token = authTokenService.getToken(request); String token = authTokenService.getToken(request);
//String token = request.getHeader("token"); //String token = request.getHeader("token");
if (!ObjectUtils.isEmpty(token)) { if (!ObjectUtils.isEmpty(token)) {
MDC.put("token",token); MDC.put("token",token);
// MDC.put("token", token); MDC.put("token", token);
// try { try {
// SessionUserInfo info = tokenService.getUserInfo(); SessionUserInfo info = tokenService.getUserInfo();
// if (info != null) { if (info != null) {
// String username = info.getUsername(); String username = info.getUsername();
// MDC.put("username", username); MDC.put("username", username);
// } }
// } catch (CommonJsonException e) { } catch (CommonJsonException e) {
// log.info("无效的token:{}", token); log.info("无效的token:{}", token);
// }
} }
} }
}*/
} }
package com.mortals.xhx.base.framework.filter; package com.mortals.xhx.base.framework.filter;
import cn.hutool.core.util.IdUtil;
import com.mortals.framework.service.IAuthTokenService;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.slf4j.MDC; import org.slf4j.MDC;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.util.ObjectUtils;
import org.springframework.web.filter.OncePerRequestFilter; import org.springframework.web.filter.OncePerRequestFilter;
import org.springframework.web.util.ContentCachingRequestWrapper; import org.springframework.web.util.ContentCachingRequestWrapper;
...@@ -23,19 +19,13 @@ import java.io.IOException; ...@@ -23,19 +19,13 @@ import java.io.IOException;
* @author: zxfei * @author: zxfei
* @date: 2022/4/20 14:52 * @date: 2022/4/20 14:52
*/ */
//@Component @Component
@Slf4j @Slf4j
public class RequestFilter extends OncePerRequestFilter implements Filter { public class RequestFilter extends OncePerRequestFilter implements Filter {
@Autowired
private IAuthTokenService authTokenService;
@Override @Override
protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain) throws ServletException, IOException { protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain) throws ServletException, IOException {
try { try {
//每个请求记录一个traceId,可以根据traceId搜索出本次请求的全部相关日志
MDC.put("traceId", IdUtil.fastSimpleUUID().substring(0,12));
setUsername(request);
request = new ContentCachingRequestWrapper(request); request = new ContentCachingRequestWrapper(request);
filterChain.doFilter(request, response); filterChain.doFilter(request, response);
} catch (Exception e) { } catch (Exception e) {
...@@ -47,22 +37,22 @@ public class RequestFilter extends OncePerRequestFilter implements Filter { ...@@ -47,22 +37,22 @@ public class RequestFilter extends OncePerRequestFilter implements Filter {
} }
private void setUsername(HttpServletRequest request) { /*private void setUsername(HttpServletRequest request) {
//通过token解析出username //通过token解析出username
String token = authTokenService.getToken(request); String token = authTokenService.getToken(request);
//String token = request.getHeader("token"); //String token = request.getHeader("token");
if (!ObjectUtils.isEmpty(token)) { if (!ObjectUtils.isEmpty(token)) {
MDC.put("token",token); MDC.put("token",token);
// MDC.put("token", token); MDC.put("token", token);
// try { try {
// SessionUserInfo info = tokenService.getUserInfo(); SessionUserInfo info = tokenService.getUserInfo();
// if (info != null) { if (info != null) {
// String username = info.getUsername(); String username = info.getUsername();
// MDC.put("username", username); MDC.put("username", username);
// } }
// } catch (CommonJsonException e) { } catch (CommonJsonException e) {
// log.info("无效的token:{}", token); log.info("无效的token:{}", token);
// }
} }
} }
}*/
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment