ApplicationEvent事件处理

Posted 2023-04-12

参考技术A ApplicationEvent用监听对象的创建并处理接下来的业务逻辑，是观察者模式的应用
接下来简单演示下其用法及进阶用法，首先ApplicationEvent本身是同步的

其中Listener可以有多个，自定义顺序可以使用@Order注解
如果想实现异步发送消息的功能就得加上@Async注解了

Spring还提供了一个关于事务的处理
其中phase 有四个值可以选
AFTER_COMMIT，BEFORE_COMMIT，AFTER_ROLLBACK，AFTER_COMPLETION
@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
还有一个fallbackExecution属性代表没有事务的时候是否应该执行，默认为false，即是必须是有事务的时候才会执行
因此@TransactionalEventListener注解需要配合事务一起使用

注：@TransactionalEventListener没必要和@Async一同使用，因为事务操作完毕意味着方法执行结束了，配合使用时异步功能是开启不了的

Spring事件发布

事件发布

• 1、基础
• 2、开发流程

1、基础

1. ApplicationContext 中的事件处理是通过 ApplicationEvent 类和 ApplicationListener 接口提供的。

2. 如果将实现 ApplicationListener 接口的bean部署到上下文中（@Component），则每次将 ApplicationEvent 发布到 ApplicationContext 时，该bean都会得到通知。

3. spring事件监听，是以异步方式来操作的，而AOP是同步的。

public abstract class ApplicationEvent extends EventObject 

    // 事件源
    public ApplicationEvent(Object source) 
        super(source);
        this.timestamp = System.currentTimeMillis();
    

    public final long getTimestamp() 
        return this.timestamp;
    

@FunctionalInterface
public interface ApplicationListener<E extends ApplicationEvent> extends EventListener 

    // 处理事件
    void onApplicationEvent(E event);

2、开发流程

实际开发中，分为三个类：Event、Publisher、Listener。

/**
 * 事件类
 * 1、继承ApplicationEvent
 * 2、重写构造方法
 * 3、参数set、get
 *
  */
public class PaymentDistributionEvent extends ApplicationEvent 

    private Payment payment;

    public PaymentDistributionEvent(Object source,Payment payment) 
        super(source);
        this.payment=payment;
    

    public Payment getPayment() 
        return payment;
    

    public void setPayment(Payment payment) 
        this.payment = payment;
    

/**
 * 发布类
 * 1、声明bean
 * 2、实现接口ApplicationEventPublisherAware
 * 3、重写方法setApplicationEventPublisher
 * 4、实现自己的方法，并在方法内调用Spring发布事件
 */
@Component
public class PaymentDistributionPublisher implements ApplicationEventPublisherAware 

    private ApplicationEventPublisher applicationEventPublisher;

    @Override
    public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) 
        this.applicationEventPublisher=applicationEventPublisher;
    

    public void publish(PaymentDistributionEvent paymentDistributionEvent) 
        //业务代码忽略
        applicationEventPublisher.publishEvent(paymentDistributionEvent);
    

---

/**
 * 监听类
 * 1、声明bean
 * 2、实现接口ApplicationListener<E>
 * 3、重写方法onApplicationEvent，方法内部做事
 */
@Component
public class PaymentDistributionListener implements ApplicationListener<PaymentDistributionEvent> 

    @Override
    public void onApplicationEvent(PaymentDistributionEvent paymentDistributionEvent) 
        Payment payment = paymentDistributionEvent.getPayment();
        System.out.println("============"+payment.getId()+"==="+payment.getSerial()+"===============");
    

使用注解实现监听，可监听多个

@Component
public class PaymentDistributionListener 

    @EventListener(PaymentDistributionEvent.class)
    public void onApplicationEvent(PaymentDistributionEvent paymentDistributionEvent) 
        Payment payment = paymentDistributionEvent.getPayment();
        System.out.println("============"+payment.getId()+"==="+payment.getSerial()+"===============");