Spring Boot 项目中使用事件发布和监听来实现消息推送和处理

import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.ApplicationEvent;
 
// 自定义事件类，继承 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;
    }
}
 
// 事件监听器，实现 ApplicationListener 接口
public class CustomEventListener implements ApplicationListener<CustomEvent> {
    @Override
    public void onApplicationEvent(CustomEvent event) {
        System.out.println("接收到事件：" + event.getMessage());
        // 处理接收到的事件
    }
}
 
// 在Spring Boot中使用ApplicationEventPublisher发布事件
@Service
public class CustomEventService {
    @Autowired
    private ApplicationEventPublisher publisher;
 
    public void publish(String message) {
        CustomEvent customEvent = new CustomEvent(this, message);
        publisher.publishEvent(customEvent);
    }
}
 
// 在Spring Boot应用中的某个位置调用publish方法发布事件
@Autowired
private CustomEventService customEventService;
 
public void someMethod() {
    customEventService.publish("发送的自定义消息内容");
}

这个代码示例展示了如何在Spring Boot项目中定义、监听和发布自定义事件。通过实现ApplicationListener接口，我们可以创建一个事件监听器来处理特定事件。通过ApplicationEventPublisher，我们可以在应用程序的任何位置发布事件。这种方式在处理异步消息和事件驱动的架构中非常有用。