观察者模式实际上是一种发布-订阅模式，多个cli订阅(监听)了一个主题，当这个主题发生改变时，会通知所有订阅的cli，cli即使更新信息，如：zookeeper的watch机制
观察者模式的组成部分：
Subject(抽象主题)：里面封装了一个注册列表，可以增加，删除观察者
ConcreteSubject(具体主题)：该角色将有关状态存入具体观察者对象，在具体主题的内部状态发生改变时，给所有注 册过的观察者发送通知
Observer：抽象观察者，是观察者者的抽象类，它定义了一个更新接口，使得在得到主题更改通知时更新自己
ConcrereObserver：具体观察者，实现抽象观察者定义的更新接口，以便在得到主题更改通知时更新自身的状态
问题：
现在有一支中国银行发行的国家债券，小王和小晴分别卖了这一支国债，当这支国债涨跌超过0.3个百分点，就会发信息提醒他们是否 抛售
传统方法：定义一个债券Bond类，内部封装一个WQL，FUqin的引用变量，setA来更新值，display负责更新时通知，在display中调用updata方法
public class 传统方法 {
public static void main(String[] args) {
Bond a=new Bond(0.1);
a.setA(0.4);
}
}
class Bond{
WQL wql;
FUQIN fuqin;
double a;//涨跌数
public Bond(double a){
this.a=a;
}
public void setA(double a){
this.a=a;
if(a>0.3){
display();
}
}
public void display(){//这是推送方法，当值被修改set方法调用display，display将值推送给小王和小晴，也可以设置为拉取
wql=new WQL();
fuqin=new FUQIN();
wql.updata(a);
fuqin.updata(a);
}
}
class WQL{
double a;//涨跌数
public void updata(double a){
this.a=a;
System.out.println("小王的债券提示！！");
}}
class FUQIN{
double a;//涨跌数
public void updata(double a){
this.a=a;
System.out.print("小晴的债券提示！！！");
}
}
弊端：当除了小王和小晴，还有其他人要买，Bond的引用会越来越多，代码冗余也多
观察者模式：减少订阅者和发布者的耦合，通过注册列表，如:传统方式当债券的涨幅变动，股票类会专门一个一个的通知，债券类必须封装每一个类的引用，代码冗余大，观察者模式，建立一个注册列表，买债券的在列表中注册添加，但值改变时，把列表中的对象取出通知，一对多，把多的用集合装起来
import java.util.ArrayList;
public class 观察者 {
public static void main(String[] args) {
Bond n=new Bond();
n.add(new WQL());
n.add(new FUQING());
n.setS(100);
}
}
interface abBond{
abstract public void add(observer a);
abstract public void remove(observer a);
abstract public void nofyity();
}
class Bond implements abBond{
int s;
public void setS(int a){
this.s=a;
nofyity();
}
ArrayList<observer> list=new ArrayList(); //注册列表
@Override
public void add(observer a) {
list.add(a);
}
@Override
public void remove(observer a) {
list.remove(a);
}
@Override
public void nofyity() {
for (observer a:list){
a.updata(s);
}
}
}
interface observer{
abstract public void updata(int a);
}
class WQL implements observer{
int a;
@Override
public void updata(int a) //更新方法
{
this.a=a;
if(a>3){
pr(a);
}
}
//把值打印
public void pr(int a){
System.out.println("小王债券更新！！！"+a);
}
}
class FUQING implements observer{
int a;
@Override
public void updata(int a) {
this.a=a;
if(a>3){
pr(a);
}
}
public void pr(int a){
System.out.println("小王债券更新！！！"+a);
}
}
Comments | NOTHING