一、概述
观察者模式（有时也被称为发布（publish）——订阅（subscribe）模式）,此模式中通常分为观察者（Observer）、被观察者（Subject）,实现被观察者状态发生改变时，观察者会监听到改变。实际上状态发生改变的信息是由被观察者发送给观察者的。
二、模拟结构
（1）观察者（Observer）：提供一个更新（通知 notify）的方法，被观察者动态发生改变时，所有“观察他的对象都得到通知。
（2）被观察者（Subject）：提供增加（addObserver）、删除（deleteObserver）和通知（notifyObservers）观察者信息的功能
三、测试代码
观察者：
package com.dolphin.adapter;
public interface Observer {
void notify(String message,String subName);
}
class WechatChen implements Observer {
private String userName = "陈XX";
@Override
public void notify(String message, String subName) {
System.out.println(userName+":接收到来自公众号<"+subName+">的消息："+message);
}
}
class WechatZhao implements Observer {
private String userName = "赵XX";
@Override
public void notify(String message, String subName) {
System.out.println(userName+":接收到来自公众号<"+subName+">的消息："+message);
}
}
class WechatQian implements Observer {
private String userName = "钱XX";
@Override
public void notify(String message, String subName) {
System.out.println(userName+":接收到来自公众号<"+subName+">的消息："+message);
}
}被观察者：
package com.dolphin.adapter;
import java.util.ArrayList;
import java.util.List;
/**
* 被观察者接口
* @author dxchen
* 提供通知，添加观察者，移除观察者方法
*
*/
public interface Subject {
//添加观察者
void addObserver(Observer observer);
//移除观察者
void deleteObserver(Observer observer);
//通知信息
void notifyObserves(String message);
}
class PublicTec implements Subject {
private String subName = "科技类公众号";
List<Observer> observerList = new ArrayList<>();
@Override
public void addObserver(Observer observer) {
observerList.add(observer);
}
@Override
public void deleteObserver(Observer observer) {
observerList.remove(observer);
}
@Override
public void notifyObserves(String message) {
for(Observer o: observerList) {
o.notify(message, subName);
}
}
}
class PublicLit implements Subject {
private String subName = "文学类类公众号";
List<Observer> observerList = new ArrayList<>();
@Override
public void addObserver(Observer observer) {
observerList.add(observer);
}
@Override
public void deleteObserver(Observer observer) {
observerList.remove(observer);
}
@Override
public void notifyObserves(String message) {
for(Observer o: observerList) {
o.notify(message, subName);
}
}
}测试代码：
package com.dolphin.adapter;
public class Test {
public static void main(String[] args) {
//有两个公众号
Subject publicLit = new PublicLit();//文学类公众号
Subject publicTec = new PublicTec();//科技类公众号
//三个微信用户
Observer wechatChen = new WechatChen();//陈XX
Observer wechatZhao = new WechatZhao();//赵XX
Observer wechatQian = new WechatQian();//钱XX
//订阅公众号 赵和陈订阅文学类 钱订阅科技类
publicLit.addObserver(wechatZhao);
publicLit.addObserver(wechatChen);
publicTec.addObserver(wechatQian);
//公众号推送信息
publicLit.notifyObserves("最新诺贝尔获奖得主。。。。");
publicTec.notifyObserves("神州16号升空。。。");
}
}
测试结果：
赵XX:接收到来自公众号<文学类类公众号>的消息：最新诺贝尔获奖得主。。。。
陈XX:接收到来自公众号<文学类类公众号>的消息：最新诺贝尔获奖得主。。。。
钱XX:接收到来自公众号<科技类公众号>的消息：神州16号升空。。。