设计模式（二十）观察者模式

爱被打了一巴掌 2022-06-18 11:21 161阅读 0赞

观察者模式也是一种行为型模式，它的作用是将被观察者的任何状态变化传递给观察者。观察者模式在GUI编程的双向绑定等领域都有应用。只要我们希望实现一个类似消息订阅、接收的模式，就可以使用观察者模式。

首先我们需要一个观察者接口，当被观察者发生变化的时候，需要通过该接口的方法通知观察者。

public interface Observer<T> {
        void onChanged(T arg);
    }

然后是被观察者，当被观察者被更改的时候，需要通过显示调用`update()`方法告诉观察者，“我已经发生了更改”。

public class Observable<T> {
        private List<Observer<T>> observers = new ArrayList<>();
        private T content;
    
        public Observable(T value) {
            content = value;
        }
    
        public void addObserver(Observer observer) {
            observers.add(observer);
        }
    
        public void removeObserver(Observer observer) {
            observers.remove(observer);
        }
    
        protected void update(T value) {
            content = value;
            for (Observer ob : observers) {
                ob.onChanged(content);
            }
        }
    }

然后来看看观察者的实现。这个例子有一点不太好，就是观察者使用了接口，但是被观察者没有使用接口。实际类库中，一般都有被观察者接口，我们可以实现该接口来实现自己的操作。这里的观察者很简单，接受消息，然后打印到终端上。

class ObserverImpl<T> implements Observer<T> { 
        private String name;
    
        public ObserverImpl(String name) {
            this.name = name;
        }
    
        @Override
        public void onChanged(T arg) {
            System.out.println(name + " receives:" + arg);
        }
    }

最后来测试一下。当被观察者发生更改的时候，观察者成功的接收到了更该消息。

public void run() {
            Observable<String> sender = new Observable("value1");
            Observer<String> receiver1 = new ObserverImpl<>("ob1");
            Observer<String> receiver2 = new ObserverImpl<>("ob2");
            sender.addObserver(receiver1);
            sender.addObserver(receiver2);
    
            sender.update("value2");
            sender.update("value3");
    
        }