一、观察者模式

当对象中存在一对多的关系时，就需要使用这种模式。比如说一个对象发生改变时，会通知到依赖它的对象。

介绍

• 意图：定义对象之间一对多的依赖关系，当一个对象的状态发生改变时，会通知到其它依赖该对象的行为。
• 主要解决：一个对象状态改变给其他对象通知的问题，而且要考虑到易用和低耦合，保证高度的协作。
• 如何解决：采用面向对象的技术，可以将这种关系弱化。
• 关键代码：在被订阅类里面采用一个集合来存放观察者，并且在状态改变时一一通知他们去更新。
• 应用实例：1.对于在订阅了微信公众号某个主题的用户来说，每当公众号有发布新的内容时，会自动的将内容及时推送到用户；2.在初中的教室上课，当下课铃声响起的时候，学生们会主动收拾书包准备下课回家吃饭了；3.在某会议上面，领导召集了负责各个业务模块的子领导，及时传达了某些核心思想，参与了此次会议的小负责人会通知到各个下属。
• 注意事项：1.Java中已经有了对于观察者的支持类。2.避免循环引用。3.如果顺序执行，某一个观察者执行时发生了错误，会导致卡克，一般采取异步的方式去执行。

演示

下面通过一个小的demo来展示一下观察者模式的使用场景。

• 微信公众号推送文章
  首先先来明确下各个扮演的角色，对于订阅了某个公众号的用户来说，他们属于观察者，而公众号的文章的发布属于被观察者。明确了这一点后，下面就比较好撸代码了。
  1、定义被观察者的主要方法，采取接口来定义

   /**
    * 微信主题的接口  即被观察着  他会有三个方法  
   * @author rain
   *
   */
  public interface IWxServerSubject {
  
        void attach(IObserver observer);
  
        void detach(IObserver observer);
  
        void updateObserver();
  }
  

2 、定义抽象的观察者接口

    /**
     * 观察者  订阅了微信主题的观察者
     * @author rain
     *
     */
    public interface IObserver {

        void receiveContent(String info);
    }

`3、实现具体的被观察者

public class IWxSubjectImpl implements IWxServerSubject{

        //观察者列表  订阅了微信公众号的读者
        private List<IObserver> observers = new ArrayList<>();
        private String submitContent;

        @Override
        public void attach(IObserver observer) {
            observers.add(observer);
        }

        //一个信号  即发布了新的文章
        public void submitContent(String content){
            this.submitContent = content;
            updateObserver();
        }

        @Override
        public void detach(IObserver observer) {
            if(observers.contains(observer)){
              observers.remove(observer);
            }
        }

        @Override
        public void updateObserver() {
            for (IObserver iObserver : observers) {
                iObserver.receiveContent(submitContent);
            }
        }
    }

4、定义一个具体的观察者

    /**
     * 读者  订阅了微信公众号的  观察者
     * @author rain
     *
     */
    public class ReaderObsever implements IObserver{

        private String name;

        public  ReaderObsever(String name) {
            this.name = name;
        }
        @Override
        public void receiveContent(String info) {
            System.out.println(name +" ，请注意：Rain发布了新的微信公众号文章---"+info);
        }

        public String getName(){
    
            return name;
        }

    }

5、来个测试类模拟一下吧

public class Test {

     public static void main(String[] args) {
    
    IWxServerSubject subject = new IWxSubjectImpl();
    
    //创建了四个读者  并且都关注了该公众号的  只有赵六没有关注  
    ReaderObsever reader1 = new ReaderObsever("张三");
    ReaderObsever reader2 = new ReaderObsever("李四");
    ReaderObsever reader3 = new ReaderObsever("王五");
    
    //订阅了该公众号的读者  即观察者角色
    subject.attach(reader1);
    subject.attach(reader2);
    subject.attach(reader3);
    
    //公众号发布了文章了
    
    ((IWxSubjectImpl)subject).submitContent("观察者设计模式开始啦！！！");
    


    }

}

运行一下：

模拟观察者.png

可以看到，订阅过该公众号的用户确实收到了新发布的文章，good。。。