springboot创建监听和处理事件的操作方法

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

@Service
public class CustomEventPublisher {
    @Autowired
    private ApplicationEventPublisher applicationEventPublisher;
    public void publishEvent(final String message) {
        CustomEvent customEvent = new CustomEvent(this, message);
        applicationEventPublisher.publishEvent(customEvent);
    }
}

@Component
public class CustomEventListener {
    @EventListener
    public void handleCustomEvent(CustomEvent customEvent) {
        System.out.println("Received event - " + customEvent.getMessage());
    }
}

@Async
@EventListener
public void handleCustomEventAsync(CustomEvent customEvent) {
    System.out.println("Received event asynchronously - " + customEvent.getMessage());
}

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@EventListener
public @interface OnCustomEvent {
}

@Component
public class AnotherEventListener {
    @OnCustomEvent
    public void onCustomEvent(CustomEvent customEvent) {
        System.out.println("Handled by custom annotation - " + customEvent.getMessage());
    }
}