Java Spring 事件驱动机制

Java Spring 事件驱动机制详解：ApplicationEventPublisher 与 ApplicationEventPublisherAware

一、什么是 Spring 的事件机制？

Spring 的事件机制是一种发布-订阅（Publish-Subscribe）模式的实现。它允许 Spring 容器中的 Bean 之间进行异步/同步通信，适合实现模块解耦、通知机制等场景。

事件驱动模型主要由三部分组成：

• 事件（Event）：继承自 ApplicationEvent 的自定义事件类
• 事件发布者（Publisher）：使用 ApplicationEventPublisher 发布事件
• 事件监听器（Listener）：通过实现 ApplicationListener 或使用 @EventListener 注解来接收事件

二、ApplicationEventPublisher 接口

ApplicationEventPublisher 是 Spring 的事件发布接口，提供如下方法：

void publishEvent(Object event);

当调用此方法时，Spring 会将事件广播给所有监听该类型事件的监听器。

示例：使用 ApplicationEventPublisher 发布事件

通过publishEvent方法，发布一个自定义事件类。MyCustomEvent就是自定义事件类

import com.wzw.entity.UserEvent;
import lombok.RequiredArgsConstructor;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Component;

@Component
@RequiredArgsConstructor
public class EventPublisher {

    private final ApplicationEventPublisher publisher;

    public void publish(String message) {
        publisher.publishEvent(new UserEvent(this, message));
    }
}

三、ApplicationEventPublisherAware 接口

如果不想使用构造函数或字段注入的方式获取 ApplicationEventPublisher，可以实现 ApplicationEventPublisherAware 接口，Spring 会自动注入该依赖：

import com.wzw.entity.UserEvent;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.ApplicationEventPublisherAware;
import org.springframework.stereotype.Component;

@Component
public class EventPublisher implements ApplicationEventPublisherAware {

    private ApplicationEventPublisher publisher;

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

    public void publish(String message) {
        publisher.publishEvent(new UserEvent(this, message));
    }
}

四、自定义事件类

可以创建一个继承自 ApplicationEvent 的事件类，也可以直接使用 POJO：

import org.springframework.context.ApplicationEvent;

public class UserEvent extends ApplicationEvent {

    private String name;

    public UserEvent(Object source, String name) {
        super(source);
        this.name = name;
    }

    public String getName() {
        return name;
    }

}

五、事件监听器的两种写法

1. 实现 ApplicationListener 接口

import com.wzw.entity.UserEvent;
import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;

@Component
public class EventListener implements ApplicationListener<UserEvent> {

    @Override
    public void onApplicationEvent(UserEvent event) {
        System.out.println("-----实现接口ApplicationListener的监听方法："+event.getName());
    }
}

2. 使用 @EventListener 注解（推荐）

import com.wzw.entity.UserEvent;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;

@Component
public class AnnoEventListener {

    @EventListener
    public void handleEvent(UserEvent event) {
        System.out.println("注解监听器收到事件：" + event.getName());
    }
}

六、实战演示

测试方法

import com.wzw.Main;
import com.wzw.service.EventPublisher;
import jakarta.annotation.Resource;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest(classes = Main.class)
public class PublisherTest {

    @Resource
    private EventPublisher publisher;

    @Test
    public void test() {
        publisher.publish("张三");
    }
}

七、使用场景总结

八、使用场景

Spring 的事件驱动机制是一个优雅的模块解耦方案。可以看做一个简单的MQ，常见用于：

• 用户注册完成后发送欢迎邮件
• 操作日志记录
• 第三方系统通知（如消息推送、钉钉机器人）
• 领域事件驱动设计（DDD）

九、直接调用、spring事件机制、MQ

✅ 举例对比：用户注册场景

场景：用户注册成功后，需完成以下动作：

• 发送欢迎邮件
• 写入操作日志
• 向 CRM 系统推送用户数据

1. 直接调用

userService.register(user);
mailService.sendWelcome(user);
logService.writeLog(user);
crmService.pushUser(user);

✅ 简单
❌ 强耦合，crmService 出错可能影响主流程

2. Spring事件机制

userService.register(user);
eventPublisher.publishEvent(new UserRegisteredEvent(user));

然后由多个监听器来处理：

@EventListener
public void sendWelcomeEmail(UserRegisteredEvent event) { ... }

@EventListener
public void writeLog(UserRegisteredEvent event) { ... }

@EventListener
public void pushToCRM(UserRegisteredEvent event) { ... }

✅ 业务解耦
⚠️ 仍在同一个进程内，CRM 如果慢，仍可能拖慢主线程（除非加 @Async）

3. MQ 消息队列方式（推荐用于服务间通信）

userService.register(user);
mqProducer.send("user.registered", user);

• 邮件服务、日志服务、CRM 服务分别订阅 user.registered 主题并异步处理
• 可持久化、失败重试、异步处理

✅ 系统间彻底解耦
✅ 网络分布式通信
⚠️ 成本高，需要部署 MQ 中间件（如 Kafka、RabbitMQ、RocketMQ）

✅ 结论建议

🔍 补充提示