大数据

设计模式笔记——观察者模式

什么是观察者模式(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类图

observer 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 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;
    }
    }