行为型模式--观察者模式【Observer Pattern】

逃离我推掉我的手 2022-05-26 02:48 108阅读 0赞

## 介绍 ##

> 观察者模式【又被称为发布-订阅（Publish/Subscribe）模式】，属于行为型模式的一种，它定义了一种一对多的依赖关系，让多个观察者对象同时监听某一个主题对象。这个主题对象在状态变化时，会通知所有的观察者对象，使他们能够自动更新自己。

表2.4 观察者模式角色

<table> 
 <tbody> 
  <tr> 
   <th>角色</th> 
   <th>作用</th> 
  </tr> 
  <tr> 
   <td> 主题接口</td> 
   <td> 指被观察的对象。当其状态发生改变或者某事件发生时，它会将这个变化通知观察者。它维护了观察者所需要依赖的状态 </td> 
  </tr> 
  <tr> 
   <td>具体主题</td> 
   <td> 具体主题实现了主题接口中的方法。如新增观察者、删除观察者和通知观察者。其内部维护一个观察者列表 </td> 
  </tr> 
  <tr> 
   <td>观察者接口</td> 
   <td> 观察者接口定义了观察者的基本方法。当依赖状态发生改变时，主题接口就会调用观察者的update()方法</td> 
  </tr> 
  <tr> 
   <td>具体观察者</td> 
   <td> 实现了观察者接口的update()，具体处理当被观察者状态改变或者某一事件发生时的业务逻辑</td> 
  </tr> 
 </tbody> 
</table>

## 类图 ##

![这里写图片描述][70]

## 代码实现 ##

主题接口实现如下：

public interface ISubject { 
    	void attach(IObserver oberver);//添加观察者
    	void detach(IObserver oberver);//删除观察者
    	void inform(String str);//通知所有观察者
    
    }

具体主题如下：

public class ConcreteSubject implements ISubject{ 
    	
    	private Vector<IObserver> observers = new Vector<>();
    
    	//添加观察者
    	@Override
    	public void attach(IObserver observer) { 
    		observers.addElement(observer);
    	}
    
    	//删除观察者
    	@Override
    	public void detach(IObserver observer) { 
    		observers.removeElement(observer);
    	}
    
    	//在这里通知观察者
    	@Override
    	public void inform(String str) { 
    		for(IObserver ob:observers){ 
    			ob.update(str);
    		}
    	}
    
    }

观察者接口实现如下：

public interface IObserver { 
    	//更新观察者
    	void update(String str);
    }

具体观察者如下：

public class ConcreteObserver implements IObserver{ 
    	// 具体观察者用户名
        private String name;
        
        public ConcreteObserver(String name) { 
            this.name = name;
        }
    
        //具体业务处理
    	@Override
    	public void update(String str) { 
    		System.out.println(name+"-"+str);
    	}
    
    }

测试类Main

public class Main { 
    	public static void main(String[] args) { 
    		//创建主题角色
    	    ISubject watched = new ConcreteSubject();
    	    //创建观察者角色
    	    IObserver observer1 = new ConcreteObserver("天明");
    	    IObserver observer2 = new ConcreteObserver("少羽");
    	    IObserver observer3 = new ConcreteObserver("高月");
    	    //把观察者角色加入到主题角色中
    	    watched.attach(observer1);
    	    watched.attach(observer2);
    	    watched.attach(observer3);
    	    watched.inform("上课了！！！");
    	}
    
    }

运行结果：

天明-上课了！！！
    少羽-上课了！！！
    高月-上课了！！！

## JDK实现 ##

> JDK内部就已经为开发人员准备了一套观察者模式的实现。  
> *java.util.Observable【使用synchronized 锁实现线程安全】*  
> *java.util.Observer*

### JDK内置的观察者模式 ###

![这里写图片描述][Image 1]

## 应用场景 ##

> ♦ JDK中，Swing框架的JButton实现  
> ♦ [哈票网购票][Link 1]

--------------------

参考资料：  
\[1\] 葛一鸣.Java程序性能优化\[M\].北京：清华大学出版社，2012: 33-36.

[70]: /images/20220526/45f44e3fbc89464d95ad844b710cf4fb.png
[Image 1]: 
[Link 1]: https://www.aliyun.com/jiaocheng/291734.html