序
Spring框架通过发布/订阅模式为组件间通信提供了高效且松散耦合的解决方案，提升了系统的灵活性和扩展性。
本文探讨该模式的原理、实现、应用场景及其优势与挑战。
1 发布订阅模式：基本概念
- 发布-订阅模式，又称为观察者模式（
Observer Pattern）的一种变体，是一种基于消息传递的设计模式。
在这个模式中，主要涉及3个核心角色：发布者（Publisher）、订阅者（Subscriber）和消息代理（Message Broker）。
- 发布者是消息的产生者，它负责生成特定类型的消息并将其发送到消息代理。
发布者不需要了解有哪些订阅者对其发布的消息感兴趣，它只专注于消息的生成和发布。
- 订阅者则是对特定类型消息感兴趣的组件，它们向消息代理注册自己感兴趣的消息类型。
当消息代理接收到发布者发送的符合订阅者兴趣的消息时，会将消息转发给对应的订阅者。订阅者可以根据接收到的消息进行相应的业务处理。
- 消息代理是发布者和订阅者之间的中介，它负责接收发布者的消息，并根据订阅者的注册信息将消息分发给相应的订阅者。
消息代理的存在使得发布者和订阅者之间实现了高度的解耦，它们不需要直接相互引用或通信，只需要与消息代理进行交互即可。
2 Spring框架中发布订阅模式的实现
下面通过发布订阅模式实现一个示例：在用户注册成功后，系统自动发送邮件通知用户。
Step1 定义事件(ApplicationEvent)
- 定义事件类，事件类通常继承自
org.springframework.context.ApplicationEvent
我们可以定义一个
UserRegisteredEvent类来表示用户注册成功的事件
public class UserRegisteredEvent extends ApplicationEvent {
// 这里的User是一个包含用户相关信息的实体类
private User user;
// source：事件的源对象，用于表明这个事件是由哪个对象触发的
// 具体作用下面订阅事件中解释
public UserRegisteredEvent(Object source, User user) {
super(source);
this.user = user;
}
public User getUser() {
return user;
}
}
Step2 发布事件
- 发布事件的组件需要获取
ApplicationEventPublisher实例，并通过它来发布事件
在用户注册操作成功完成后，发布用户注册事件
@Service
public class UserRegistrationService {
@Autowired
private ApplicationEventPublisher eventPublisher;
public void registerUser(User user) {
// 执行用户注册逻辑，如保存用户信息到数据库等
// 注册成功后发布事件
UserRegisteredEvent event = new UserRegisteredEvent(this, user);
eventPublisher.publishEvent(event);
}
}
Step3 订阅事件
方式1 ApplicationListener接口
-
订阅者可以通过实现org.springframework.context.ApplicationListener接口来订阅特定的事件
-
发送欢迎邮件的服务可以订阅UserRegisteredEvent事件
@Component
public class WelcomeEmailSender implements ApplicationListener<UserRegisteredEvent> {
@Override
public void onApplicationEvent(UserRegisteredEvent event) {
User user = event.getUser();
// 发送欢迎邮件给用户的逻辑，如调用邮件发送接口等
System.out.println("Sending welcome email to " + user.getEmail());
}
}
方式2 @EventListener注解
-
除了基于接口的订阅方式，Spring还提供了@EventListener注解来简化订阅者的实现。插播一条：如果你想加入我们，可以点击->程序员交流社区
-
Spring还提供了对异步事件的支持，可以使用@Async注解来实现异步处理，从而避免阻塞事件的发布者
@Component
public class AnotherWelcomeEmailSender {
@EventListener
@Async
public void handleUserRegisteredEvent(UserRegisteredEvent event) {
User user = event.getUser();
// 发送欢迎邮件的逻辑
System.out.println("Another welcome email sent to " + user.getEmail());
}
}
方式3 事件源Object source的作用
- 假设有一个Web服务和一个API服务都可能触发UserRegisteredEvent事件，你可以在监听器中根据source进一步区分事件的处理方式
@EventListener
public void onUserRegistered(UserRegisteredEvent event) {
Object source = event.getSource();
if (source instanceof WebRegistrationService) {
// 处理通过 Web 注册的用户
} else if (source instanceof ApiRegistrationService) {
// 处理通过 API 注册的用户
}
}
3 应用场景
社交网络平台
用户发布新动态后，动态发布服务触发创建事件。
关注者列表服务订阅并推送该动态给关注者，推荐算法服务也订阅事件，分析内容为潜在用户推荐，扩大传播范围。
电商系统
商品管理系统修改价格后发布价格变动事件，促销活动系统订阅并重新评估促销规则，购物车系统订阅并实时更新商品价格，确保用户看到最新价格。
金融交易系统
用户交易时，交易处理服务发布交易事件，包含金额、类型等信息。
账户余额更新系统订阅并更新余额及交易流水，确保准确性和可追溯性。
风险监控系统也订阅事件，实时评估风险，检测异常交易并触发预警机制。
P 小结
- Spring的发布-订阅模式通过ApplicationEvent、ApplicationListener和@EventListener等组件，解耦了消息的生产者和消费者，并支持异步通信。
这样可以让不同模块独立处理事件，提升系统的灵活性、可扩展性和响应速度。