网站内链检测,自定义域名,企业官网查询,m2型虚拟主机带宽 网站一、观察者模式场景
1.1 什么是观察者模式#xff1f; 观察者模式#xff08;Observer Pattern#xff09;观察者模式是一种行为型设计模式#xff0c;用于定义一种一对多的依赖关系#xff0c;当对象的状态发生变化时#xff0c;所有依赖于它的对象都会自动收到通知并更…一、观察者模式场景
1.1 什么是观察者模式 观察者模式Observer Pattern观察者模式是一种行为型设计模式用于定义一种一对多的依赖关系当对象的状态发生变化时所有依赖于它的对象都会自动收到通知并更新。
核心思想观察者模式实现了对象之间的解耦被观察者Subject专注于自身状态的管理而观察者Observer专注于对状态变化的响应二者通过通知机制进行交互
1.2 传统开发模式的三大死穴
强耦合陷阱订单状态变更需要手动调用10通知服务邮件/SMS/物流…
扩展噩梦新增通知渠道必须修改核心业务代码违反OCP原则
性能瓶颈同步调用链导致接口响应时间突破2秒红线
1.3 观察者模式的破局之道 事件驱动架构业务逻辑与事件处理物理隔离
动态扩展能力新增观察者零侵入核心系统
异步削峰实测QPS提升300%订单支付场景
1.4 优点
解耦被观察者和观察者之间的耦合度低便于扩展。
动态联动可以动态添加、移除观察者灵活性强。
符合开闭原则被观察者的状态变化通知机制对扩展开放对修改关闭。
1.5 缺点
性能问题观察者过多时通知机制可能导致性能开销。
复杂性增加过多的观察者与被观察者关系可能增加系统的复杂性。
可能产生循环依赖若观察者与被观察者相互依赖可能导致循环调用。
1.6 应用场景
事件驱动模型如 UI 事件监听器按钮点击等。
发布-订阅机制消息队列、事件总线等。
状态同步某一对象的状态变化需要通知多个依赖对象时。
二、技术方案设计
2.1 架构演进对比
2.2 核心组件设计
[事件源] --发布-- [EventBus] --通知-- [观察者集群]↑ ↖[事件对象] [线程池分发]三、Java原生实现
3.1 基于JDK的经典实现
// 支付成功事件定义
public class PaymentSuccessEvent extends EventObject {private final String orderId;private final BigDecimal amount;public PaymentSuccessEvent(Object source, String orderId, BigDecimal amount) {super(source);this.orderId orderId;this.amount amount;}
}// 支付服务事件源
public class PaymentService {private final ListEventListener listeners new CopyOnWriteArrayList();public void addListener(EventListener listener) {listeners.add(listener);}public void pay(String orderId, BigDecimal amount) {// 支付核心逻辑...notifyListeners(new PaymentSuccessEvent(this, orderId, amount));}private void notifyListeners(PaymentSuccessEvent event) {listeners.forEach(listener - listener.onEvent(event));}
}// 邮件通知观察者
public class EmailNotifier implements EventListener {Overridepublic void onEvent(EventObject event) {if (event instanceof PaymentSuccessEvent) {PaymentSuccessEvent e (PaymentSuccessEvent) event;sendEmail(e.getOrderId(), e.getAmount());}}
}3.2 Java9改进方案
// 使用Flow API实现响应式流
public class PaymentPublisher implements Flow.PublisherPaymentEvent {private final Executor executor ForkJoinPool.commonPool();private final ListFlow.Subscriber? super PaymentEvent subscribers new CopyOnWriteArrayList();Overridepublic void subscribe(Flow.Subscriber? super PaymentEvent subscriber) {subscribers.add(subscriber);subscriber.onSubscribe(new PaymentSubscription(subscriber));}private class PaymentSubscription implements Flow.Subscription {private final Flow.Subscriber? super PaymentEvent subscriber;PaymentSubscription(Flow.Subscriber? super PaymentEvent subscriber) {this.subscriber subscriber;}Overridepublic void request(long n) {// 背压处理}Overridepublic void cancel() {subscribers.remove(subscriber);}}
}四、Spring生态进阶实现
4.1 基于ApplicationEvent
// 配置中心变更事件
public class ConfigUpdateEvent extends ApplicationEvent {private final String configKey;private final String newValue;public ConfigUpdateEvent(Object source, String configKey, String newValue) {super(source);this.configKey configKey;this.newValue newValue;}
}// 动态配置观察者
Component
public class ConfigRefreshListener {EventListenerAsyncpublic void handleConfigUpdate(ConfigUpdateEvent event) {refreshConfigCache(event.getConfigKey(), event.getNewValue());notifyAllServers(event);}
}// 事件发布
Service
public class ConfigService {Autowiredprivate ApplicationEventPublisher eventPublisher;public void updateConfig(String key, String value) {// 更新数据库eventPublisher.publishEvent(new ConfigUpdateEvent(this, key, value));}
}4.2 注解驱动增强
Retention(RetentionPolicy.RUNTIME)
Target(ElementType.METHOD)
public interface BusinessEventListener {String[] keys() default {};EventMode mode() default EventMode.ASYNC;
}// AOP切面处理
Aspect
Component
public class EventListenerAspect {Around(annotation(listener))public Object processEvent(ProceedingJoinPoint pjp, BusinessEventListener listener) {EventObject event (EventObject) pjp.getArgs()[0];if (shouldHandle(event, listener.keys())) {return switch (listener.mode()) {case ASYNC - CompletableFuture.runAsync(() - proceed(pjp));case TRANSACTIONAL - executeInTransaction(pjp);default - proceed(pjp);};}return null;}
}五、生产级优化方案
5.1 性能优化策略
5.2 可靠性保障
// 事件持久化方案
public class PersistentEventBus {private final EventStoreRepository eventStore;Transactional(propagation Propagation.REQUIRES_NEW)public void publishWithPersistence(DomainEvent event) {eventStore.save(event);realPublish(event);}// 定时补偿任务Scheduled(fixedRate 60000)public void retryFailedEvents() {eventStore.findFailedEvents().forEach(event - {try {realPublish(event);event.markAsSent();} catch (Exception e) {event.recordRetry();}});}
}六、经典应用场景
6.1 电商订单系统
支付成功事件 → 库存扣减/物流触发/积分发放使用「发布-确认-补偿」机制保证最终一致性6.2 微服务配置中心
配置变更事件 → 所有服务实例动态刷新结合Spring Cloud Bus实现集群通知6.3 物联网数据采集
设备状态事件 → 实时监控/预警分析/大屏展示采用MQTT协议实现百万级设备连接七、避坑指南
7.1 常见问题排查 内存泄漏
检查观察者是否及时取消注册
使用WeakReference包装监听器
事件丢失
增加本地事件持久化层
实现至少一次投递语义
循环触发
在事件对象中添加traceId
设置最大传播深度阈值
7.2 生产注意事项 事件版本控制使用Avro Schema管理事件格式
监控埋点统计事件处理耗时/成功率
熔断降级Hystrix隔离异常观察者
