探索Spring事件监听机制的奇妙世界

2023-12-14 15:11:44

前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家。点击跳转到网站。

什么是Spring事件监听机制

Spring事件监听机制是Spring框架中的一种设计模式,主要用于处理应用程序的各种事件。这种机制基于发布-订阅设计模式,允许将业务逻辑解耦,并能更好地组织和管理代码。

使用 Spring 事件监听机制的好处:

  1. 解耦:通过将事件的响应逻辑交给监听器处理,可以将事件源和监听器解耦,降低代码的耦合度。
  2. 可扩展性:可以添加新的监听器来处理新的事件类型,而无需修改原有代码。
  3. 可重用性:相同类型的事件可以在多个地方处理,提高了代码的可重用性。
  4. 异步处理:事件监听机制支持异步处理,可以避免阻塞主线程,提高应用程序的性能。
  5. 事件过滤:可以使用条件筛选需要处理的事件,只对符合条件的事件进行处理。

主要组件

Spring 事件监听机制包括以下几个主要组件:

  1. 事件源(Event Source):事件源是事件的发起者,通常是一个应用程序中的特定组件或服务。当事件源发生特定事件时,会触发事件的发布。
  2. 事件(Event):事件是事件源发出的消息,通常包含与事件相关的数据。事件可以是自定义的类,继承自 Spring 的 ApplicationEvent 类。
  3. 监听器(Listener):监听器是订阅了事件源的事件并负责处理事件的组件。监听器需要实现 Spring 的 ApplicationListener 接口,并指定要监听的事件类型,该接口定义了一个onApplicationEvent方法,用于处理接收到的事件。。
  4. 发布者(Publisher):发布者是负责将事件发布给所有注册的监听器的组件。在 Spring 框架中,可以使用 ApplicationContext的 publishEvent 方法来发布事件。
  5. 应用上下文(ApplicationContext)ApplicationContext是Spring中的一个中心类,它提供了一个将事件发布到监听器的机制。

内置的事件监听类

Spring框架提供了许多内置的事件监听类,用于处理不同的事件。以下是一些常用的Spring事件监听类:

  1. ContextRefreshedEvent:当ApplicationContext被初始化或刷新时触发。可以用来执行在应用程序启动后需要进行的初始化任务。

  2. ContextStartedEvent:当ApplicationContext被启动(调用start()方法)时触发。可以用来执行在应用程序启动后需要进行的特定任务。

  3. ContextStoppedEvent:当ApplicationContext被停止(调用stop()方法)时触发。可以用来执行在应用程序停止前需要进行的清理任务。

  4. ContextClosedEvent:当ApplicationContext被关闭(调用close()方法)时触发。可以用来执行在应用程序关闭前需要进行的清理任务。

  5. RequestHandledEvent:当一个HTTP请求被处理完成后触发。可以用来记录请求的处理信息或进行其他相关操作。

这些只是一些常见的事件监听类,实际上Spring还提供了更多的事件监听类,可以满足不同场景下的需求。开发者也可以自定义事件监听类,继承自ApplicationEvent,以实现自己的特定事件监听逻辑。

Event

自定义事件监听类

自定义事件监听类之前 先来了解一下Spring事件监听机制的基本工作流程:

  1. 定义事件:事件通常是扩展ApplicationEvent的类的对象,它包含有关事件的信息。
  2. 定义监听器:监听器是实现了ApplicationListener接口的类,被定义为处理特定事件类型的类。
  3. 注册监听器:通过将监听器注册到Spring容器中,或者手动添加到ApplicationContext中。
  4. 发布事件:在需要的情况下,通过调用ApplicationContextpublishEvent()方法发布事件,Spring将该事件传递给所有匹配的监听器。

Spring机制基于发布-订阅设计模式,这就像你关注了某个人,他一旦有作品更新,你就能立马收到消息一样。

下面举个例子自定义一个Spring事件监听功能,比如你喜欢波多老师并且关注了她,波多老师一旦发布新电影你就能收到并且观看。具体代码如下:

  1. 定义事件MovieEvent
public class MovieEvent extends ApplicationEvent {

    private String movieName;
    
    public MovieEvent(Actor source , String movieName) {
        super(source);
        this.movieName = movieName;
    }


    public String getMovieName() {
        return movieName;
    }
}
@Data
public class Actor {

    private String name;

}
  1. 定义监听器MovieListener

定义监听器有两种方式,一是实现 ApplicationListener接口,而是使用 @EventListener 注解。下面使用这两种方式分别定义一个监听器。

@Component
public class MovieListener implements ApplicationListener<MovieEvent> {

    @Override
    public void onApplicationEvent(MovieEvent event) {
        Actor actor = (Actor) event.getSource();
        String movieName = event.getMovieName();

        System.out.println("实现类监听器 监听到"+actor.getName()+" 发布了新电影,电影名字叫:"+movieName);
    }
}
@Component
public class MovieListener2 {

    @EventListener
    public void listener(MovieEvent event) {
        Actor actor = (Actor) event.getSource();
        String movieName = event.getMovieName();

        System.out.println("注解监听器 监听到 "+actor.getName()+" 发布了新电影,电影名字叫:"+movieName);
    }
}

@EventListener注解是方法级别的注解,使用它可以在一个类中定义多个监听方法。

  1. 测试事件发布功能
@RunWith(SpringRunner.class)
@SpringBootTest(classes = MqApplication.class)
public class RestTest {

    @Autowired
    private ApplicationEventPublisher applicationEventPublisher;

    @Autowired
    private ApplicationContext applicationContext;

    @Test
    public void testEvent(){
        Actor boDuo = new Actor();
        boDuo.setName("波多老师");

        MovieEvent movieEvent = new MovieEvent(boDuo , "好好学习,别胡思乱想!");
        applicationContext.publishEvent(movieEvent);
    }
}

测试结果:

实现类监听器 监听到波多老师 发布了新电影,电影名字叫:好好学习,别胡思乱想!
注解监听器 监听到 波多老师 发布了新电影,电影名字叫:好好学习,别胡思乱想!

ApplicationContext 继承了 ApplicationEventPublisher ,所以发布事件既可以通过 ApplicationEventPublisher#publishEvent() 方法,也可以通过ApplicationContext#publishEvent() 方法。

通过上面的测试结果可以发现,两个监听类最终都监听到了MovieEvent ,都在控制台打印结果了。
实际上Spring的事件监听机制对于同一个事件的监听是同步的,默认情况下是同步的。当事件被发布时,Spring会依次通知所有监听该事件的监听器,并在事件发布的同一线程中依序执行监听器的处理逻辑。
这意味着,当一个事件被触发后,事件监听器的执行是按照注册的顺序依次进行的,前一个监听器完成后才会执行下一个监听器。只有当所有监听器都执行完毕后,事件发布者才会继续往下执行。

如果想实现异步可以在监听器的方法上添加@Async注解,或在配置文件中进行相应的配置,可以使监听器的处理逻辑在不同的线程中执行,从而实现异步处理。

如果是想实现监听器按照指定顺序执行,可以使用 @Order 注解,@Order注解的值越小,优先级越高,即执行顺序越靠前。

总结

总的来说,Spring事件监听机制使用起来简单方便,可以是组件之间解耦,提高了代码的可维护性和可扩展性。当需要使用监听机制的时候,Spring的事件监听机制是个很好的选择之一。

文章来源:https://blog.csdn.net/qq_39654841/article/details/134001344
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。