springboot 事件发布订阅

在 Spring Boot 中，可以使用 Spring Framework 提供的事件机制来实现事件发布订阅。

第一步，需要定义事件。可以创建一个类，继承自 ApplicationEvent 类，表示一个事件。例如：

public class MyEvent extends ApplicationEvent {
    public MyEvent(Object source) {
        super(source);
    }
}

第二步，需要在发布事件的地方发送事件。可以使用 ApplicationContext 的 publishEvent 方法来发送事件。例如：

@Autowired
private ApplicationContext applicationContext;

public void doSomething() {
    MyEvent event = new MyEvent(this);
    applicationContext.publishEvent(event);
}

第三步，需要在订阅事件的地方接收事件。可以创建一个类，实现 ApplicationListener 接口，并指定要监听的事件类型。例如：

@Component
public class MyEventListener implements ApplicationListener<MyEvent> {
    @Override
    public void onApplicationEvent(MyEvent event) {
        // 处理事件
    }
}

在上面的例子中，MyEventListener 类标记为 @Component，表示它是一个 Spring Bean，并且实现了 ApplicationListener 接口，指定要监听 MyEvent 类型的事件。当事件被发布时，MyEventListener 将会自动接收事件并处理。

通过这种方式，可以在 Spring Boot 应用程序中实现事件发布订阅的功能。