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组件（比如一个服务类），并注入ApplicationEventPublisher：
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Service;
@Service
public class CustomEventPublisher {
private final ApplicationEventPublisher applicationEventPublisher;
public CustomEventPublisher(ApplicationEventPublisher applicationEventPublisher) {
this.applicationEventPublisher = applicationEventPublisher;
}
public void publishCustomEvent(String message) {
CustomEvent customEvent = new CustomEvent(this, message);
applicationEventPublisher.publishEvent(customEvent);
}
}
3. 创建事件监听器： 创建一个监听事件的类，实现ApplicationListener接口，并处理相应的事件：
import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;
@Component
public class CustomEventListener implements ApplicationListener<CustomEvent> {
@Override
public void onApplicationEvent(CustomEvent event) {
System.out.println("Received custom event: " + event.getMessage());
// 处理事件的逻辑
}
}
4. 触发事件： 在需要的地方调用事件发布者的方法触发事件：
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class SomeService {
private final CustomEventPublisher customEventPublisher;
@Autowired
public SomeService(CustomEventPublisher customEventPublisher) {
this.customEventPublisher = customEventPublisher;
}
public void performSomeBusinessLogic() {
// 执行业务逻辑
// ...
// 发布自定义事件
customEventPublisher.publishCustomEvent("Custom event message");
}
}
通过这样的方式，你就可以在Spring应用程序中使用自定义事件来实现事件驱动的架构。当SomeService中的performSomeBusinessLogic方法被调用时，它会触发自定义事件，然后监听器CustomEventListener将捕获并处理这个事件。
转载请注明出处：http://www.pingtaimeng.com/article/detail/6957/Spring