springboot监听器

发布器（ApplicationEventPublisher）：用来在业务逻辑中发布事件。

广播器（ApplicationEventMulticaster）：用来把发布的事件广播给支持当前事件的监听器。

监听器（ApplicationListener）：用来监听自己感兴趣的事件，当程序发布事件时，可以执行一些相应的业务逻辑。ApplicationListener定义了onApplicationEvent方法，监听器监听到事件发布后执行onApplicationEvent方法。

事件（ApplicationEvent）：用来定义事件。

程序在执行时调用SpringBoot的发布器（ApplicationEventPublisher）发布事件（ApplicationEvent）

发布器（ApplicationEventPublisher）调用广播器（ApplicationEventMulticaster）把事件广播给支持当前事件的监听器（ApplicationListener）。通俗的话描述，就是广播器根据发布的事件，从所有的监听器中筛选出支持当前事件的监听器。

执行监听器。Spring boot的监听器必须实现ApplicationListener接口并重写onApplicationEvent(Eevent)方法。执行监听器就是广播器筛选出符合条件的监听器后执行onApplicationEvent方法。

//发布器中实现ApplicationEventPublisherAware接口,同时初始化ApplicationEventPublisher
@Slf4j
@Component
public class cachePublisher implements ApplicationEventPublisherAware {

    //spring boot的事件发布器
    private ApplicationEventPublisher applicationEventPublisher;

    @Override
    public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {
        this.applicationEventPublisher = applicationEventPublisher;
    }
    
    /**
     * Desc: 发布事件，根据发布缓存事件的参数类型先构造对应的Event对象再发布事件 <br>
     * date: 2022/9/3   
     * @param event
     * @return void
     */
    public void publishEvent(Object event){
        applicationEventPublisher.publishEvent(new RefreshCacheEvent(this,(RefreshCache)event));
    }
}

public class RefreshCacheEvent extends ApplicationEvent {

    private final RefreshCache refreshCache;

    public RefreshCache getRefreshCache() {
        return refreshCache;
    }

    public RefreshEvent(Object source, RefreshCache refreshCache) {
        super(source);
        Assert.notNull(refreshCache, "refreshCache must not be null");
        this.refreshCache = refreshCache;
    }
}

@Slf4j
@Component
@ConditionalOnBean(name={"refreshCacheService"})
public class RefreshCacheListener {

    @Resource
    private RefreshCacheService refreshCacheService;

    /***
     * Desc: 门户缓存刷新事件 <br>
     *     @TransactionalEventListener 注解表示此监听器是一个事务监听器，在事件发布方事务的对应阶段执行此监听器事件。
     *                                   phase 表示事务的阶段
     *                                   classes 表示监听的事件类型
     *                                   fallbackExecution 没有事务运行是否处理此事件，默认false
     */
    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT,
                                classes = {RefreshCacheEvent.class},
                                fallbackExecution = true)
    public void onApplicationEvent(RefreshCacheEvent event){
        //发送刷新缓存的消息
        refreshCacheService.sendMessage(event.getRefreshCache().getType());
    }

}

refreshCachePublisher.publishEvent(refreshSingleJournalCache);