您现在的位置是：首页 > Java

当前栏目

[java][annotation][@Aspect]Java注解与切面使用

2023-03-02 10:31:17 时间

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][]

import org.springframework.kafka.annotation.KafkaListener;
    
    import java.lang.annotation.*;
    
    
    @Target({ ElementType.TYPE, ElementType.METHOD, ElementType.ANNOTATION_TYPE })
    @Retention(RetentionPolicy.RUNTIME)
    @Documented
    @KafkaListener
    public @interface Listener {
    
        String[] topics() default {};
    
    }
    
    import lombok.extern.slf4j.Slf4j;
    import org.apache.kafka.clients.consumer.ConsumerRecord;
    import org.aspectj.lang.JoinPoint;
    import org.aspectj.lang.annotation.Aspect;
    import org.aspectj.lang.annotation.Before;
    import org.aspectj.lang.reflect.MethodSignature;
    import org.springframework.stereotype.Component;
    
    import java.lang.reflect.Method;
    
    @Aspect
    @Component
    @Slf4j
    public class ListenAspect {
        @Before("@annotation(Listener)")
        public void beforeListener(JoinPoint point) {
            Object[] args = point.getArgs();
            if (args[0] != null && args[0] instanceof ConsumerRecord) {
                ConsumerRecord consumerRecord = (ConsumerRecord) args[0];
                log.debug("consumerRecord:{}", consumerRecord.toString());
    
                String value = consumerRecord.value().toString();
                log.trace("value:{}", value);
            }
    
            Class<?> className = point.getTarget().getClass();
            String methodName = point.getSignature().getName();
            Class[] argClass = ((MethodSignature) point.getSignature()).getParameterTypes();
            log.trace("className:" + className);
            log.trace("methodName:" + methodName);
            log.trace("argClass:" + argClass);
    
            if (argClass[0] != null) {
                log.trace("argClass[0]:" + argClass[0].toString());
    //            try {
    //                ConsumerRecord consumerRecord = (ConsumerRecord)argClass[0].newInstance();
    //                log.debug("consumerRecord:{}", consumerRecord.toString());
    //            } catch (InstantiationException|IllegalAccessException e) {
    //                e.printStackTrace();
    //            }
            }
    
            try {
                Method method = className.getMethod(methodName, argClass);
                log.trace("method:" + method);
    
                if (method.isAnnotationPresent(Listener.class)) {
                    Listener annotation = method.getAnnotation(Listener.class);
                    log.trace("annotation:" + annotation);
                    log.trace("topics:" + annotation.topics());
                }
            } catch (Exception e) {
                log.warn(e.getMessage(), e);
            }
        }
    }

转载于:https://my.oschina.net/u/2464371/blog/3056316

[2019_Python_]: https://my.oschina.net/u/2663968/blog/3061697
[hot3.png]: /images/20220113/ee6ca0d029a3451a838c6844f24df78f.png

猜你喜欢

3dmax界面字体很小怎么解决
手把手教你如何创建及使用Go module
Go错误集锦 | 通过示例理解数据竞争及竞争条件
火凤凰插件 PhoenixFD for maya/3ds max下载安装教程
深入浅出Go泛型之泛型使用三步曲
GoLand/IntelliJ中提高研发效率的5个使用技巧
Go泛型实战 | 如何在结构体中使用泛型
程序员必须知道的7种数据结构
硬核，图解bufio包系列之读取原理
SketchUp 2021、2022、2023下载安装教程
硬核，图解bufio包系列之写入原理篇
物联网、大数据、人工智能——智慧农业的视频监控与数据处理
Pencil+ 4.0.3 for Maya下载安装教程
转录组分析实战第一天就踩的坑——sed与换行符的恩怨
bufio包系列之一个误用bufio读取的示例
Go错误集锦 | 字符串格式化竟然能引起死锁
Go错误集锦 | append操作造成数据竞争
Go错误集锦 | map中因mutex使用不当导致的数据竞争
Go实战 | 实现http请求排队处理
AirBuddy for Mac(AirPods耳机管理)

zl程序教程

当前栏目

[java][annotation][@Aspect]Java注解与切面使用

相关文章