设计模式之观察者模式——利用java中提供的观察者实现

Myth丶恋晨 2022-04-15 01:11 281阅读 0赞

### java实现与自己实现的对比 ###

一、不需要再定义观察者和目标的接口了，JDK帮忙定义了  
二、具体的目标实现里面不需要再维护观察者的注册信息了，这在Java中的Observable类里面已经帮忙实现好了。  
三、触发通知的方式有一点变化，要先调用setChanged方法，这个是Java未来帮助实现更精确的触发控制而提供的功能。  
四、具体观察者的实现里面，update方法其实能同时支持推模型和拉模型，这个是java在定义的时候，就已经考虑进去了。

### ConcreteSubject ###

public class ConcreteSubject extends Observable {
        private String content;
    
        public String getContent() {
            return content;
        }
    
        public void setContent(String content) {
            this.content = content;
            //通知所有股东观察者
            //注意在通知之前，在用java中Observer模式时候，下面这句不能少
            this.setChanged();
            //然后主动通知，这里先用推的方式
            this.notifyObservers(content);
    
            //如果是拉的方式，我们就调用
            //this.notifyObservers();//默认把整个subject传过去了
        }
    }

### ConcreteObserver ###

public class ConcreteObserver implements Observer {
        //观察者名称的变量
        private String observerName;
    
        public String getObserverName() {
            return observerName;
        }
    
        public void setObserverName(String observerName) {
            this.observerName = observerName;
        }
    
        @Override
        public void update(Observable o, Object arg) {
            //第一种是推的方式
            System.out.println(observerName+"收到了消息，目标推送过来的是"+arg);
            //第二种是拉的方式
            System.out.println(observerName+"收到了消息，主动到目标对象中去拉，拉的内容是"+((ConcreteSubject)o).getContent());
        }
    }

测试类

public class Client {
        public static void main(String[] args) {
            //创建一个目标，也可以说是被观察者
            ConcreteSubject subject =new ConcreteSubject();
            //创建观察者
            ConcreteObserver observer1=new ConcreteObserver();
            observer1.setObserverName("观察者一号");
    
            ConcreteObserver observer2=new ConcreteObserver();
            observer2.setObserverName("观察者二号");
    
            //注册观察者
            subject.addObserver(observer1);
            subject.addObserver(observer2);
    
            //目标更新content
            subject.setContent("目标内容更新了");
        }
    }