Java 创建事件(Event)、事件监听器(EventListener)、事件发布(publishEvent)详解

在Java中，创建事件（Event）、事件监听器（EventListener）和事件发布（publishEvent）的工作原理涉及到观察者设计模式。这种设计模式用于实现对象之间的松耦合通信。事件（Event）相当于被观察对象，事件监听器（EventListener）相当于观察者。

其中一个对象（事件源）维护一组依赖于它的对象（事件监听器），并在状态改变时通知它们。

一般的，事件发布或事件监听后处理逻辑应该都是异步不阻塞线程。可以在发布时间或者事件监听方法上面加上@Async注解

总体而言，整个调用过程是一个松耦合的事件驱动模型。支付服务和事件监听器之间没有直接的依赖关系，支付服务只需发布支付完成事件，而不需要关心谁在监听它。监听器则通过事件类型感知并响应事件，实现了对象之间的解耦。这种模式使得系统更加灵活、可扩展，并能更容易地实现事件驱动的业务逻辑。

事件源（Event Source）

事件源是指能够产生事件的对象，它是整个事件系统的起点。你可以把它理解为一个java对象类。

package com.xxxx.model;
 
import lombok.Data;
 
@Data
public class PaymentVo {
 
    private String paymentId;
 
    public PaymentVo(String paymentId) {
        this.paymentId = paymentId;
    }
}

事件对象（Event）

事件对象是包含了事件相关信息的类，用于在事件源和事件监听器之间传递数据。必须继承ApplicationEvent。

package com.xxxx.event;
 
import com.xxxx.model.PaymentVo;
import org.springframework.context.ApplicationEvent;
 
public class PaymentEvent extends ApplicationEvent {
 
    private PaymentVo paymentVo;
 
    public PaymentEvent(PaymentVo paymentVo) {
        super(paymentVo);
    }
 
    public PaymentVo getPaymentVo() {
        return paymentVo;
    }
}

事件发布（publishEvent）

事件发布是指事件源对象发出事件的过程。一般使用ApplicationContext的publishEvent()方法。

package com.xxxx.service;
 
import com.xxxx.event.PaymentEvent;
import com.xxxx.model.PaymentVo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.context.ApplicationContext;
 
@Service
public class PaymentService {
 
    /**
     * ApplicationContext 继承实现了 ApplicationEventPublisher, 可以直接发布事件
     */
    @Autowired
    private ApplicationContext applicationContext;
 
    public void processPayment(String paymentId) {
        // 执行支付逻辑
 
        // 假设支付成功后，构造PaymentVo对象，并触发支付事件
        PaymentVo paymentVo = new PaymentVo(paymentId);
        applicationContext.publishEvent(new PaymentEvent(paymentVo));
    }
}

事件监听器（EventListener）

当相应的事件被发布时，这些方法会被触发执行，处理事件相关的逻辑。使用 @EventListener 注解。(@EventListener工作原理-CSDN博客)

package com.xxxx.event;
 
import com.xxxx.model.PaymentVo;
import org.springframework.context.event.EventListener;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
 
@Component
public class EventListenerHandle {
 
    /**
     * EventListener 监听到PaymentEvent事件，触发方法
     * @param paymentEvent
     */
    @Async
    @EventListener
    public void handlePaymentEvent(PaymentEvent paymentEvent) {
        PaymentVo paymentVo = paymentEvent.getPaymentVo();
 
        // 处理支付成功业务
        System.out.println("Payment successful for paymentId: " + paymentVo.getPaymentId());
    }
}