使用@AfterReturning spring aop时缺少参数

t5fffqht  于 5个月前  发布在  Spring
关注(0)|答案(1)|浏览(40)

编辑以提供MCVE。

@Target(ElementType.PARAMETER)
@Retention(RetentionPolicy.RUNTIME)
public @interface Random {
}
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface Audited {
}
@Target(ElementType.PARAMETER)
@Retention(RetentionPolicy.RUNTIME)
public @interface Tester {
}
package spring;

import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;

@Slf4j
@SpringBootApplication
public class springLoader extends SpringBootServletInitializer {
    public static final Class<springLoader> CLASS = springLoader.class;

    public static void main(String[] args) {
        try (final var context = SpringApplication.run(CLASS, args)) {
            while(true){
                Thread.sleep(1000*60*60*24);
            }
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
    }
}
package spring;

import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.ArrayList;
import java.util.List;

@Slf4j
@RestController
@RequestMapping("/Inventory")
public class springRest {
    private List<String> info;

    public springRest() {
        final var strArr = new String[]{"1234", "2345", "3456", "4567", "5678"};
        info = new ArrayList<>();
        info.addAll(List.of(strArr));
    }

    @Audited
    @GetMapping()
    public List<String> getInfo(@Tester String permittedValues, @Random String randomValues) {
        log.info("permitted {}", permittedValues);
        log.info("random: {}", randomValues);
        List<String> returnedValues = new ArrayList<>();
        for (final var str : info) {
            if (permittedValues.contains(str) || randomValues.contains(str)) {
                log.info("{}", str);
                returnedValues.add(str);
            } else {
                log.info("Not permitted: {}", str);
            }
        }

        return returnedValues;
    }
}
package spring;

import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.annotation.AfterReturning;
import org.aspectj.lang.annotation.AfterThrowing;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.stereotype.Component;

import java.time.LocalDate;
import java.time.LocalTime;
import java.util.Arrays;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.stream.Collectors;

@Component
@Aspect
@Slf4j
public class AuditAspect {
    @AfterReturning("@annotation(spring.Audited)")
    public void afterReturning(JoinPoint joinPoint) {
        auditHelper(joinPoint, null);
    }

    @AfterThrowing(pointcut = "@annotation(spring.Audited)", throwing = "ex")
    public void handleException(JoinPoint joinPoint, Exception ex) {
        // This advice will be executed if an exception occurs.
        auditHelper(joinPoint, ex);
    }

    private void auditHelper(JoinPoint joinPoint, Exception ex) {
        final var date = LocalDate.now();
        final var time = LocalTime.now();

        final var method = ((MethodSignature) joinPoint.getSignature()).getMethod();
        final var methodname = method.getName();
        final var args = joinPoint.getArgs();

        final var arguments = Arrays.stream(args).map(Object::toString).collect(Collectors.joining(" | "));
        final var base = "accessed " + methodname + " with arguments: " + arguments;
        final var statement = (ex == null) ? base : base + " but failed: " + ex.getMessage();

        final Map<String, Object> linkedMap = new LinkedHashMap<>();
        linkedMap.put("Time", time);
        linkedMap.put("Date", date);
        linkedMap.put("Log", statement);
        log.info(statement);
    }
}
package spring;

import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.stereotype.Component;

import java.lang.annotation.Annotation;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;

@Component
@Aspect
public class TesterAspect {
    private String[] permittedValues = new String[]{"1234", "2345"};
    private List<String> randomValues = new ArrayList<>(List.of("1234", "2345", "3456", "4567","5678"));

    @Around("execution(* *(.., @spring.Tester (*), ..))")
    public Object permittedValues(ProceedingJoinPoint pjp) throws Throwable {
        final var args = pjp.getArgs();
        final var annotations = ((MethodSignature) pjp.getSignature()).getMethod().getParameterAnnotations();

        for (int i = 0; i < args.length; i++) {
            for (Annotation annotation : annotations[i]) {
                if (annotation.annotationType() == Tester.class) {
                    args[i] = String.join(",", permittedValues);
                }
            }
        }

        Object result = pjp.proceed(args);
        return result;
    }

    @Around("execution(* *(.., @spring.Random (*), ..))")
    public Object randomValues(ProceedingJoinPoint pjp) throws Throwable {
        final var args = pjp.getArgs();
        final var annotations = ((MethodSignature) pjp.getSignature()).getMethod().getParameterAnnotations();

        for (int i = 0; i < args.length; i++) {
            for (Annotation annotation : annotations[i]) {
                if (annotation.annotationType() == Random.class) {
                    Collections.shuffle(randomValues);
                    args[i] = randomValues.get(0)+","+randomValues.get(1);
                }
            }
        }
        Object result = pjp.proceed(args);
        return result;
    }
}

下面的代码模拟了我遇到的错误。我在参数级别上为GetMapping添加了两个注解，在方法级别上添加了一个注解。两个Around方面被执行，并且在GetMapping方法中，修改后的参数被正确地注销。但是，在@AfterReturning或@AfterThrowing方面方法中，其中一个参数为null。我通过键入localhost访问了GetMapping：8080/库存到谷歌Chrome。
IDE上的堆栈跟踪为：

2023-12-06 11:39:14.938  INFO 7905 --- [nio-8080-exec-1] s.springRest                             : permitted 1234,2345
2023-12-06 11:46:17.851  INFO 8067 --- [nio-8080-exec-1] s.springRest                             : random: 3456,5678
2023-12-06 11:46:17.851  INFO 8067 --- [nio-8080-exec-1] s.springRest                             : 1234
2023-12-06 11:46:17.851  INFO 8067 --- [nio-8080-exec-1] s.springRest                             : 2345
2023-12-06 11:46:17.851  INFO 8067 --- [nio-8080-exec-1] s.springRest                             : 3456
2023-12-06 11:46:17.852  INFO 8067 --- [nio-8080-exec-1] s.springRest                             : Not permitted: 4567
2023-12-06 11:46:17.852  INFO 8067 --- [nio-8080-exec-1] s.springRest                             : 5678
2023-12-06 11:39:14.942 ERROR 7905 --- [nio-8080-exec-1] o.a.c.c.C.[.[.[.[dispatcherServlet]      : Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is java.lang.NullPointerException] with root cause

java.lang.NullPointerException: null
    at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:197) ~[?:?]
    at java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:992) ~[?:?]
    at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:509) ~[?:?]
    at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:499) ~[?:?]
    at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:921) ~[?:?]
    at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?]
    at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:682) ~[?:?]
    at spring.AuditAspect.auditHelper(AuditAspect.java:41) ~[classes/:?]
    at spring.AuditAspect.afterReturning(AuditAspect.java:24) ~[classes/:?]
    at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?]
    at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) ~[?:?]
    at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
    at java.lang.reflect.Method.invoke(Method.java:568) ~[?:?]
    at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:634) ~[spring-aop-5.3.24.jar:5.3.24]
    at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:617) ~[spring-aop-5.3.24.jar:5.3.24]
    at org.springframework.aop.aspectj.AspectJAfterReturningAdvice.afterReturning(AspectJAfterReturningAdvice.java:66) ~[spring-aop-5.3.24.jar:5.3.24]
    at org.springframework.aop.framework.adapter.AfterReturningAdviceInterceptor.invoke(AfterReturningAdviceInterceptor.java:58) ~[spring-aop-5.3.24.jar:5.3.24]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:175) ~[spring-aop-5.3.24.jar:5.3.24]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) ~[spring-aop-5.3.24.jar:5.3.24]
    at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97) ~[spring-aop-5.3.24.jar:5.3.24]
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186) ~[spring-aop-5.3.24.jar:5.3.24]
    at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.proceed(CglibAopProxy.java:763) ~[spring-aop-5.3.24.jar:5.3.24]
    at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:708) ~[spring-aop-5.3.24.jar:5.3.24]
    at spring.springRest$$EnhancerBySpringCGLIB$$1d14e293.getInfo(<generated>) ~[classes/:?]
    at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:?]
    at jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77) ~[?:?]
    at jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:?]
    at java.lang.reflect.Method.invoke(Method.java:568) ~[?:?]
    at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:205) ~[spring-web-5.3.24.jar:5.3.24]
    at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:150) ~[spring-web-5.3.24.jar:5.3.24]
    at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:117) ~[spring-webmvc-5.3.24.jar:5.3.24]
    at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:895) ~[spring-webmvc-5.3.24.jar:5.3.24]
    at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:808) ~[spring-webmvc-5.3.24.jar:5.3.24]
    at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87) ~[spring-webmvc-5.3.24.jar:5.3.24]
    at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1071) ~[spring-webmvc-5.3.24.jar:5.3.24]
    at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:964) ~[spring-webmvc-5.3.24.jar:5.3.24]
    at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1006) ~[spring-webmvc-5.3.24.jar:5.3.24]
    at org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:898) ~[spring-webmvc-5.3.24.jar:5.3.24]
    at javax.servlet.http.HttpServlet.service(HttpServlet.java:670) ~[tomcat-embed-core-9.0.70.jar:4.0.FR]
    at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:883) ~[spring-webmvc-5.3.24.jar:5.3.24]
    at javax.servlet.http.HttpServlet.service(HttpServlet.java:779) ~[tomcat-embed-core-9.0.70.jar:4.0.FR]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:227) ~[tomcat-embed-core-9.0.70.jar:9.0.70]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162) ~[tomcat-embed-core-9.0.70.jar:9.0.70]
    at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:53) ~[tomcat-embed-websocket-9.0.70.jar:9.0.70]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189) ~[tomcat-embed-core-9.0.70.jar:9.0.70]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162) ~[tomcat-embed-core-9.0.70.jar:9.0.70]
    at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100) ~[spring-web-5.3.24.jar:5.3.24]
    at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117) ~[spring-web-5.3.24.jar:5.3.24]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189) ~[tomcat-embed-core-9.0.70.jar:9.0.70]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162) ~[tomcat-embed-core-9.0.70.jar:9.0.70]
    at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93) ~[spring-web-5.3.24.jar:5.3.24]
    at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117) ~[spring-web-5.3.24.jar:5.3.24]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189) ~[tomcat-embed-core-9.0.70.jar:9.0.70]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162) ~[tomcat-embed-core-9.0.70.jar:9.0.70]
    at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201) ~[spring-web-5.3.24.jar:5.3.24]
    at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117) ~[spring-web-5.3.24.jar:5.3.24]
    at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189) ~[tomcat-embed-core-9.0.70.jar:9.0.70]
    at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162) ~[tomcat-embed-core-9.0.70.jar:9.0.70]
    at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:177) [tomcat-embed-core-9.0.70.jar:9.0.70]
    at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:97) [tomcat-embed-core-9.0.70.jar:9.0.70]
    at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:541) [tomcat-embed-core-9.0.70.jar:9.0.70]
    at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:135) [tomcat-embed-core-9.0.70.jar:9.0.70]
    at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92) [tomcat-embed-core-9.0.70.jar:9.0.70]
    at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:78) [tomcat-embed-core-9.0.70.jar:9.0.70]
    at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:360) [tomcat-embed-core-9.0.70.jar:9.0.70]
    at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:399) [tomcat-embed-core-9.0.70.jar:9.0.70]
    at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:65) [tomcat-embed-core-9.0.70.jar:9.0.70]
    at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:891) [tomcat-embed-core-9.0.70.jar:9.0.70]
    at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1784) [tomcat-embed-core-9.0.70.jar:9.0.70]
    at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49) [tomcat-embed-core-9.0.70.jar:9.0.70]
    at org.apache.tomcat.util.threads.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1191) [tomcat-embed-core-9.0.70.jar:9.0.70]
    at org.apache.tomcat.util.threads.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:659) [tomcat-embed-core-9.0.70.jar:9.0.70]
    at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) [tomcat-embed-core-9.0.70.jar:9.0.70]
    at java.lang.Thread.run(Thread.java:840) [?:?]

型
使用的pom.xml如下，但分发管理模糊。

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>org.example</groupId>
    <artifactId>demo</artifactId>
    <version>1.0-SNAPSHOT</version>

    <properties>
        <maven.compiler.source>17</maven.compiler.source>
        <maven.compiler.target>17</maven.compiler.target>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-web</artifactId>
            <version>5.3.24</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <version>2.7.7</version>
            <exclusions>
                <exclusion>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-starter-logging</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
            <version>2.7.7</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-log4j2</artifactId>
            <version>2.7.7</version>
            <exclusions>
                <exclusion>
                    <groupId>org.apache.logging.log4j</groupId>
                    <artifactId>log4j-slf4j-impl</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.apache.logging.log4j</groupId>
            <artifactId>log4j-slf4j2-impl</artifactId>
            <version>2.20.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.logging.log4j</groupId>
            <artifactId>log4j-api</artifactId>
            <version>2.20.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.logging.log4j</groupId>
            <artifactId>log4j-core</artifactId>
            <version>2.20.0</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.24</version>
            <scope>compile</scope>
        </dependency>
        <dependency>
            <groupId>javax.xml.bind</groupId>
            <artifactId>jaxb-api</artifactId>
            <version>2.4.0-b180830.0359</version>
        </dependency>
        <dependency>
            <groupId>com.h2database</groupId>
            <artifactId>h2</artifactId>
            <version>2.1.214</version>
            <scope>runtime</scope>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-surefire-plugin</artifactId>
                <version>2.22.2</version>
            </plugin>
        </plugins>
    </build>

    <distributionManagement>
        <repository>
            <id>nexus-es</id>
            <name>Internal Release Repository</name>
            <url>https://nexus/repository/my-docker/</url>
            <layout>default</layout>
        </repository>
        <snapshotRepository>
            <id>nexus-snapshot</id>
            <name>Internal Snapshot Repository</name>
            <url>https://nexus/repository/snapshot/</url>
        </snapshotRepository>
    </distributionManagement>
</project>

型

spring

1条答案

按热度按时间
dphi5xsq

dphi5xsq1#

您的错误只是发生了，因为AuditAspect::auditHelper中的代码并不期望Arrays.stream(args).map(Object::toString)可以包含null元素，但它确实包含了，这会使后续的.collect(Collectors.joining(" | "))调用脱轨。
如果将.map(Object::toString)替换为.map(o -> o == null ? "null" : o.toString())，则审计方面可以正常工作。应用程序将记录如下内容：

springRest          : permitted 1234,2345
springRest          : random: 1234,2345
springRest          : 1234
springRest          : 2345
springRest          : Not permitted: 3456
springRest          : Not permitted: 4567
springRest          : 5678
AuditAspect         : accessed getInfo with arguments: 1234,2345 | null

字符串
为什么第二个参数为null？你可能会期望它是类似于“2345，5678”的东西，因为你对Spring AOP的工作原理有一个错误的想法。虽然在两个around advice的情况下，内部的可以看到外部的输入参数变化，after通知显然不能。它看起来像是看到了传入最里面的around通知的参数，而不是后者传递给目标方法的参数。
实际上，在Spring AOP和AOP J中，继续的语义看起来是不同的。（可能已更改）参数传递到目标方法，而在原生ANOJ中，只有当它们与args绑定时才能传递更改的参数，这就不那么灵活了。当比较两者时，我实际上也很惊讶，这是不一样的，因为在许多其他方面，Spring AOP试图模仿原生AOP J。
现在关注Spring AOP，您将TesterAspect中最内层的around通知的参数传递给AuditAspect的解决方法是将after通知转换为around通知。
您还需要确保TesterAspect的方面优先级高于AuditAspect，也就是说，您将@Order(1)注解放在TesterAspect上，并将@Order(2)注解放在AuditAspect上。数字越小，优先级越高。优先级越高，意味着proceed()之前和之后的所有内容都比优先级较低的方面执行得更早。这就是您想要的，因为您想要在方法执行之后进行审计，并且在继续进行审计方面之前，tester方面应该已经完成了它的魔术，操纵它的输入参数。

@Component
@Aspect
@Order(1)
public class TesterAspect {
  // ...
}
package de.scrum_master.spring.q77576228;

import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;

import java.lang.reflect.Method;
import java.time.LocalDate;
import java.time.LocalTime;
import java.util.Arrays;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.stream.Collectors;

@Component
@Aspect
@Slf4j
@Order(2)
public class AuditAspect {
  @Around("@annotation(Audited)")
  public Object auditHelper(ProceedingJoinPoint pjp) throws Throwable {
    try {
      Object result = pjp.proceed();
      auditHelper(pjp, null);
      return result;
    } catch (Exception e) {
      auditHelper(pjp, e);
      throw e;
    }
  }

  private void auditHelper(JoinPoint joinPoint, Exception ex) {
    LocalDate date = LocalDate.now();
    LocalTime time = LocalTime.now();

    Method method = ((MethodSignature) joinPoint.getSignature()).getMethod();
    String methodname = method.getName();
    Object[] args = joinPoint.getArgs();

    String arguments = Arrays.stream(args)
      .map(o -> o == null ? "null" : o.toString())
      .collect(Collectors.joining(" | "));
    String base = "accessed " + methodname + " with arguments: " + arguments;
    String statement = (ex == null) ? base : base + " but failed: " + ex.getMessage();

    Map<String, Object> linkedMap = new LinkedHashMap<>();
    linkedMap.put("Time", time);
    linkedMap.put("Date", date);
    linkedMap.put("Log", statement);
    log.info(statement);
  }
}

的数据
控制台日志将更改为：

springRest          : permitted 1234,2345
springRest          : random: 1234,2345
springRest          : 1234
springRest          : 2345
springRest          : Not permitted: 3456
springRest          : Not permitted: 4567
springRest          : 5678
AuditAspect         : accessed getInfo with arguments: 1234,2345 | 1234,5678

型

赞(0）分享  回复(0）举报  5个月前
我来回答

相关问题

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新问答

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com