Spring实现自己的注解-AOP型(二)

接着上文,我们分析了@Async注解的实现原理,这一片文章我们来一步步实现一个自定义的注解。注解实现的功能很简单,记录一个方法的执行时间消耗,并且写入到日志中。在完全仿照@Async之前,我们先看看利用SpringBoot提供的Aspect去实现,同时输出一个可以提供给别的项目使用的spring-boot-starter工程。

定义注解

第一步很简单,我们依样画葫芦,定义一个我们自己的注解,命名为@TimeConsumeLogger。为了方便,我们先将这个注解限定在只能修饰方法上。

import java.lang.annotation.*;
import java.util.concurrent.TimeUnit;

@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Inherited
@Documented
public @interface TimeConsumeLogger {
    String   logTopic() default "";
    TimeUnit timeUnit() default TimeUnit.MILLISECONDS;
}

这个注解很简单,我们在打印时间消耗的日志的时候,对于一些我们已经预估到了的,非常耗时的方法,我们希望用秒级,或者分钟级来进行统计;同时对于一些可以预估到的应该非常快就处理完的方法,我们就应该用毫秒来统计。为了满足对时间颗粒度的控制,我们添加一个timeUnit注解参数。
在设计这个注解的时候我们还要考虑这个注解可能会使用不同的Logger去记录,因此,我们添加一个logTopic参数,用来控制使用哪一个Logger去打印日志。

使用SpringBootStarterAOP

新建一个工程,这个项目我们可以对外提供成为一个spring-boot-starter包,同时,我们需要引入SpringBootAOP,来实现切面变编程。

工程目录.png

整个工程的pom文件如下:

<?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>zsh.tools</groupId>
    <artifactId>utils-helper-starter</artifactId>
    <version>1.0.0-SNAPSHOT</version>
    <name>utils-helper</name>
    <organization>
        <name>mine.name.zsh</name>
    </organization>
    <developers>
        <developer>
            <email>simon.zhu.chn@hotmail.com</email>
        </developer>
    </developers>

    <properties>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-configuration-processor</artifactId>
            <optional>true</optional>
            <scope>compile</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-autoconfigure-processor</artifactId>
            <scope>compile</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-autoconfigure</artifactId>
            <scope>compile</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-aop</artifactId>
            <scope>compile</scope>
        </dependency>
    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>2.1.6.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

</project>

编写Aspect

接下来就应该定义我们的切面类了。我们既然自定义了注解,那么我们的切点就应该是所有被我们注解所修饰的方法。我们对切点的表达式需要做一点小修改,如下:

private final String POINT_CUT = "@annotation(zsh.tools.aop.anno.TimeConsumeLogger)";

上述的切点表达式定义了这个切点为匹配@TimeConsumeLogger所修饰的所有类或方法,我们这里将注解限定在方法上。
定义好切点之后,我们就要开始定义我们的通知(Advice)了。因为我们的的目标简单明确,只是记录一个时间消耗的记录,不会多做任何事情,那么,@Around这个通知是最合适的。@Around这个通知可以在执行完切入点逻辑之后继续执行方法本体,执行完方法本体后又可以继续执行切入点逻辑。

@Around(value=POINT_CUT)
public void doAroundAdvice(ProceedingJoinPoint proceedingJoinPoint) throws Throwable {

    Signature signature = proceedingJoinPoint.getSignature();
    Method method = ((MethodSignature)signature).getMethod();
    // 获取注解参数
    TimeConsumeLogger annotation = method.getAnnotation(TimeConsumeLogger.class);
    Map<String, Object> attributesMap = AnnotationUtils.getAnnotationAttributes(annotation);
    String logTopic = (String) attributesMap.get("logTopic");
    TimeUnit timeUnit = (TimeUnit) attributesMap.get("timeUnit");

    if (logTopic.equals("")) {
        logTopic = proceedingJoinPoint.getTarget().getClass().toString();
    }
    Logger log = LoggerFactory.getLogger(logTopic);

    long s = System.currentTimeMillis();
    proceedingJoinPoint.proceed();
    long e = System.currentTimeMillis() - s;

    log.info( "{} -> COST: [{}] {}", method.toGenericString(), timeUnit.convert(e, TimeUnit.MILLISECONDS), timeUnit.name());
}

这个方法的第一步,我们需要获取切点所匹配的方法。获取到方法之后,我们解析这个方法上修饰的@TimeConsumeLogger注解,读取到注解的参数值。第三步,我们根据参数logTopic来获取slf4j.Logger,用timeUnit参数来获取时间单位。最后我们记录执行本体方法前后的时间,计算时间差,打印到日志中。

编写Starter配置

Starter配置也非常简单,我们的切面是要注册进Spring的Bean管理容器才能生效,因此,我们在Starter配置中定义一个TimeConsumeAspect的Bean,这样子就能使@TimeConsumeLogger注解生效了。

@Configuration
public class ZshToolsStarterAutoConfigure {
    @Bean
    @ConditionalOnMissingBean(TimeConsumeAspect.class)
    @ConditionalOnClass({
        org.slf4j.Logger.class,
        org.slf4j.LoggerFactory.class
    })
    public TimeConsumeAspect timeConsumeAspectBean() {
        return new TimeConsumeAspect();
    }
}

因为我们在通知中用到了slf4j的日志,因此,为了避免项目依赖中不存在slfj4而导致空指针的情况,加入一个@Conditional条件,如果不存在slf4j,我们的@TimeConsumeLogger就不生效
编写完Starter配置之后我们需要在工程的resources文件夹下加入一个 META-INF/spring.factories文件,敲入如下配置:

org.springframework.boot.autoconfigure.EnableAutoConfiguration=zsh.tools.autoconfigure.ZshToolsStarterAutoConfigure

大功告成,接下来使用mvn clean install构建工程,结果会在本机的.m2目录下生成jar包

使用注解

新建一个工程,引入我们编译好的maven依赖,然后执行测试

<dependency>
    <groupId>zsh.tools</groupId>
    <artifactId>utils-helper-starter</artifactId>
    <version>1.0.0-SNAPSHOT</version>
</dependency>
@Component
public class TestComponent {

    @TimeConsumeLogger
    public void Filter a() {
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    @TimeConsumeLogger(logTopic = "ZSH.LOGGERS")
    public void b() {
        try {
            Thread.sleep(1500);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    @TimeConsumeLogger(logTopic = "ZSH.LOGGERS", timeUnit = TimeUnit.SECONDS)
    public void c() {
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

可以看到日志已经打出来了

2019-08-02 18:47:29.129  INFO 887472 --- [           main] class zsh.demos.TestComponent       : public  void zsh.demos.TestComponent.a() -> COST: [1009] MILLISECONDS
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 216,287评论 6 498
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 92,346评论 3 392
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 162,277评论 0 353
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,132评论 1 292
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,147评论 6 388
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,106评论 1 295
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,019评论 3 417
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,862评论 0 274
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,301评论 1 310
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,521评论 2 332
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,682评论 1 348
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,405评论 5 343
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,996评论 3 325
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,651评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,803评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,674评论 2 368
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,563评论 2 352

推荐阅读更多精彩内容