小熊科技|从零学ELK系列（十）:SpringBoot接入ELK升级版
【从零学ELK系列目录】从零学ELK系列（一）:为什么要跟我学从零学ELK系列
从零学ELK系列（二）:VMware安装Centos（超详细图文教程）
从零学ELK系列（三）:Centos安装Docker（超详细图文教程）
从零学ELK系列（四）Docker安装Elasticsearch（超详细图文教程）
从零学ELK系列（五）:Docker安装kibana（超详细图文教程）
从零学ELK系列（六）:Docker安装Logstash（超详细图文教程）
从零学ELK系列（七）:Centos安装Filebeat（超详细图文教程）
从零学ELK系列（八）:SpringBoot项目接入ELK（超详细图文教程）
从零学ELK系列（九）:Nginx接入ELK（超详细图文教程）
从零学ELK系列（十）:SpringBoot项目接入ELK升级版（超详细图文教程）
前言之前在《从零学ELK系列（八）:SpringBoot项目接入ELK（超详细图文教程） 》中演示了SpringBoot项目接入ELK ， 后来项目中对这部分进行了优化 ， 之前博文中也有读者问到 ， 将优化整理成博文和大家共享；
优化前：
一次请求记录两条日志（request一条 ， response一条） ， 通过UUID传连起来
优化后：
一次请求记录一条日志（request信息与response信息都在一起）
架构图import com.alibaba.fastjson.JSON;import com.zhanghan.zhelkboot.util.wrapper.Wrapper;import org.aspectj.lang.JoinPoint;import org.aspectj.lang.reflect.MethodSignature;import org.slf4j.Logger;import org.slf4j.MDC;import javax.servlet.http.HttpServletRequest;import javax.servlet.http.HttpServletResponse;import java.text.SimpleDateFormat;import java.util.*;public class FileBeatLogUtil {public static void writeRequestInfo(HttpServletRequest request, String applicationName, String reqName, String requestParams) {String requestURI = request.getRequestURI();//获取requestHeaderEnumeration requestHeaderNames = request.getHeaderNames();Map reuestHeaderMap = new HashMap<>();while (requestHeaderNames.hasMoreElements()) {String name = requestHeaderNames.nextElement();String value = http://kandian.youth.cn/index/request.getHeaders(name).nextElement();reuestHeaderMap.put(name, value);}String requestHeader ="";if (null != reuestHeaderMap}//防止MDC值空指针 ， 所有入参不为nullapplicationName = org.springframework.util.StringUtils.isEmpty(applicationName) ? "" : applicationName;requestURI = org.springframework.util.StringUtils.isEmpty(requestURI) ? "" : requestURI;reqName = org.springframework.util.StringUtils.isEmpty(reqName) ? "" : reqName;requestParams = "null".equals(requestParams) ? "" : requestParams;//MDC值为ES键值对JSON信息MDC.put("applicationName", applicationName);MDC.put("requestTime", getStringTodayTime());MDC.put("requestURI", requestURI);MDC.put("requestHeader", requestHeader);MDC.put("sourceName", reqName);MDC.put("requestParams", requestParams);}public static void writeResponseLog(Object o, Logger log, HttpServletResponse response) {//取responseHeader内容Map responseHeaderMap = new HashMap<>();Collection headerNames = response.getHeaderNames();headerNames.forEach(name -> {responseHeaderMap.put(name, response.getHeader(name));});String strResponseHeader = "";if (null != responseHeaderMap}//获取response内容String responseCode = "";String responseMsg = "";String responseBody = "";Wrapper wrapper;if (null != o) {wrapper = (Wrapper) o;if (null != wrapper) {responseCode = String.valueOf(wrapper.getCode());responseMsg = wrapper.getMessage();responseBody = wrapper.getResult().toString();}}//MDC值为ES键值对JSON信息MDC.put("responseHeader", strResponseHeader);MDC.put("responseCode", responseCode);MDC.put("responseMsg", responseMsg);MDC.put("responseBody", responseBody);MDC.put("responseTime", getStringTodayTime());Map copyOfContextMap = MDC.getCopyOfContextMap();String reqInfoJsonStr = JSON.toJSONString(copyOfContextMap);log.info(reqInfoJsonStr);}/*** 获取请求参数 ， 处理为json字符串** @param joinPoint* @return*/public static String getParams(JoinPoint joinPoint) {Object[] argValues = joinPoint.getArgs();String[] argNames = ((MethodSignature) joinPoint.getSignature()).getParameterNames();LinkedHashMap linkedHashMap = new LinkedHashMap
推荐阅读
- 所持股份|万兴科技：公司控股股东、实际控制人吴太兵质押150万股
- 发布公告|数量过半！博创科技：天通股份累计减持约150万股
- 英雄科技聊数码|蔡崇信有实力买下篮网，那身价3200亿的马云，能买下几支NBA球队
- 科技前沿阵地|涨疯了！海思安防芯片遭哄抬“围剿”
- 月影浓|吴亦凡机械造型走秀 垫肩披风搭银框眼镜科技感足
- 中国历史发展过程|中国历史发展过程.中国的科技史界过去半个多世纪
- 天津|桂发祥：不再持有昆汀科技股份
- 消费|减持！天通股份：减持博创科技约32万股
- 处罚|老周侃股：吉鑫科技大股东应补偿踩雷投资者
- 华中科技大学|杯具！超本科线95分，本科有路不走，却梦幻般碰瓷，撞开专科的门