ApplicationEvent事件处理

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了ApplicationEvent事件处理相关的知识,希望对你有一定的参考价值。

参考技术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、基础

  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()+"===============");
    

以上是关于ApplicationEvent事件处理的主要内容,如果未能解决你的问题,请参考以下文章

SpringBoot 发布ApplicationEventPublisher和监听ApplicationEvent事件

Java:SpringBoot实现ApplicationEvent事件的监听和发布

spring#事件发布订阅

Spring事件发布

Spring事件发布

Spring事件发布