springboot实现监听机制

在Spring Boot中，可以使用Spring Framework提供的事件机制来实现监听功能。

首先，需要定义一个事件类，它是一个普通的Java类，可以包含一些事件相关的属性。例如：

public class MyEvent {
    private String message;

    public MyEvent(String message) {
        this.message = message;
    }

    public String getMessage() {
        return message;
    }
}

然后，创建一个事件发布者类，用于发布事件。可以使用Spring Framework提供的ApplicationEventPublisher接口来实现事件发布功能。例如：

@Service
public class MyEventPublisher {

    private final ApplicationEventPublisher eventPublisher;

    public MyEventPublisher(ApplicationEventPublisher eventPublisher) {
        this.eventPublisher = eventPublisher;
    }

    public void publishEvent(String message) {
        MyEvent event = new MyEvent(message);
        eventPublisher.publishEvent(event);
    }
}

接下来，创建一个事件监听器类，用于处理事件。可以使用Spring Framework提供的ApplicationListener接口来实现事件监听功能。例如：

@Component
public class MyEventListener implements ApplicationListener<MyEvent> {

    @Override
    public void onApplicationEvent(MyEvent event) {
        System.out.println("Received message: " + event.getMessage());
        // 处理事件逻辑
    }
}

最后，可以在任何需要发布事件的地方注入MyEventPublisher并调用publishEvent方法来发布事件。例如：

@RestController
public class MyController {

    private final MyEventPublisher eventPublisher;

    public MyController(MyEventPublisher eventPublisher) {
        this.eventPublisher = eventPublisher;
    }

    @GetMapping("/publish")
    public String publishEvent() {
        eventPublisher.publishEvent("Hello, world!");
        return "Event published";
    }
}

当/publish接口被调用时，MyEventPublisher会发布一个MyEvent事件，然后MyEventListener会接收到该事件并进行处理。

需要注意的是，Spring Boot会自动扫描并注册所有实现了ApplicationListener接口的Bean作为事件监听器，因此无需额外配置