Spring事件注解@EventListener【观察】

2023-11-29 01:01
文章标签 java spring 事件 注解 观察 eventlistener

本文主要是介绍Spring事件注解@EventListener【观察】，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

一、背景

在开发工作中，我们常常会遇到这样一种情况：完成一项任务后，需要向其他模块广播消息或通知，以触发其他事件的处理。逐个发送请求固然可行，但更好的方式是采用事件监听，它是设计模式中的发布-订阅模式和观察者模式的一种实现。

观察者模式简单来说就是一种角色扮演，你在做某件事时有人在一旁观察你。当这个人观察到你有兴趣的特定事件发生时，他们会根据这个事件做一些其他的事情。但请注意，任何想要观察你的人都必须先到你这儿进行登记，否则你将无法通知到他们，或者他们没有资格来观察你。

在Spring容器中，我们可以监听并触发各种事件。通常有两种方法可以实现这一目标：使用ApplicationListener接口和使用@EventListener注解。这两种方法都能帮助我们更好地管理和响应应用程序中的各种事件。

二、简介

2.1 用途

为了实现一个能够监听应用程序事件的监听器方法，我们可以使用特定的注解来标记该方法，并定义其支持的事件类型。

如果监听器方法只支持单一的事件类型，我们可以将其参数声明为该事件类型的唯一实例。例如，如果我们的监听器方法只监听ApplicationEvent实例，则可以将其参数声明为ApplicationEvent类型。

如果监听器方法支持多种事件类型，我们可以使用注解的classes属性来指定一个或多个支持的事件类型。这样，该方法就可以监听到在classes属性中指定的任何事件类型。

2.2 事件处理条件

可以通过 condition 属性指定一个SpEL表达式，如果返回 “true”, “on”, “yes”, or “1” 中的任意一个，则事件会被处理，否则不会。

2.3 处理器

在Spring框架中，@EventListener注解的处理是通过内部的EventListenerMethodProcessor类进行的。这个类负责寻找带有@EventListener注解的方法，并在适当的时候触发它们。

当使用Java配置时，EventListenerMethodProcessor会自动注册到Spring容器中。你只需要在带有@EventListener注解的方法上添加@Component或@Service等注解，Spring就会自动检测并注册这个方法。

2.4 返回值

被标注的方法可以没有返回值，也可以有返回值。当有返回值是，其返回值会被当作为一个新的事件发送。如果返回类型是数组或集合，那么数组或集合中的每个元素都作为一个新的单独事件被发送。

2.5 异常处理

同步监听器抛出的所有checked异常都会被封装成 UndeclaredThrowableException ，因为事件发布者只能处理运行时异常（unchecked异常）。

2.6 异步监听器

当需要异步处理监听器时，可以在监听器方法上再增加另外的一个Spring注解 @Async，但需要注意以下限制：

监听器报错不会传递给事件发起者，因为双方已经不在同一个线程了。
异步监听器的非空返回值不会被当作新的事件发布。如果需要发布新事件，需要注入 ApplicationEventPublisher后手动发布。

2.7 监听器排序

如果同一个事件可能会被多个监听器监听处理，那么我们可以使用 @Order 注解对各个监听器进行排序。

2.8 源码

@Target({ElementType.METHOD, ElementType.ANNOTATION_TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface EventListener {/*** Alias for {@link #classes}.*/@AliasFor("classes")Class<?>[] value() default {};/*** 可以处理的事件类型*/@AliasFor("value")Class<?>[] classes() default {};/*** SpEL表达式判断是否满足处理条件*/String condition() default "";/*** 可以给监听器指定一个id，默认是方法的全限定名，如：mypackage.MyClass.myMethod()*/String id() default "";}

三、示例详解

3.1 单一事件监听器

发布事件

@Service
public class EventPublisher {private ApplicationEventPublisher  eventPublisher;@Autowiredpublic void setEventPublisher(ApplicationEventPublisher eventPublisher) {this.eventPublisher = eventPublisher;}public void publishPersonSaveEvent(){PersonSaveEvent  saveEvent = new PersonSaveEvent();saveEvent.setId(1);saveEvent.setName("i余数");saveEvent.setAge(18);eventPublisher.publishEvent(saveEvent);}
}

监听事件

@Slf4j
@Service
public class EventListenerService {@EventListenerpublic void handleForPersonSaveEvent(PersonSaveEvent saveEvent){log.info("saveEvent -> {}", saveEvent);}
}

结果验证

saveEvent -> PersonSaveEvent(id=1, name=i余数, age=18)

3.2 使用classes实现多事件监听器

发布事件
在上一个示例的基础上，再多加一个PersonUpdateEvent事件。

public void publishPersonUpdateEvent(){PersonUpdateEvent  updateEvent = new PersonUpdateEvent();updateEvent.setId(1);updateEvent.setName("i余数");updateEvent.setAge(19);eventPublisher.publishEvent(updateEvent);
}

监听事件

@EventListener(classes = {PersonSaveEvent.class, PersonUpdateEvent.class})
public void handleForPersonSaveAndUpdateEvent(Object event){log.info("multi handle event -> {}", event);
}

验证结果
可以监听到多个事件

multi handle event -> PersonSaveEvent(id=1, name=i余数, age=18)
multi handle event -> PersonUpdateEvent(id=1, name=i余数, age=19)

3.3 使用condition筛选监听的事件

发布事件

public void publishPersonSaveEvent(){PersonSaveEvent  saveEvent = new PersonSaveEvent();saveEvent.setId(1);saveEvent.setName("i余数");saveEvent.setAge(18);eventPublisher.publishEvent(saveEvent);PersonSaveEvent  saveEvent2 = new PersonSaveEvent();saveEvent2.setId(2);saveEvent2.setName("i余数");saveEvent2.setAge(18);eventPublisher.publishEvent(saveEvent2);
}

监听事件

@EventListener(condition = "#root.event.getPayload().getId() == 1")
public void handleByCondition(PersonSaveEvent saveEvent){log.info("只处理id等于1的 -> {}", saveEvent);
}

结果验证
id为2的事件不满足条件，所以不会执行。

只处理id等于1的 -> PersonSaveEvent(id=1, name=i余数, age=18)

3.4 有返回值的监听器

3.4.1 返回一个单一对象

发布事件

public void publishPersonSaveEvent(){PersonSaveEvent  saveEvent = new PersonSaveEvent();saveEvent.setId(1);saveEvent.setName("i余数");saveEvent.setAge(18);eventPublisher.publishEvent(saveEvent);
}

监听事件

@EventListener
public void handleForPersonUpdateEvent(PersonUpdateEvent updateEvent){log.info("handle update event -> {}", updateEvent);
}@EventListener
public PersonUpdateEvent handleHaveReturn(PersonSaveEvent saveEvent){log.info("handle save event -> {}", saveEvent);PersonUpdateEvent updateEvent = new PersonUpdateEvent();updateEvent.setId(saveEvent.getId());updateEvent.setName(saveEvent.getName());updateEvent.setAge(saveEvent.getAge());return updateEvent;
}

验证结果
可以看到我们监听到了2个事件，PersonSaveEvent是我们主动发布的事件，PersonUpdateEvent 是 handleHaveReturn 方法的返回值，会被 Spring 自动当作一个事件被发送。

handle save event -> PersonSaveEvent(id=1, name=i余数, age=18)
handle update event -> PersonUpdateEvent(id=1, name=i余数, age=18)
3.4.2 返回一个集合

将监听器稍作修改，使其返回一个集合。

@EventListener
public List<PersonUpdateEvent> handleHaveReturn(PersonSaveEvent saveEvent){log.info("handle save event -> {}", saveEvent);List<PersonUpdateEvent> events = new ArrayList<>();PersonUpdateEvent updateEvent = new PersonUpdateEvent();updateEvent.setId(saveEvent.getId());updateEvent.setName(saveEvent.getName());updateEvent.setAge(saveEvent.getAge());events.add(updateEvent);PersonUpdateEvent updateEvent2 = new PersonUpdateEvent();BeanUtils.copyProperties(updateEvent, updateEvent2);events.add(updateEvent2);return events;}

查看结果可以发现，集合中的每个对象都被当作一个单独的事件进行发送。

handle save event -> PersonSaveEvent(id=1, name=i余数, age=18)
handle update event -> PersonUpdateEvent(id=1, name=i余数, age=18)
handle update event -> PersonUpdateEvent(id=1, name=i余数, age=18)
3.4.3 返回一个数组

和返回值为集合一样，数组中的每个对象都被当作一个单独的事件进行发送。

3.4.4 异步监听器

创建两个监听器，一个同步一个异步，异步监听器就是在方法上加一个 @Async 标签即可（你可以指定线程池）。

@EventListener
public void handleForPersonSaveEvent(PersonSaveEvent saveEvent){log.info("handle event -> {}", saveEvent);
}@Async
@EventListener
public void handleForPersonSaveEventAsync(PersonSaveEvent saveEvent){log.info("async handle event -> {}", saveEvent);
}

从执行结果可以看出，异步线程是 task-1，不是主线程 main，即异步是生效的。

INFO 3851 --- [           main] i.k.s.e.listener.EventListenerService    : handle event -> PersonSaveEvent(id=1, name=i余数, age=18)
INFO 3851 --- [         task-1] i.k.s.e.listener.EventListenerService    : async handle event -> PersonSaveEvent(id=1, name=i余数, age=18)

3.5 监听器异常处理

3.5.1 同步异常处理

使用 SimpleApplicationEventMulticaster 处理同步监听器抛出异常。
先定义一个ErrorHandler:

@Slf4j
@Component
public class MyErrorHandler implements ErrorHandler {@Overridepublic void handleError(Throwable t) {log.info("handle error -> {}", t.getClass());}
}

将自定义ErrorHandler绑定到 SimpleApplicationEventMulticaster。

@Slf4j
@Service
public class EventListenerService {@Autowiredprivate SimpleApplicationEventMulticaster simpleApplicationEventMulticaster;@Autowiredprivate MyErrorHandler errorHandler;@PostConstructpublic void init(){simpleApplicationEventMulticaster.setErrorHandler(errorHandler);}@Order(1)@EventListenerpublic void handleForPersonSaveEvent(PersonSaveEvent saveEvent) throws AuthException {log.info("handle event -> {}", saveEvent);throw new AuthException("test exception");}
}

结果：可以看到捕获的异常是 UndeclaredThrowableException。

handle event -> PersonSaveEvent(id=1, name=i余数, age=18)
handle error -> class java.lang.reflect.UndeclaredThrowableException
3.5.2 异步异常处理

使用 SimpleAsyncUncaughtExceptionHandler 来处理 @Async 抛出的异常。

@Configuration
public class AsyncConfig implements AsyncConfigurer {@Overridepublic AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {return new SimpleAsyncUncaughtExceptionHandler();}
}

监听器代码：人为的抛出一个异常。

@Async
@EventListener
public void handleForPersonSaveEvent(PersonSaveEvent saveEvent) throws AuthException {log.info("handle event -> {}", saveEvent);throw new AuthException("test exception");
}

结果: SimpleAsyncUncaughtExceptionHandler捕获到了 @Async 方法抛出的异常

 INFO 4416 --- [         task-1] i.k.s.e.listener.EventListenerService    : handle event -> PersonSaveEvent(id=1, name=i余数, age=18)
ERROR 4416 --- [         task-1] .a.i.SimpleAsyncUncaughtExceptionHandler : Unexpected exception occurred invoking async method: public void xxxx.handleForPersonSaveEvent(xxxx.PersonSaveEvent) throws javax.security.auth.message.AuthException

3.6 监听器排序

如果同时有多个监听器监听同一个事件，默认情况下监听器的执行顺序是随机的，如果想要他们按照某种顺序执行，可以借助Spring的另外一个注解 @Order 实现。

创建三个监听器，并使用@Order 排好序。

@Order(1)
@EventListener
public void handleForPersonSaveEvent(PersonSaveEvent saveEvent){log.info("handle event1 -> {}", saveEvent);
}@Order(2)
@EventListener
public void handleForPersonSaveEvent2(PersonSaveEvent saveEvent){log.info("handle event2 -> {}", saveEvent);
}@Order(3)
@EventListener
public void handleForPersonSaveEvent3(PersonSaveEvent saveEvent){log.info("handle event3 -> {}", saveEvent);
}

从执行结果可以看到，确实是按照@Order中指定的顺序执行的。

handle event1 -> PersonSaveEvent(id=1, name=i余数, age=18)
handle event2 -> PersonSaveEvent(id=1, name=i余数, age=18)
handle event3 -> PersonSaveEvent(id=1, name=i余数, age=18)

四、总结

在Spring框架中，@EventListener注解用于标识监听器方法，可以监听Spring ApplicationEvent或其他任意对象的事件。

当一个方法被标注为@EventListener时，它就被视为一个事件监听器，可以接收和响应特定类型的事件。这个方法可以在事件发布时被调用，以处理该事件。在Spring框架中，EventListenerMethodProcessor负责寻找和调用带有@EventListener注解的方法。

@EventListener注解可以设置两个属性：value和classes，用于指定监听器监听的事件类型。如果value和classes没有设置值，那么被标注的方法必须有一个且只能有一个参数。如果value或classes设置了值，单个Class值表示监听器可以不用设置参数；多个Class值则要求被标注的方法一定不要设置参数。这是因为在监听事件时，通过反射监听方法处理事件，事件转换成方法参数时，若类型不一致，可能会发生类型转换异常。

此外，还有一个注解@TransactionalEventListener，它继承了@EventListener的功能，并添加了新的特性。这个注解可以用于在事务处理期间监听事件，并且可以根据需要自动回滚事务。

总的来说，EventListener是一种非常有用的技术，可以帮助我们更好地管理和响应应用程序中的事件。在Spring框架中，我们可以使用@EventListener注解来方便地创建和注册事件监听器，从而实现更高效的事件处理和控制。

这篇关于Spring事件注解@EventListener【观察】的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/430870。

相关文章

Java中流式并行操作parallelStream的原理和使用方法

Java中流式并行操作parallelStream的原理和使用方法

《Java中流式并行操作parallelStream的原理和使用方法》本文详细介绍了Java中的并行流（parallelStream）的原理、正确使用方法以及在实际业务中的应用案例,并指出在使用并行流... 目录Java中流式并行操作parallelStream0. 问题的产生1. 什么是parallelS
阅读更多...
Java中Redisson 的原理深度解析

Java中Redisson 的原理深度解析

《Java中Redisson的原理深度解析》Redisson是一个高性能的Redis客户端,它通过将Redis数据结构映射为Java对象和分布式对象,实现了在Java应用中方便地使用Redis,本文... 目录前言一、核心设计理念二、核心架构与通信层1. 基于 Netty 的异步非阻塞通信2. 编解码器三、
阅读更多...
SpringBoot基于注解实现数据库字段回填的完整方案

SpringBoot基于注解实现数据库字段回填的完整方案

《SpringBoot基于注解实现数据库字段回填的完整方案》这篇文章主要为大家详细介绍了SpringBoot如何基于注解实现数据库字段回填的相关方法,文中的示例代码讲解详细,感兴趣的小伙伴可以了解... 目录数据库表pom.XMLRelationFieldRelationFieldMapping基础的一些代
阅读更多...
一篇文章彻底搞懂macOS如何决定java环境

一篇文章彻底搞懂macOS如何决定java环境

《一篇文章彻底搞懂macOS如何决定java环境》MacOS作为一个功能强大的操作系统,为开发者提供了丰富的开发工具和框架,下面：本文主要介绍macOS如何决定java环境的相关资料,文中通过代码... 目录方法一：使用 which命令方法二：使用 Java_home工具（Apple 官方推荐）那问题来了，
阅读更多...
Java HashMap的底层实现原理深度解析

Java HashMap的底层实现原理深度解析

《JavaHashMap的底层实现原理深度解析》HashMap基于数组+链表+红黑树结构,通过哈希算法和扩容机制优化性能,负载因子与树化阈值平衡效率,是Java开发必备的高效数据结构,本文给大家介绍... 目录一、概述：HashMap的宏观结构二、核心数据结构解析1. 数组（桶数组）2. 链表节点（Node
阅读更多...
Java AOP面向切面编程的概念和实现方式

Java AOP面向切面编程的概念和实现方式

《JavaAOP面向切面编程的概念和实现方式》AOP是面向切面编程,通过动态代理将横切关注点（如日志、事务）与核心业务逻辑分离,提升代码复用性和可维护性,本文给大家介绍JavaAOP面向切面编程的概... 目录一、AOP 是什么？二、AOP 的核心概念与实现方式核心概念实现方式三、Spring AOP 的关
阅读更多...
详解SpringBoot+Ehcache使用示例

详解SpringBoot+Ehcache使用示例

《详解SpringBoot+Ehcache使用示例》本文介绍了SpringBoot中配置Ehcache、自定义get/set方式,并实际使用缓存的过程,文中通过示例代码介绍的非常详细,对大家的学习或者... 目录摘要概念内存与磁盘持久化存储：配置灵活性：编码示例引入依赖：配置ehcache.XML文件：配置
阅读更多...
Java 虚拟线程的创建与使用深度解析

Java 虚拟线程的创建与使用深度解析

《Java虚拟线程的创建与使用深度解析》虚拟线程是Java19中以预览特性形式引入,Java21起正式发布的轻量级线程,本文给大家介绍Java虚拟线程的创建与使用,感兴趣的朋友一起看看吧... 目录一、虚拟线程简介1.1 什么是虚拟线程？1.2 为什么需要虚拟线程？二、虚拟线程与平台线程对比代码对比示例：三
阅读更多...
Java中的.close()举例详解

Java中的.close()举例详解

《Java中的.close()举例详解》.close()方法只适用于通过window.open()打开的弹出窗口,对于浏览器的主窗口,如果没有得到用户允许是不能关闭的,：本文主要介绍Java中的.... 目录当你遇到以下三种情况时，一定要记得使用 .close()：用法作用举例如何判断代码中的 input
阅读更多...
Spring Gateway动态路由实现方案

Spring Gateway动态路由实现方案

《SpringGateway动态路由实现方案》本文主要介绍了SpringGateway动态路由实现方案,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随... 目录前沿何为路由RouteDefinitionRouteLocator工作流程动态路由实现尾巴前沿S
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2