常见设计模式——观察者模式（行为型模式）

﹏ヽ暗。殇╰゛Y 2022-12-23 00:49 172阅读 0赞

### 文章目录 ###

*  观察者模式（发布-订阅模式）
 *   *  概念
     *  结构图
     *  优点
     *  缺点
     *  应用场景
     *  注意
     *  实例：

# 观察者模式（发布-订阅模式） #

## 概念 ##

> **观察者模式**（observer），又叫**发布—订阅模式（publish/subscribe）**，定义了对象间的一对多依赖关系，就是当一个对象的状态发生变化后，所有依赖它的对象就会得到通知自动更新。

## 结构图 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzgzOTMyMw_size_16_color_FFFFFF_t_70_pic_center]

>  *  Subject：抽象主题（抽象被观察者）抽象主题角色把所有的观察者对象保存在一个集合里，每个主题都可以有任意数量的观察者，抽象主题提供一个接口，可以增加和删除观察者对象。
>  *  ConcreteSubject：具体主题（具体被观察者），该角色将有关状态存入具体观察者对象，在具体主题的内部状态发生改变时，给所有注册过的观察者发送通知。
>  *  Observer：抽象观察者，是观察者的抽象类，定义了一个更新的接口，使得它在得到主题更改通知时更新自己。
>  *  ConcreteObserver：具体观察者，实现抽象观察者定义的更新接口，以便在得到主题更改通知时更新自身状态。

## 优点 ##

>  *  观察者和被观察者是抽象耦合的。
>  *  建立了一套触发机制。

## 缺点 ##

>  *  如果一个被观察者对象有很多的直接或间接观察者的话，将所有的观察者都通知到会花费很多时间。
>  *  如果观察者和被观察者之间存在循环依赖的话，可能会导致系统崩盘。
>  *  观察者不知道被观察者是怎么发生变化的，只知道发生了变化。

## 应用场景 ##

>  *  具有关联行为的场景。
>  *  需要对对象跨级别通知的。比如a通知b，b通知c，c通知d。
>  *  不知道要通知的的对象是哪个的情况。

## 注意 ##

>  *  要尽量避免循环引用。
>  *  如果顺序执行，某一个观察者错误会导致系统卡壳，一般采用异步方式。

## 实例： ##

首先创建观察者，它可以是一个接口，里边有接收到订阅消息的方法：

package com.spring.test2;
    /** * 观察者 * @author 17610 * */
    public interface Observer { 
    	/** * 接收到的订阅消息 * @param message */
    	public void update(String message);
    
    }

创建主题，也就是被观察者，它可以是一个接口，提供了添加订阅者、删除订阅者和通知订阅者更新消息的方法。

package com.spring.test2;
    
    
    /** * 主题（被观察者，被监督者） * @author 17610 * */
    public interface Subject { 
    
    	/** * 添加订阅者 * @param observer */
    	public void attach(Observer observer);
    	
    	/** * 删除订阅者 * @param observer */
    	public void detach(Observer observer);
    	
    	/** * 通知订阅者更新消息 * @param message */
    	public void notify(String message);
    }

创建具体的主题，也就是真正的被观察者。具体的主题类实现了主题接口Subject，并重写了接口中的方法，同时创建一个list来存放订阅者对象。

package com.spring.test2;
    
    import java.util.ArrayList;
    import java.util.List;
    import com.spring.test2.Observer;
    /** * 具体的主题（具体的被观察者） * @author 17610 * */
    public class ConcreteSubject implements Subject{ 
    
    	/** * 存放订阅者的list */
    	private List<Observer> subjectList = new ArrayList<Observer>();
    	
    	/** * 重写父类方法 添加订阅者的 */
    	@Override
    	public void attach(Observer observer) { 
    		// TODO Auto-generated method stub
    		subjectList.add(observer);
    	}
    
    	/** * 重写父类方法 删除订阅者的 */
    	@Override
    	public void detach(Observer observer) { 
    		// TODO Auto-generated method stub
    		subjectList.remove(observer);
    	}
    
    	/** * 重写父类方法 通知订阅正更新消息 */
    	@Override
    	public void notify(String message) { 
    		// TODO Auto-generated method stub
    		for (Observer observer : subjectList) { 
    			observer.update(message);
    		}
    	}
    
    }

具体的观察者，实现了观察者接口，重写了观察者父类的方法。

package com.spring.test2;
    /** * 具体的观察者 * @author 17610 * */
    public class ConcreteObserver implements Observer{ 
    
    	/** * 观察者的属性 */
    	private String name;
    	
    	/** * 构造方法定义对象的具体属性 * @param name */
    	ConcreteObserver(String name){ 
    		this.name = name;
    	}
    	
    	/** * 订阅到的消息 */
    	@Override
    	public void update(String message) { 
    		// TODO Auto-generated method stub
    		System.out.println(name + message);
    	}
    
    }

另一个具体的观察者，也是实现了观察者接口，并重写了父类中的方法。

package com.spring.test2;
    /** * 具体的观察者2号 * @author 17610 * */
    public class ConcreteObserver2 implements Observer{ 
    
    	/** * 观察者的属性 */
    	private String name;
    	
    	/** * 构造方法定义对象的具体属性 * @param name */
    	ConcreteObserver2(String name){ 
    		this.name = name;
    	}
    	
    	/** * 订阅到的消息 */
    	@Override
    	public void update(String message) { 
    		// TODO Auto-generated method stub
    		System.out.println(name + message);
    	}
    
    }

客户端调用：

package com.spring.test2;
    /** * 测试类 * @author 17610 * */
    public class TestClient { 
    
    	public static void main(String[] args) { 
    		
    		//具体的被观察者
    		ConcreteSubject concreteSubject = new ConcreteSubject();
    		
    		//创建观察者对象
    		ConcreteObserver concreteObserver1 = new ConcreteObserver("小学部全体教师：");
    		ConcreteObserver2 concreteObserver2 = new ConcreteObserver2("中学部全体教师：");
    		
    		//观察者订阅消息
    		concreteSubject.attach(concreteObserver1);
    		concreteSubject.attach(concreteObserver2);
    		
    		//中学部 取消了订阅消息
    // concreteSubject.detach(conreteObserver2);
    		
    		//通知订阅者更新消息
    		concreteSubject.notify("今天下午在学校的大礼堂召开全体教职工会议，大家做好准备。");
    	}
    }

运行结果：

小学部全体教师：今天下午在学校的大礼堂召开全体教职工会议，大家做好准备。
    中学部全体教师：今天下午在学校的大礼堂召开全体教职工会议，大家做好准备。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzgzOTMyMw_size_16_color_FFFFFF_t_70_pic_center]: /images/20221120/b4b765d94b60491cbb9f9e97eba5380f.png