详解SpringBoot 发布ApplicationEventPublisher和监听ApplicationEvent事件

/** * 自定义保存事件 * @author peter * 2019/1/27 14:59 */public class PersonSaveEvent<DATA> extends ApplicationEvent {  private DATA data;  public PersonSaveEvent(DATA source) {    super(source);    this.data = source;  }  public DATA getData() {    return data;  }}//发布事件public void savePerson(Person person){  personDao.save(person);  publisher.publishEvent(new PersonSaveEvent<>(1));}//监听事件@EventListenerpublic void listenEvent(PersonSaveEvent<Integer> event) {   System.out.println("监听到PersonSaveEvent事件; 接收到的值：" + event.getData() + "；发布的时间为" + Instant.ofEpochMilli(event.getTimestamp()));}

 * <p>If the event is not published within the boundaries of a managed transaction, the * event is discarded unless the {@link #fallbackExecution} flag is explicitly set. If a * transaction is running, the event is processed according to its {@code TransactionPhase}.

 @TransactionalEventListener(phase = TransactionPhase.AFTER_COMPLETION)  public void listenEvent1(PersonSaveEvent<Integer> event) {    divide(event);  }  @Transactional(propagation = Propagation.REQUIRES_NEW)  public void divide(PersonSaveEvent<Integer> event) {    System.out.println("监听到PersonSaveEvent事件; 接收到的值：" + event.getData() + "；接受的时间为" + Instant.ofEpochMilli(event.getTimestamp()));  }

/** * @author peter * @version 1.0 * @date 2019/04/18 08:47 */@Configuration@EnableAsyncpublic class AsyncEventConfiguration implements AsyncConfigurer {  @Override  public Executor getAsyncExecutor() {    return Executors.newCachedThreadPool();  }}