AOP+MySQL实现一个简历的日志收集工具

一、自定义日志注解

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;/*** @Description 日志监控自定义注解*/
@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
public @interface WebLog {WebApiLogType logType() default WebApiLogType.NULL;String desc() default "";String name() default "";
}

二、定义AOP逻辑

import cn.hutool.core.bean.BeanUtil;
import com.alibaba.fastjson.JSON;
import org.apache.commons.lang3.StringUtils;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.aspectj.lang.reflect.MethodSignature;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
import javax.servlet.http.HttpServletRequest;
import java.util.Date;
import java.util.Objects;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.Executor;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;@Aspect
@Component
public class WebLogApiAspect {private static final Logger log = LoggerFactory.getLogger(WebLogApiAspect.class);public final static String POST ="POST", GET = "GET";@Autowiredprivate LogService logService;/*** 采用异步逻辑处理日志保存，降低整体调用的时间* <p>只开一个线程处理日志保存逻辑，防止流量洪峰压垮保存逻辑侧</p>* <p>拒绝策略采用直接拒绝而非交给主线程处理，则当前的监控日志只能承担1001的TPS</p>*/public static Executor EXECUTOR = new ThreadPoolExecutor(1, 1, 60L, TimeUnit.SECONDS, new ArrayBlockingQueue<>(1000), new ThreadPoolExecutor.AbortPolicy());@Pointcut("@annotation(com.common.aop.WebLog) ")public void webLogPoint() {}@Around("webLogPoint()")public Object webLogRecord(ProceedingJoinPoint point) throws Throwable {ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();if (Objects.isNull(requestAttributes)){return point.proceed();}HttpServletRequest request = requestAttributes.getRequest();Object result=null;Exception e = null;try {result= point.proceed();} catch (Exception exception) {e = exception;throw exception;} finally {try {save(request,point,result,e);} catch (Exception aopException) {log.error("webLogRecord error", aopException);}}return result;}private void save(HttpServletRequest request, ProceedingJoinPoint point, Object result, Exception e) {LogParam webApiLogParam = new LogParam();if (POST.equalsIgnoreCase(request.getMethod())){//根据不同的请求类型存入请求内容：POSTString requestBody = WebLogUtil.buildPostParam(point);webApiLogParam.setRequestBody(requestBody);log.info("Request Args  ："+ WebLogUtil.buildPostParam(point));} else if (GET.equalsIgnoreCase(request.getMethod())) {//GETwebApiLogParam.setRequestBody(request.getQueryString());log.info("get Args : "+ request.getQueryString());} else {log.info("接口监控只支持REST风格的GET/POST方法，当前方法为 {}", request.getMethod());return;}//请求参数组装buildRequestParam(webApiLogParam,request,point);//响应结果过组装buildResultParam(webApiLogParam, result);//异常信息组装if (null!=e) {buildExceptionParam(webApiLogParam, e);}EXECUTOR.execute(() -> {//日志model发送到api_webtry {logService.getBaseMapper().insert(BeanUtil.copyProperties(webApiLogParam, WebApiLogParam.class));} catch (Exception exception) {log.error("日志监控保存失败",exception);}});}private void buildExceptionParam(LogParam webApiLogParam, Exception exception) {webApiLogParam.setException(1);webApiLogParam.setExceptionMessage(exception.toString());webApiLogParam.setErr(exception.toString());}private void buildRequestParam(LogParam webApiLogParam, HttpServletRequest request, ProceedingJoinPoint point) {//反射获取自定义注解WebLog webLog = ((MethodSignature) point.getSignature()).getMethod().getAnnotation(WebLog.class);webApiLogParam.setUrl(request.getRequestURL().toString());webApiLogParam.setMethod(request.getMethod());webApiLogParam.setRetry(0);webApiLogParam.setApi(point.getSignature().toString());if (StringUtils.isNotEmpty(request.getServletPath())){webApiLogParam.setSourceCode(Objects.requireNonNull(webLog.name()));webApiLogParam.setSourceType(Objects.requireNonNull(webLog.desc()));}webApiLogParam.setCreator(IpUtils.getIpAddr(request));webApiLogParam.setCreateTime(new Date());webApiLogParam.setIsDeleted(0);}public void buildResultParam(LogParam webApiLogParam,Object result) {try {if (result instanceof ChannelResult) {ChannelResult<?> modelResult = (ChannelResult<?>) result;if (ChannelResultUtil.isSuccess(modelResult)) {webApiLogParam.setResult(0);}else {webApiLogParam.setResult(1);}webApiLogParam.setResponseBody(JSON.toJSONString(modelResult));} else if (result instanceof ChannelResult) {ChannelResult<?> modelResult = (ChannelResult<?>) result;if (ChannelResultUtil.isSuccess(modelResult)) {webApiLogParam.setResult(0);}else {webApiLogParam.setResult(1);}webApiLogParam.setResponseBody(JSON.toJSONString(modelResult));}else {webApiLogParam.setResult(0);webApiLogParam.setResponseBody(JSON.toJSONString(result));}} catch (Exception exception) {log.error("组装响应结果失败", exception);}}
}

三.日志类和工具

import com.alibaba.fastjson.JSON;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RequestBody;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.lang.annotation.Annotation;
import java.lang.reflect.Method;
import java.lang.reflect.Parameter;
import java.util.Objects;/*** @ClassName WebLogUtil*/
@Component
public class WebLogUtil {public static String buildPostParam(JoinPoint joinPoint) {Object[] args = joinPoint.getArgs();MethodSignature signature = (MethodSignature) joinPoint.getSignature();Method method = signature.getMethod();Annotation[][] parameterAnnotations = method.getParameterAnnotations();Parameter[] parameters = method.getParameters();for (int i = 0; i < parameters.length; i++) {Annotation[] parameterAnnotation = parameterAnnotations[i];if (null != parameterAnnotation) {for (Annotation annotation : parameterAnnotation) {Objects.equals(RequestBody.class, annotation.getClass());if (args[i] == null) return null;return JSON.toJSONString(args[i]);}}}for (int i = 0; i < parameters.length; i++) {Parameter parameter = parameters[i];if (parameter.getType() != HttpServletRequest.class&& parameter.getType() != HttpServletResponse.class&& parameter.getType() != ServletRequest.class&& parameter.getType() != ServletResponse.class) {if (args[i] == null) return null;return JSON.toJSONString(args[i]);}}return null;}
}
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors;
import java.io.Serializable;
import java.util.Date;
/*** @Description 日志监控模型*/
@Data
@EqualsAndHashCode(callSuper = false)
@Accessors(chain = true)
public class LogParam implements Serializable {private Long id;/*** 来源单号*/private String sourceCode;/*** 来源类型*/private String sourceType;/*** 请求方式*/private String method;/*** 请求入参*/private String requestBody;/*** 响应参数*/private String responseBody;/*** 接口推送结果* 0成功1失败*/private Integer result;/*** 错误信息*/private String err;/*** 有无异常* 0有1没有*/private Integer exception;/*** 异常信息*/private String exceptionMessage;/*** 重试标志* 0是1否*/private Integer retry;/*** 接口地址*/private String url;/*** 请求方法*/private String api;private Date createTime;private Date modifyTime;private Integer isDeleted;private String creator;private Long modifier;
}
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import javax.servlet.http.HttpServletRequest;public class IpUtils {private static Logger logger = LoggerFactory.getLogger(IpUtils.class);public IpUtils() {}public static String getIpAddr(HttpServletRequest request) {String unknown = "unknown";String ip = null;try {ip = request.getHeader("x-forwarded-for");if (StringUtils.isEmpty(ip) || unknown.equalsIgnoreCase(ip)) {ip = request.getHeader("Proxy-Client-IP");}if (StringUtils.isEmpty(ip) || ip.length() == 0 || unknown.equalsIgnoreCase(ip)) {ip = request.getHeader("WL-Proxy-Client-IP");}if (StringUtils.isEmpty(ip) || unknown.equalsIgnoreCase(ip)) {ip = request.getHeader("HTTP_CLIENT_IP");}if (StringUtils.isEmpty(ip) || unknown.equalsIgnoreCase(ip)) {ip = request.getHeader("HTTP_X_FORWARDED_FOR");}if (StringUtils.isEmpty(ip) || unknown.equalsIgnoreCase(ip)) {ip = request.getRemoteAddr();}} catch (Exception var4) {logger.error("IPUtils ERROR ", var4);}return ip;}
}

import com.baomidou.mybatisplus.extension.service.IService;
import com.dal.log.entity.WebApiLogParam;
public interface LogService extends IService<WebApiLogParam> {
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/762867.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

【数据库系统】SQL和T-SQL

【数据库系统】SQL和T-SQL

第四章 SQL 基本内容 系统结构、DDL、DML、视图、数据控制、嵌入式SQL SQL介绍 特点 一体化&#xff1b;面向集合操作&#xff1b;非过程化语言&#xff1b;可以单独写&#xff0c;也可以作为嵌入式语言&#xff08;JDBC&#xff09; 体系结构 数据库存储结构 逻辑存储结构 面…
阅读更多...
AES对称和RSA非对称加密登录接口参数

AES对称和RSA非对称加密登录接口参数

使用RSA非对称加密AES对称加密 加密类型&#xff1a; RSA&#xff1a;是一种非对称加密算法。它使用一对密钥&#xff08;公钥和私钥&#xff09;&#xff0c;其中公钥可以公开给任何人&#xff0c;用于加密数据&#xff1b;而私钥需要保密&#xff0c;用于解密数据。AES&#…
阅读更多...
小程序 转发 功能

小程序 转发 功能

mina/pages/food/info.wxml <import src"../../wxParse/wxParse.wxml" /> <view class"container"> <!--商品轮播图--> <view class"swiper-container"><swiper class"swiper_box" autoplay"{{autop…
阅读更多...
在vscode中使用git-新手向

在vscode中使用git-新手向

Git 应该是必学的版本同步工具&#xff0c;是代码管理的好帮手。 可是对新手来说上手还是有一丢丢门槛&#xff0c;结合 vscode 同步非常方便。 可实现可视化代码变化&#xff0c;提醒自己记录版本修改内容。非常好用。 在 VSCode 中将项目上传至 GitHub 私有仓库基本步骤 确保…
阅读更多...
基于ssm电子竞技管理平台的设计与实现论文

基于ssm电子竞技管理平台的设计与实现论文

摘 要 现代经济快节奏发展以及不断完善升级的信息化技术&#xff0c;让传统数据信息的管理升级为软件存储&#xff0c;归纳&#xff0c;集中处理数据信息的管理方式。本电子竞技管理平台就是在这样的大环境下诞生&#xff0c;其可以帮助管理者在短时间内处理完毕庞大的数据信息…
阅读更多...
2024上半年软考报名时间及费用汇总！最新！

2024上半年软考报名时间及费用汇总！最新！

2024上半年软考考试时间为5月25-28日&#xff0c;2024年上半年软考全国报名平台入口3月18日开通&#xff0c;由此可知各地报名时间将会从3月份陆续开始。各地报名时间不同&#xff0c;且部分地区报名持续时间很短&#xff0c;请大家尽早报名&#xff0c;以免错过。 2024上半年…
阅读更多...
java:基于BeanDeserializer实现自定义的Java bean 解析器

java:基于BeanDeserializer实现自定义的Java bean 解析器

JsonDeserializer 关于jackson实现自定义的对象解析器&#xff0c;最常用的方式就是继承顶级抽象类(com.fasterxml.jackson.databind.JsonDeserializer) 来实现,比如下面的代码实现 // 自定义的JavaBean class Person {private String name;private int age;// 标准的getter和…
阅读更多...
Prometheus（四）：VMware Vsphere监控及数据展示

Prometheus（四）：VMware Vsphere监控及数据展示

目录 1 vmware exporter安装配置1.1 vmware exporter介绍1.2 安装 - 使用kubernetes部署1、下载2、修改配置文件3、执行安装4、查看 1.3 安装-使用docker的方式1.4 Prometheus配置1.5 Grafana配置&#xff08;模板页面还需要修改&#xff09; 总结 1 vmware exporter安装配置 …
阅读更多...
基于docker commit和Dockerfile为镜像添加ssh服务

基于docker commit和Dockerfile为镜像添加ssh服务

系统管理员可以通过SSH服务来远程登录管理服务器 本文介绍基于docker commit和Dockerfile为镜像添加ssh服务 docker commit 该命令支持用户对容器自定义 1.获取镜像ubuntu&#xff1a;18.04&#xff0c;并创建一个容器 [rootnode2 db]docker pull ubuntu:18.04 [rootnode2 …
阅读更多...
cloudflare 应用例子几则

cloudflare 应用例子几则

Cloudflare&#xff08;以下简称 CF&#xff09; 堪称互联网活菩萨&#xff0c;造就一大批高质量的互联网基础技术服务&#xff0c;更难得的是&#xff0c;几乎所有的服务都有对应的免费的套餐&#xff0c;而且出手大方&#xff0c;基本上有足够的容量或请求次数。 CDN CF 最…
阅读更多...
MySQL的基本操作

MySQL的基本操作

目录 引言 一、SQL语句简介 &#xff08;一&#xff09;SQL通用语法 &#xff08;二&#xff09;SQL分类 &#xff08;三&#xff09;数据类型 1.数值类型 2.字符串类型 3.日期/时间类型 4.修饰符 二、登录mysql服务 三、SQL语句操作 &#xff08;一&#xff09;DD…
阅读更多...
深度学习500问——Chapter04：经典网络解读（1）

深度学习500问——Chapter04：经典网络解读（1）

文章目录 4.1 LeNet-5 4.1.1 模型介绍 4.1.2 模型结构 4.1.3 模型特性 4.2 AlexNet 4.2.1 模型介绍 4.2.2 模型结构 4.2.3 模型特性 4.3 ZFNet 4.3.1 模型介绍 4.3.2 模型结构 4.3.3 模型特性 4.4 Network in Network 4.4.1 模型介绍 4.4.2 模型结构 4.4.3 模型特性 4.1 LeNet-…
阅读更多...
java面试：常见的限流算法有哪些

java面试：常见的限流算法有哪些

1 什么是限流算法 限流算法是一种用于限制流量请求的频率或速率的算法&#xff0c;其目的是在高并发或大流量请求的情况下&#xff0c;保护系统服务的安全性和可用性。限流算法可以应对热点业务带来的突发请求、调用方bug导致的突发请求以及恶意攻击请求等情况。是一种系统保护…
阅读更多...
金融知识分享系列之：出场信号RSI指标

金融知识分享系列之：出场信号RSI指标

金融知识分享系列之&#xff1a;出场信号RSI指标 一、出场信号RSI指标二、RSI指标原理三、 指标用法四、RSI指标总结 一、出场信号RSI指标 名称&#xff1a;相对强弱指标参数&#xff1a;(默认14)组成&#xff1a;RSI线以及30轴、50轴、70轴构成 0-30是极弱&#xff1a;0-30的…
阅读更多...
jmeter接口自动化测试框架

jmeter接口自动化测试框架

接口测试可以分为两部分&#xff1a; 一是线上接口&#xff08;生产环境&#xff09;自动化测试&#xff0c;需要自动定时执行&#xff0c;每5分钟自动执行一次&#xff0c;相当于每5分钟就检查一遍线上的接口是否正常&#xff0c;有异常能够及时发现&#xff0c;不至于影响用…
阅读更多...
服务器病毒木马通用排查处理应急响应流程

服务器病毒木马通用排查处理应急响应流程

目录 一、勒索病毒发作的特征 二、勒索病毒的应急响应 三、勒索病毒预防与事后加固 一、勒索病毒发作的特征 如果发现大量统一后缀的文件&#xff1b;发现勒索信在Linux/home、/usr等目录&#xff0c;在Windows 桌面或者是被加密文件的文件夹下。如果存在以上特…
阅读更多...
四十八岁男子心慌心悸，失眠，喉咙有异物，刘家峰告诉你怎么办！

四十八岁男子心慌心悸，失眠，喉咙有异物，刘家峰告诉你怎么办！

植物神经功能紊乱&#xff0c;通常简称为植物神经紊乱&#xff0c;是一种涉及自主神经系统的失调疾病。自主神经系统负责控制人体内许多自动功能&#xff0c;如心率、血压、消化和体温调节。植物神经功能紊乱是指由于自主神经系统失衡导致的一系列症状和体征的综合症。 植物神经…
阅读更多...
windows DCMTK编译使用(qt) 医学图像

windows DCMTK编译使用(qt) 医学图像

由于项目需要生成DICOM格式的图片&#xff0c;需要使用到第三方开源库DCMTK&#xff0c;于是研究了一番&#xff0c;该库是C编写的&#xff0c;DICOM主要用于医疗体系中&#xff0c;除了可以保存图片信息外&#xff0c;还可以储存患者信息&#xff0c;病例信息&#xff0c;医疗…
阅读更多...
【Emgu CV教程】10.2、轮廓之外接矩形、面积计算

【Emgu CV教程】10.2、轮廓之外接矩形、面积计算

文章目录 一、轮廓的外接矩形二、轮廓的面积三、两个函数的简单应用1.原始素材2.代码3.运行结果 一、轮廓的外接矩形 轮廓的外接矩形&#xff0c;函数是&#xff1a; public static Rectangle BoundingRectangle (IInputArray points // 输入的轮廓 )函数返回的是一个矩形&am…
阅读更多...
unity3d——沙盒路径

unity3d——沙盒路径

文章目录 Unity3D中不同平台的沙盒路径&#xff1a; 示例 在Unity3D中&#xff0c;尤其是在移动平台如Android和iOS上&#xff0c;由于系统安全机制&#xff0c;应用程序不能直接访问操作系统的所有文件和目录&#xff0c;而是被限制在一个特定的“沙盒”环境中。这个沙盒是一个…
阅读更多...
最新文章

Copyright @ 2022~2023