观察者模式之通用代码（拉模型方式实现）

忘是亡心i 2022-06-06 09:22 74阅读 0赞

1.首先定义目标对象

import java.util.ArrayList;
    import java.util.List;
    
    
    /** * 目标对象，它知道他的观察者，并提供添加和删除观察者的接口 * @author MQC * */
    public class Subject { 
        /** * 当前注册的所有观察者 */
        private List<Observer> observers = new ArrayList<Observer>();
    
        /** * @param os * 注册新的观察者 */
        private void attach(Observer os){
            observers.add(os);
        }
    
        /** * @param os * 删除对应的观察者 */
        private void detach(Observer os){
            observers.remove(os);
        }
    
        /** * 通知所有观察者 */
        protected void notifyObserver() {
            for (Observer observer : observers) {
                observer.update(this);
            }
        }
    }

2.定义具体目标对象

/** * 具体的目标对象 * @author MQC * */
    public class CreateSubject extends Subject{ 
        /** * 当前目标对象的状态 */
        private String subjectStatus;
    
        public String getSubjectStatus() {
            return subjectStatus;
        }
    
        /** * @param subjectStatus * 当目标对象的状态发生改变的时候需要通知当前所有的观察者 */
        public void setSubjectStatus(String subjectStatus) {
            this.subjectStatus = subjectStatus;
            this.notifyObserver();
        }
    
    }

3.观察者接口的定义

4.观察者的具体实现

/** * 具体的观察者对象，实现更新方法，使自身的状态和目标的状态保持一致 * @author MQC * */
    public class CreateObserver implements Observer { 
    
        /** * 自身状态 */
        private String observerStatus;
    
        /** * 更新自身的状态，使自身的状态跟目标对象的状态保持一致 */
        @Override
        public void update(Subject os) {
            this.observerStatus = ((CreateSubject)os).getSubjectStatus();
        }
    
    }

下面是一个我写的一个测试代码：做的是一个天气预报发送的小案例  
**目标对象：**

import java.util.ArrayList;
    import java.util.List;
    
    
    /** * 目标对象，它知道他的观察者，并提供添加和删除观察者的接口 * @author HASEE * */
    public class WeatherSubject { 
        /** * 当前注册的所有观察者 */
        private List<Observer> observers = new ArrayList<Observer>();
    
        /** * @param os * 注册新的观察者 */
        protected void attach(Observer os){
            observers.add(os);
        }
    
        /** * @param os * 删除对应的观察者 */
        protected void detach(Observer os){
            observers.remove(os);
        }
    
        /** * 通知所有观察者 */
        protected void notifyObserver() {
            for (Observer observer : observers) {
                observer.update(this);
            }
        }
    }

**具体的目标对象**

/** * 具体的目标对象 * @author HASEE * */
    public class CreateWeatherSubject extends WeatherSubject{ 
        /** * 当前目标对象的状态 */
        private String subjectStatus;
    
        public String getSubjectStatus() {
            return subjectStatus;
        }
    
        /** * @param subjectStatus * 当目标对象的状态发生改变的时候需要通知当前所有的观察者 */
        public void setSubjectStatus(String subjectStatus) {
            this.subjectStatus = subjectStatus;
            this.notifyObserver();
        }
    
    }

**观察者接口**

/** * 观察者接口，定义一个更新的接口给那些在目标对象发生改变的时候被通知的对象 * @author HASEE * */
    public interface Observer { 
        public void update(WeatherSubject os );
    }

**具体观察者对象**

**对应的测试代码：**

import org.junit.Test;
    
    
    public class TestObserver { 
    
        @Test
        public void test(){
            //第一步，创建目标对象
            CreateWeatherSubject subject = new CreateWeatherSubject();
            //第二步，创建吗观察者对象
            CreateObserver obOne = new CreateObserver();
            CreateObserver obTwo = new CreateObserver();
    
            obOne.setDoThing("去约会");
            obOne.setObserverName("小明");
    
            obTwo.setDoThing("去阿米东西");
            obTwo.setObserverName("小白");
    
            //第三步，注册对应的观察者
            subject.attach(obOne);
            subject.attach(obTwo);
    
            //第四步，目标对象改变自身的状态
            subject.setSubjectStatus("今天的天气是25°，天气晴朗");
        }
    }

以上是我学习得到对于观察者模式的理解，我觉得IT这一行是一个不断学习的职业，作为入门者，欢迎大家的指导.