时间:2021-05-19
操作日志对于程序员或管理员而言,可以快速定位到系统中相关的操作,而对于操作日志的管理的实现不能对正常业务实现进行影响,否则即不满足单一原则,也会导致后续代码维护困难,因此我们考虑使用AOP切面技术来实现对日志管理的实现。
文章大致内容:
1、基本概念
2、基本应用
3、日志管理实战
对这几部分理解了,会对AOP的应用应该很轻松。
一、基本概念
项目 描述 Aspect(切面) 跨越多个类的关注点的模块化,切面是通知和切点的结合。通知和切点共同定义了切面的全部内容——它是什么,在何时和何处完成其功能。事务处理和日志处理可以理解为切面 Join point(连接点) 程序执行过程中的一个点,如方法的执行或异常的处理 Advice(通知) 切面在特定连接点上采取的动作 Pointcut(切点) 匹配连接点的断言。通知与切入点表达式相关联,并在切入点匹配的任何连接点上运行(例如,具有特定名称的方法的执行)。切入点表达式匹配的连接点概念是AOP的核心,Spring默认使用AspectJ切入点表达式语言 Introduction(引用) 为类型声明其他方法或字段。Spring AOP允许您向任何建议的对象引入新的接口(和相应的实现)。例如,您可以使用介绍使bean实现IsModified接口,以简化缓存 Target object(目标) 由一个或多个切面通知的对象。也称为“通知对象”。由于Spring AOP是通过使用运行时代理实现的,所以这个对象始终是代理对象 AOP proxy(代理) AOP框架为实现切面契约(通知方法执行等)而创建的对象。在Spring框架中,AOP代理是JDK动态代理或CGLIB代理 Weaving(织入) 织入是将通知添加对目标类具体连接点上的过程,可以在编译时(例如使用AspectJ编译器)、加载时或运行时完成
Spring切面可以应用5种类型的通知:
其执行的顺序为:
后续的基本应用,会将环绕通知、前置通知、后置通知、返回通知、异常通知进行实现,并演示其执行顺序。
二、基本应用
声明通知
大家可以将下面的代码复制出来,验证上面的执行顺序。
其中需要注意的是切入点:@Pointcut的表达式
格式:
execution(modifiers-pattern? ret-type-pattern declaring-type-pattern? name-pattern(param-pattern)throws-pattern?)
括号中各个pattern分别表示:
示例:
1)execution(* (…))
//表示匹配所有方法
2)execution(public * com. savage.service.UserService.(…))
//表示匹配com.savage.server.UserService中所有的公有方法
3)execution(* com.savage.server….(…))
//表示匹配com.savage.server包及其子包下的所有方法
三、日志管理实战
有了上面基本应用的理解,现在我们直接就贴代码:
1、依赖的jar包
<!-- aop依赖 --><dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-aop</artifactId></dependency>2、自定义注解
@Target(ElementType.METHOD)@Retention(RetentionPolicy.RUNTIME)public @interface Log { String value() default "";}3、实现切面
@Aspect@Order(5)@Componentpublic class LogAspect { private Logger logger = LoggerFactory.getLogger(LogAspect.class); @Autowired private ErpLogService logService; @Autowired ObjectMapper objectMapper; private ThreadLocal<Date> startTime = new ThreadLocal<Date>(); @Pointcut("@annotation(com.chenyanwu.erp.erpframework.annotation.Log)") public void pointcut() { } /** * 前置通知,在Controller层操作前拦截 * * @param joinPoint 切入点 */ @Before("pointcut()") public void doBefore(JoinPoint joinPoint) { // 获取当前调用时间 startTime.set(new Date()); } /** * 正常情况返回 * * @param joinPoint 切入点 * @param rvt 正常结果 */ @AfterReturning(pointcut = "pointcut()", returning = "rvt") public void doAfter(JoinPoint joinPoint, Object rvt) throws Exception { handleLog(joinPoint, null, rvt); } /** * 异常信息拦截 * * @param joinPoint * @param e */ @AfterThrowing(pointcut = "pointcut()", throwing = "e") public void doAfter(JoinPoint joinPoint, Exception e) throws Exception { handleLog(joinPoint, e, null); } @Async private void handleLog(final JoinPoint joinPoint, final Exception e, Object rvt) throws Exception{ // 获得注解 Method method = getMethod(joinPoint); Log log = getAnnotationLog(method); if (log == null) { return; } Date now = new Date(); // 操作数据库日志表 ErpLog erpLog = new ErpLog(); erpLog.setErrorCode(0); erpLog.setIsDeleted(0); // 请求信息 HttpServletRequest request = ToolUtil.getRequest(); erpLog.setType(ToolUtil.isAjaxRequest(request) ? "Ajax请求" : "普通请求"); erpLog.setTitle(log.value()); erpLog.setHost(request.getRemoteHost()); erpLog.setUri(request.getRequestURI().toString());// erpLog.setHeader(request.getHeader(HttpHeaders.USER_AGENT)); erpLog.setHttpMethod(request.getMethod()); erpLog.setClassMethod(joinPoint.getSignature().getDeclaringTypeName() + "." + joinPoint.getSignature().getName()); // 请求的方法参数值 Object[] args = joinPoint.getArgs(); // 请求的方法参数名称 LocalVariableTableParameterNameDiscoverer u = new LocalVariableTableParameterNameDiscoverer(); String[] paramNames = u.getParameterNames(method); if (args != null && paramNames != null) { StringBuilder params = new StringBuilder(); params = handleParams(params, args, Arrays.asList(paramNames)); erpLog.setParams(params.toString()); } String retString = JsonUtil.bean2Json(rvt); erpLog.setResponseValue(retString.length() > 5000 ? JsonUtil.bean2Json("请求参数数据过长不与显示") : retString); if (e != null) { erpLog.setErrorCode(1); erpLog.setErrorMessage(e.getMessage()); } Date stime = startTime.get(); erpLog.setStartTime(stime); erpLog.setEndTime(now); erpLog.setExecuteTime(now.getTime() - stime.getTime()); erpLog.setUsername(MySysUser.loginName()); HashMap<String, String> browserMap = ToolUtil.getOsAndBrowserInfo(request); erpLog.setOperatingSystem(browserMap.get("os")); erpLog.setBrower(browserMap.get("browser")); erpLog.setId(IdUtil.simpleUUID()); logService.insertSelective(erpLog); } /** * 是否存在注解,如果存在就获取 */ private Log getAnnotationLog(Method method) { if (method != null) { return method.getAnnotation(Log.class); } return null; } private Method getMethod(JoinPoint joinPoint) { Signature signature = joinPoint.getSignature(); MethodSignature methodSignature = (MethodSignature) signature; Method method = methodSignature.getMethod(); if (method != null) { return method; } return null; } private StringBuilder handleParams(StringBuilder params, Object[] args, List paramNames) throws JsonProcessingException { for (int i = 0; i < args.length; i++) { if (args[i] instanceof Map) { Set set = ((Map) args[i]).keySet(); List list = new ArrayList(); List paramList = new ArrayList<>(); for (Object key : set) { list.add(((Map) args[i]).get(key)); paramList.add(key); } return handleParams(params, list.toArray(), paramList); } else { if (args[i] instanceof Serializable) { Class<?> aClass = args[i].getClass(); try { aClass.getDeclaredMethod("toString", new Class[]{null}); // 如果不抛出NoSuchMethodException 异常则存在 toString 方法 ,安全的writeValueAsString ,否则 走 Object的 toString方法 params.append(" ").append(paramNames.get(i)).append(": ").append(objectMapper.writeValueAsString(args[i])); } catch (NoSuchMethodException e) { params.append(" ").append(paramNames.get(i)).append(": ").append(objectMapper.writeValueAsString(args[i].toString())); } } else if (args[i] instanceof MultipartFile) { MultipartFile file = (MultipartFile) args[i]; params.append(" ").append(paramNames.get(i)).append(": ").append(file.getName()); } else { params.append(" ").append(paramNames.get(i)).append(": ").append(args[i]); } } } return params; }}4、对应代码添加注解
@Log("新增学生") @RequestMapping(value = "/create", method = RequestMethod.POST) @ResponseBody public ResultBean<String> create(@RequestBody @Validated ErpStudent item) { if(service.insertSelective(item) == 1) { // 插入 insertErpSFamilyMember(item); return new ResultBean<String>(""); } return new ResultBean<String>(ExceptionEnum.BUSINESS_ERROR, "新增学生异常!", "新增失败!", ""); }通过对业务进行操作后,会写入数据库,界面查询:
日志管理的完整的代码可以从git上获取:
https://github.com/chyanwu/erp-framework
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
SpringBoot在annotation的层面实现了数据缓存的功能,基于Spring的AOP技术。所有的缓存配置只是在annotation层面配置,像声明式事
jax-wshandler的详解及简单实例aop技术一般用于某个对象的函数调用的日志,认证等。webservice是远程的函数调用,也需要类似的aop方法,举例
今天继续实现AOP,到这里我个人认为是最灵活,可扩展的方式了,就拿日志管理来说,用SpringAOP自定义注解形式实现日志管理。废话不多说,直接开始!!!关于配
这篇文章主要介绍了Spring框架实现AOP添加日志记录功能过程详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以
AOP日志框架实现JDK动态代理实现日志框架首先,在项目包com.ay.test下创建业务接口类BusinessClassService,具体代码如下:Busi