什么是观察者模式(Observer Pattern)
观察者模式定义了对象之间的一对多依赖。这样一来,当一个对象状态改变时它的所有依赖者都会收到通知并自动更新。
观察者模式的应用
观察者模式的应用很广泛。例如在Android开发时需要对控件注册事件监听,控件属于被观察者,在该控件上所注册的事件属于观察者,当控件发生变化时相应的监听事件会立即做出回应。我想大家都有自己喜欢的微信公众号,其实微信公众号的订阅、推送很好的体现了观察者模式。当我们想及时获得自己喜欢的公号的更新就得先关注它,然后公号有更新时会第一时间通知它的每一位仰慕者。
设计模式来源于生活,细细品味生活能够更好的去理解设计模式。
观察者模式所涉及的 OO 设计原则
-
实现交互对象之间的松耦合。
-
何为对象之间的松耦合?松耦合就是两个对象可以交互,但是不太清楚彼此的细节。更通俗一点来说就是你和你的手机就是松耦合的,你可以很轻松的玩耍你的手机(你和手机进行者交互),但你并知道手机内部的实现,手机也更不知道使用者是谁啦。
-
封装变化。
-
多用组合,少用继承。
-
针对接口编程,不针对实现编程。
观察者模式 Java 代码实现及分析
-
分析
-
此 Demo 借用模拟微信公众号简单地实现了观察者模式。
-
WeChatPublicNumber 是所有微信公众号的公共接口,所有具体的微信公众号都要实现此接口,CnboJavaDev 就是一个实现此接口的微信公众号(我决定了,我以后的微信公众号就叫此名了,嘻嘻)。WeChatPublicNumber 提供了用户订阅 registerUser(User user) 和取消订阅的方法 removeUser(User user),还有推送更新的方法 notifyUsers()。
-
User 是所有用户的公共接口,此接口提供了更新方法 update() 和文章阅读方法 readArticle() (此方法主要用来测试打印)。Facebook 和 Google 实现了 User 接口。
-
TestObserver 用于对此 Demo 的测试。
-
Demo 的 UML 类图
- WeChatPublicNumber.java
/**
* WeChatPublicNumber(微信公众号接口)
* @author cnbo
*/
public interface WeChatPublicNumber {
//用户订阅公号
public void registerUser(User user);
//用户取消订阅
public void removeUser(User user);
//向所有订阅用户推送更新
public void notifyUsers();
}
- Article.java
/**
* 文章(别乱想哦)
* @author cnbo
*
*/
public class Article {
/** 文章的标题 */
private String title;
/** 文章的作者 */
private String author;
public String getTitle() {
return title;
}
public void setTitle(String title) {
this.title = title;
}
public String getAuthor() {
return author;
}
public void setAuthor(String author) {
this.author = author;
}
@Override
public String toString() {
return "title:" + title + "; author:" + author;
}
}
- User.java
/**
* 微信用户接口
* @author cnbo
*
*/
public interface User {
public void update(Article article);
public void readAritcle();
}
- CnboJavaDev.java
/**
* CnboJavaDev是一个实现了接口WeChatPublicNumber
* 的具体的公号
* @author cnbo
*/
public class CnboJavaDev implements WeChatPublicNumber {
private Article article;
private List<User> users;
public CnboJavaDev() {
users = new ArrayList<>();
}
@Override
public void registerUser(User user) {
if (users != null) {
users.add(user);
}
}
@Override
public void removeUser(User user) {
if (users != null && users.contains(user)) {
users.remove(user);
}
}
//发布文章
public void publishArticle() {
notifyUsers();
}
//向所有订阅者推送文章
@Override
public void notifyUsers() {
if (users == null) {
return;
}
for (User user : users) {
user.update(article);
user.readAritcle();
}
}
public void addArticle(Article article) {
this.article = article;
publishArticle();
}
}
- Facebook.java
/**
* 微信用户Facebook
* @author cnbo
*
*/
public class Facebook implements User {
private Article article;
private WeChatPublicNumber weChatPublicNumber;
public Facebook(WeChatPublicNumber weChatPublicNumber) {
this.weChatPublicNumber = weChatPublicNumber;
weChatPublicNumber.registerUser(this);
}
@Override
public void update(Article article) {
this.article = article;
}
@Override
public void readAritcle() {
System.out.println("facebook read " + article);
}
}
- Google.java
/**
* 微信用户Google
* @author cnbo
*/
public class Google implements User {
private Article article;
private WeChatPublicNumber weChatPublicNumber;
public Google(WeChatPublicNumber weChatPublicNumber) {
this.weChatPublicNumber = weChatPublicNumber;
weChatPublicNumber.registerUser(this);
}
@Override
public void update(Article article) {
this.article = article;
}
@Override
public void readAritcle() {
System.out.println("google read " + article);
}
}
- TestObserver.java
/*
* 测试观察者模式
* @author cnbo
*/
public class TestObserver {
public static void main(String[] args) {
CnboJavaDev cnboJavaDev = new CnboJavaDev();
//facebook和google关注了cnboJavaDev(如果我真被facebook和google
//关注了,那我会兴奋成神经的,哈哈)
User facebook = new Facebook(cnboJavaDev);
User google = new Google(cnboJavaDev);
Article article1 = getArticle("学习笔记之单例设计模式", "cnbo");
//cnboJavaDev发布一篇新文章article1,同时facebook和google
//都接收到了更新,然后他哥俩有滋有味的读者cnbo的文章。
cnboJavaDev.addArticle(article1);
Article article2 = getArticle("学习笔记之策略设计模式", "cnbo");
cnboJavaDev.addArticle(article2);
}
public static Article getArticle(String title, String author) {
Article article = new Article();
article.setTitle(title);
article.setAuthor(author);
return article;
}
}