设计模式第5讲——观察者模式（Observer）在现代化架构中的演进与实践

1. 观察者模式基础概念观察者模式Observer Pattern是一种行为型设计模式它定义了对象之间的一对多依赖关系。当一个对象的状态发生改变时所有依赖于它的对象都会得到通知并自动更新。这种模式也被称为发布-订阅模式Publish-Subscribe是解耦系统组件的重要工具。想象一下报纸订阅的场景报社被观察者每天发布新报纸订阅者观察者会自动收到最新报纸。在这个过程中报社不需要知道具体有哪些订阅者订阅者也无需主动询问是否有新报纸。这种松耦合的设计正是观察者模式的核心价值。观察者模式包含四个关键角色抽象主题Subject定义添加、删除观察者及通知观察者的接口具体主题ConcreteSubject维护观察者列表状态改变时通知所有观察者抽象观察者Observer定义更新接口用于接收主题通知具体观察者ConcreteObserver实现更新接口保持与主题状态的一致性2. 传统实现与现代化演进2.1 经典Java实现在传统Java实现中我们通常会定义Subject和Observer接口// 抽象主题 interface Subject { void registerObserver(Observer o); void removeObserver(Observer o); void notifyObservers(); } // 抽象观察者 interface Observer { void update(Subject subject); }具体主题维护观察者列表并在状态变化时通知class ConcreteSubject implements Subject { private ListObserver observers new ArrayList(); private int state; public void setState(int state) { this.state state; notifyObservers(); } Override public void registerObserver(Observer o) { observers.add(o); } Override public void notifyObservers() { for (Observer o : observers) { o.update(this); } } }2.2 JDK内置支持Java标准库提供了Observable类和Observer接口import java.util.Observable; import java.util.Observer; class WeatherData extends Observable { private float temperature; public void measurementsChanged() { setChanged(); // 标记状态已改变 notifyObservers(); // 通知观察者 } public void setMeasurements(float temp) { this.temperature temp; measurementsChanged(); } } class CurrentConditionsDisplay implements Observer { Override public void update(Observable o, Object arg) { if (o instanceof WeatherData) { // 处理更新逻辑 } } }虽然JDK提供了现成实现但在现代Java开发中更推荐使用自定义接口因为Observable是类而非接口限制了复用性。3. 现代分布式架构中的观察者模式3.1 消息队列实现在微服务架构中观察者模式通常通过消息队列实现// 使用Spring AMQP实现 Configuration public class RabbitConfig { Bean public TopicExchange eventExchange() { return new TopicExchange(event-exchange); } } Service public class OrderService { Autowired private RabbitTemplate rabbitTemplate; public void createOrder(Order order) { // 创建订单逻辑 rabbitTemplate.convertAndSend(event-exchange, order.created, order); } } Component public class NotificationService { RabbitListener(bindings QueueBinding( value Queue(notification-queue), exchange Exchange(event-exchange), key order.created )) public void handleOrderCreated(Order order) { // 发送通知 } }这种实现方式解耦了服务间的直接调用提高了系统的可扩展性和可靠性。3.2 事件总线模式现代框架如Spring提供了更高级的事件机制// 定义事件 public class OrderCreatedEvent { private final Order order; public OrderCreatedEvent(Order order) { this.order order; } // getter } // 发布事件 Service public class OrderService { Autowired private ApplicationEventPublisher eventPublisher; public void createOrder(Order order) { // 创建订单逻辑 eventPublisher.publishEvent(new OrderCreatedEvent(order)); } } // 监听事件 Component public class NotificationListener { EventListener public void handleOrderCreated(OrderCreatedEvent event) { // 处理事件 } }事件总线模式提供了类型安全的事件处理同时保持了松耦合特性。4. 云原生场景下的最佳实践4.1 响应式编程实现使用Reactor库实现响应式观察者public class StockPublisher { private final FluxStockPrice prices; public StockPublisher() { this.prices Flux.interval(Duration.ofSeconds(1)) .map(i - generateRandomPrice()) .publish() .autoConnect(); } public FluxStockPrice getPrices() { return prices; } } // 订阅使用 stockPublisher.getPrices() .subscribe(price - System.out.println(Price update: price));响应式流天然实现了观察者模式支持背压等高级特性。4.2 WebSocket实时通知前端与后端的实时通信场景RestController RequestMapping(/notifications) public class NotificationController { private final SimpMessagingTemplate messagingTemplate; PostMapping public void sendNotification(RequestBody Notification notification) { messagingTemplate.convertAndSend( /topic/notifications, notification ); } } // 前端JavaScript const socket new SockJS(/ws); const client Stomp.over(socket); client.connect({}, () { client.subscribe(/topic/notifications, (message) { // 处理实时通知 }); });这种模式广泛应用于实时仪表盘、聊天应用等场景。5. 性能优化与常见陷阱5.1 异步通知机制同步通知可能导致性能瓶颈// 异步通知实现 class AsyncSubject implements Subject { private final Executor executor Executors.newFixedThreadPool(4); private final ListObserver observers new CopyOnWriteArrayList(); public void notifyObservers() { for (Observer o : observers) { executor.execute(() - o.update(this)); } } }使用线程池和线程安全的集合类可以避免并发问题。5.2 内存泄漏防护观察者未正确注销会导致内存泄漏// 使用弱引用防止内存泄漏 class WeakRefSubject { private final ListWeakReferenceObserver observers new ArrayList(); public void addObserver(Observer o) { observers.add(new WeakReference(o)); } public void notifyObservers() { IteratorWeakReferenceObserver it observers.iterator(); while (it.hasNext()) { Observer o it.next().get(); if (o ! null) { o.update(this); } else { it.remove(); // 清理已被GC的观察者 } } } }5.3 分布式一致性挑战在分布式系统中实现可靠事件传递// 使用事务发件箱模式 Service Transactional public class OrderService { Autowired private OutboxRepository outbox; public void createOrder(Order order) { // 保存订单 orderRepository.save(order); // 写入发件箱 outbox.save(new OutboxEvent( order.created, order.getId(), order )); } } // 单独进程处理发件箱 Scheduled(fixedRate 5000) public void processOutbox() { ListOutboxEvent events outbox.findUnprocessed(); events.forEach(event - { rabbitTemplate.convertAndSend( event-exchange, event.getType(), event.getPayload() ); event.markAsProcessed(); outbox.save(event); }); }6. 行业应用案例分析6.1 电商订单状态通知典型电商系统中的观察者模式应用// 订单状态变更事件 public class OrderStatusEvent { private String orderId; private OrderStatus oldStatus; private OrderStatus newStatus; // getters setters } // 多个监听器处理不同业务 Component public class OrderStatusListener { EventListener public void sendNotification(OrderStatusEvent event) { // 发送短信/邮件通知 } EventListener public void updateInventory(OrderStatusEvent event) { if (event.getNewStatus() OrderStatus.CANCELLED) { // 恢复库存 } } EventListener Async public void logAuditTrail(OrderStatusEvent event) { // 异步记录审计日志 } }6.2 IoT设备状态监控物联网设备状态监控场景// 设备状态主题 public class DeviceStateTopic { private final MapString, ListConsumerDeviceState subscribers new ConcurrentHashMap(); public void subscribe(String deviceId, ConsumerDeviceState callback) { subscribers.computeIfAbsent(deviceId, k - new ArrayList()) .add(callback); } public void publish(String deviceId, DeviceState state) { ListConsumerDeviceState deviceSubscribers subscribers.get(deviceId); if (deviceSubscribers ! null) { deviceSubscribers.forEach(c - c.accept(state)); } } } // 使用示例 deviceTopic.subscribe(sensor-001, state - { if (state.getTemperature() 50) { triggerAlarm(); } });7. 模式变体与相关模式7.1 事件溯源模式事件溯源是观察者模式的进阶应用// 事件存储 public class EventStore { private final ListEvent events new ArrayList(); private final ListConsumerEvent subscribers new ArrayList(); public void append(Event event) { events.add(event); subscribers.forEach(s - s.accept(event)); } public void subscribe(ConsumerEvent subscriber) { subscribers.add(subscriber); } } // 使用示例 eventStore.subscribe(event - { if (event instanceof OrderCreated) { updateReadModel((OrderCreated)event); } });7.2 中介者模式对比中介者模式与观察者模式的区别观察者单向通信主题不知道观察者如何响应中介者集中式控制协调多个对象间的交互// 中介者示例 class ChatRoom { public static void showMessage(User user, String message) { System.out.println(user.getName() : message); } } // 用户只需与中介者交互 user1.sendMessage(Hi!); // 内部调用ChatRoom.showMessage8. 测试策略与调试技巧8.1 单元测试观察者使用Mock对象测试观察者交互Test public void testObserverNotification() { // 创建mock观察者 Observer mockObserver mock(Observer.class); // 创建主题并注册观察者 ConcreteSubject subject new ConcreteSubject(); subject.registerObserver(mockObserver); // 改变状态触发通知 subject.setState(5); // 验证观察者被调用 verify(mockObserver).update(subject); }8.2 集成测试事件流测试完整事件处理流水线SpringBootTest public class EventIntegrationTest { Autowired private ApplicationEventPublisher publisher; MockBean private NotificationService notificationService; Test public void testOrderEventFlow() { Order order new Order(test-order); // 发布事件 publisher.publishEvent(new OrderCreatedEvent(order)); // 验证通知服务被调用 verify(notificationService, timeout(1000)) .sendOrderCreatedNotification(order); } }9. 未来演进趋势观察者模式在云原生时代的演进方向包括服务网格中的全局事件总线基于WebAssembly的跨语言事件处理与AI结合的智能事件路由区块链环境中的去中心化观察者网络这些趋势将继续扩展观察者模式的应用边界使其在分布式系统架构中发挥更重要的作用。