当前位置：首页 > news >正文

Spring事件监听机制（三）

news 2025/9/9 5:57:02

为了理解@EvenListener注解的底层原理，我们可以自己实现一个类似的注解模拟实现。

1.定义@MyListener注解

    @Target({ElementType.METHOD})@Retention(RetentionPolicy.RUNTIME)public @interface MyListener {}

2.注解使用

    @Componentstatic class SmsService {private static final Logger log = LoggerFactory.getLogger(SmsService.class);@MyListenerpublic void listener(MyEvent event) {log.debug("发送短信");}}

3.注解解析

public static void main(String[] args) {AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(TestMyListener.class);SmsService smsService = context.getBean(SmsService.class);for(Method method : SmsService.class.getMethods()){if(method.isAnnotationPresent(MyListener.class)){ApplicationListener listener = new ApplicationListener<MyEvent>() {@Overridepublic void onApplicationEvent(MyEvent event) {try {method.invoke(smsService, event);}catch (Exception e){e.printStackTrace();}}};context.addApplicationListener(listener);}}context.getBean(MyService.class).doBusiness();context.close();}

1）获取监听器类

2）通过反射拿到方法

判断方法上的注解是否是我们自定义的注解，如果是，创建ApplicationListener对象（这里使用了泛型去指定事件类型，如果不这样做可能会接收到别的事件而报错，比如说容器关闭事件），重写里面的监听事件的方法，通过反射调用加了@MyListener注解的方法。

3）把监听器加入容器里面。

打印结果：

@MyListener注解实现了事件监听机制。

4.改进点

上面我们固定解析了监听类为SmsService类，现实情况是其它类上也可能加了@MyListener注解，我们可以做得更通用一些。

（1）再写一个监听类EmailService。

    @Componentstatic class EmailService {private static final Logger log = LoggerFactory.getLogger(EmailService.class);@MyListenerpublic void listener(MyEvent event) {log.debug("发送邮件");}}

2）遍历所有满足条件的bean

public static void main(String[] args) {AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(TestMyListener.class);for (String beanName : context.getBeanDefinitionNames()){Object bean = context.getBean(beanName);for(Method method : bean.getClass().getMethods()){if(method.isAnnotationPresent(MyListener.class)){ApplicationListener listener = new ApplicationListener<MyEvent>() {@Overridepublic void onApplicationEvent(MyEvent event) {try {method.invoke(bean, event);}catch (Exception e){e.printStackTrace();}}};context.addApplicationListener(listener);}}}context.getBean(MyService.class).doBusiness();context.close();}

3)测试结果