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

2023-12-13 20:06:23

在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());
    }
}

文章来源:https://blog.csdn.net/maple05/article/details/134977976
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。