别再面向 for 循环编程了，Spring 自带的观察者模式就很香！ (2)

https://github.com/javastacks/spring-boot-best-practice

新增观察者目标类 import lombok.Getter; import org.springframework.context.ApplicationEvent; /** * 观察目标：栈长 * 来源微信公众号：Java技术栈 */ @Getter public class JavaStackEvent extends ApplicationEvent { /** * Create a new {@code ApplicationEvent}. * * @param source the object on which the event initially occurred or with * which the event is associated (never {@code null}) */ public JavaStackEvent(Object source) { super(source); } }

实现 Spring 框架中的 ApplicationEvent 应用程序事件接口，相当于是一个观察者目标。

新增观察者类 import lombok.NonNull; import lombok.RequiredArgsConstructor; import org.springframework.context.ApplicationListener; import org.springframework.scheduling.annotation.Async; /** * 观察者：读者粉丝 * 来源微信公众号：Java技术栈 */ @RequiredArgsConstructor public class ReaderListener implements ApplicationListener<JavaStackEvent> { @NonNull private String name; private String article; @Async @Override public void onApplicationEvent(JavaStackEvent event) { // 更新文章 updateArticle(event); } private void updateArticle(JavaStackEvent event) { this.article = (String) event.getSource(); System.out.printf("我是读者：%s，文章已更新为：%s\n", this.name, this.article); } }

实现 Spring 框架中的 ApplicationListener 应用监听接口，相当于是观察者。

观察目标和观察者类结构图如下：

新增测试配置类 import lombok.extern.slf4j.Slf4j; import org.springframework.boot.CommandLineRunner; import org.springframework.context.ApplicationContext; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @Slf4j @Configuration public class ObserverConfiguration { @Bean public CommandLineRunner commandLineRunner(ApplicationContext context) { return (args) -> { log.info("发布事件：什么是观察者模式？"); context.publishEvent(new JavaStackEvent("什么是观察者模式？")); }; } @Bean public ReaderListener readerListener1(){ return new ReaderListener("小明"); } @Bean public ReaderListener readerListener2(){ return new ReaderListener("小张"); } @Bean public ReaderListener readerListener3(){ return new ReaderListener("小爱"); } }

在 Spring 配置中创建了三个读者 Bean，在 Spring Boot 启动后发布一个观察者模式事件，然后这三个 Bean 就会收到通知。

输出结果：

这里每个读者创建一个 Bean 可能不太合适，因为要模仿上一个观察者模式的应用。

实际中的观察者模式应用应该是指具体业务，举例说一个电商支付场景，在用户支付完后可以发布一个支付事件，然后会有扣减积分，短信通知、赠送优惠券等一系列后续的事件监听器观察者，这样可以实现业务解耦，这是一种很典型的应用场景。

如果大家有用到消息中间件，其实也是观察者模式中发布订阅模式的概念。

总结

利用 Spring 中的事件监听机制也可以轻松实现观察者模式，观察目标也不需要维护观察者列表了，相当于发布-订阅模式，它们之间是完全解耦的，但每个观察者需要创建一个 Bean。

好了，今天的分享就到这里了，又学了一种设计模式的写法吧，后面栈长我会更新其他设计模式的实战文章，公众号Java技术栈第一时间推送。

本节教程所有实战源码已上传到这个仓库：

https://github.com/javastacks/spring-boot-best-practice

最后，觉得我的文章对你用收获的话，动动小手，给个在看、转发，原创不易，栈长需要你的鼓励。

版权申明：本文系公众号 "Java技术栈" 原创，原创实属不易，转载、引用本文内容请注明出处，禁止抄袭、洗稿，请自重，尊重他人劳动成果和知识产权。