Spring Boot事件监听使用指南

在Spring Boot中，事件监听是一种常见的设计模式，用于在事件发生时通知感兴趣的组件。通过事件监听机制，我们可以实现模块之间的松耦合，增强系统的可扩展性和可维护性。本文将详细介绍如何通过实现类和使用注解@EventListener的方式来实现事件监听。

什么是Spring事件

Spring事件是一种观察者模式的实现。Spring提供了一个事件发布-订阅模型，允许我们定义和监听事件。当事件发生时，事件发布者会发布事件，所有注册了该事件的监听器都会收到通知并作出相应的处理。

通过实现类的方式实现事件监听

1. 定义事件类

首先，我们需要定义一个事件类。事件类需要继承ApplicationEvent。

import org.springframework.context.ApplicationEvent;public class CustomEvent extends ApplicationEvent {private String message;public CustomEvent(Object source, String message) {super(source);this.message = message;}public String getMessage() {return message;}
}

2. 发布事件

接下来，我们需要一个事件发布者来发布事件。可以在任意Spring Bean中发布事件。

import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.ApplicationEventPublisherAware;
import org.springframework.stereotype.Component;@Component
public class CustomEventPublisher implements ApplicationEventPublisherAware {private ApplicationEventPublisher applicationEventPublisher;@Overridepublic void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {this.applicationEventPublisher = applicationEventPublisher;}public void publishEvent(String message) {CustomEvent event = new CustomEvent(this, message);applicationEventPublisher.publishEvent(event);}
}

3. 创建事件监听器

然后，我们需要创建一个事件监听器来处理事件。监听器需要实现ApplicationListener接口。

import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;@Component
public class CustomEventListener implements ApplicationListener<CustomEvent> {@Overridepublic void onApplicationEvent(CustomEvent event) {System.out.println("Received custom event - " + event.getMessage());}
}

4. 测试事件监听

最后，我们可以通过Spring Boot的入口类来测试事件监听的效果。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
public class EventDemoApplication implements CommandLineRunner {@Autowiredprivate CustomEventPublisher customEventPublisher;public static void main(String[] args) {SpringApplication.run(EventDemoApplication.class, args);}@Overridepublic void run(String... args) throws Exception {customEventPublisher.publishEvent("Hello, Spring Events!");}
}

启动应用程序，您应该会在控制台看到监听器输出的消息。

使用@EventListener注解实现事件监听

除了实现ApplicationListener接口，Spring还提供了另一种更简洁的方式来监听事件，即使用@EventListener注解。

1. 定义事件类

事件类与前面的定义相同。

import org.springframework.context.ApplicationEvent;public class CustomEvent extends ApplicationEvent {private String message;public CustomEvent(Object source, String message) {super(source);this.message = message;}public String getMessage() {return message;}
}

2. 发布事件

事件发布的方式也与前面相同。

import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.ApplicationEventPublisherAware;
import org.springframework.stereotype.Component;@Component
public class CustomEventPublisher implements ApplicationEventPublisherAware {private ApplicationEventPublisher applicationEventPublisher;@Overridepublic void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {this.applicationEventPublisher = applicationEventPublisher;}public void publishEvent(String message) {CustomEvent event = new CustomEvent(this, message);applicationEventPublisher.publishEvent(event);}
}

3. 创建事件监听器

这次，我们使用@EventListener注解来定义事件监听器。

import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;@Component
public class CustomEventListener {@EventListenerpublic void handleCustomEvent(CustomEvent event) {System.out.println("Received custom event - " + event.getMessage());}
}

4. 测试事件监听

通过Spring Boot的入口类来测试事件监听的效果，同样可以使用前面提供的测试代码。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
public class EventDemoApplication implements CommandLineRunner {@Autowiredprivate CustomEventPublisher customEventPublisher;public static void main(String[] args) {SpringApplication.run(EventDemoApplication.class, args);}@Overridepublic void run(String... args) throws Exception {customEventPublisher.publishEvent("Hello, Spring Events!");}
}