java设计模式九之观察者设计模式（二）

电玩女神 2022-05-22 08:11 198阅读 0赞

##### 前言： #####

在上一篇中，我们是用的java.util包下的观察者与被观察者父类。这次我们自己写一个

##### 代码：    #####

被观察者父类Observable，有一个添加观察者的集合，添加观察者的方法，删除观察者的方法，通知观察者的方法。

package com.xhx.designpattern.entity;
    
    import com.xhx.designpattern.observer.Observer;
    
    import java.util.ArrayList;
    import java.util.List;
    
    public abstract class Observable {
        List<Observer> observerList;
    
        public Observable(){
            observerList = new ArrayList<>();
        }
    
        public synchronized void addObserver(Observer observer){
            if(observer==null){
                throw new NullPointerException();
            }
            if(!observerList.contains(observer)){
                observerList.add(observer);
            }
        }
    
        public synchronized void deleteObservers() {
            observerList.clear();
        }
        public synchronized void deleteObserver(Observer observer){
            observerList.remove(observer);
        }
    
        public void notifyObservers(Object object){
            observerList.forEach(observer -> observer.update(this,object));
        }
    
    
    }

被观察者实现类，当年龄改变的时候通知观察者

package com.xhx.designpattern.entity;
    
    
    /**
     * xuhaixing
     * 2018/6/18 23:31
     *
     * Person类作为被观察者，需要继承java.util.Observable这个类
     **/
    public class Person extends Observable {
        private String name;
        private int age;
    
        public String getName() {
            return name;
        }
    
        public void setName(String name) {
            this.name = name;
        }
    
        public int getAge() {
            return age;
        }
    
        /**
         * 当年龄改变的时候，通知观察者
         * @param age
         */
        public void setAge(int age) {
            this.age = age;
            this.notifyObservers(this); //通知观察者，可以传参数也可以不传
        }
    }

观察者父类，含有一个回调函数

package com.xhx.designpattern.observer;
    
    import com.xhx.designpattern.entity.Observable;
    
    public interface Observer {
        void update(Observable observable, Object object);
    }

观察者的具体实现

package com.xhx.designpattern.observer;
    
    import com.xhx.designpattern.entity.Observable;
    import com.xhx.designpattern.entity.Person;
    
    
    /**
     * xuhaixing
     * 2018/6/18 23:35
     *
     * 观察者，需要继承 Observer 这个类
     **/
    public class BirthdayObserver implements Observer {
        @Override
        public void update(Observable o, Object arg) {
            Person person = (Person)arg;
            System.out.println("祝 "+person.getName() +" " +person.getAge() + "岁生日快乐");
        }
    }

测试方法：

package com.xhx.designpattern;
    
    import com.xhx.designpattern.entity.Person;
    import com.xhx.designpattern.observer.BirthdayObserver;
    
    /**
     * Hello world!
     *
     */
    public class App 
    {
        public static void main( String[] args )
        {
    
            Person person = new Person();
            person.addObserver(new BirthdayObserver()); //添加观察者
            person.setName("小红");
            person.setAge(17);
            person.setAge(18);
    
            person.deleteObservers();//删除所有观察者
            person.setAge(19);
    
        }
    }

![70][]

[我的github代码地址][github]

[70]: /images/20220522/1b0f86f218af40a18f0302532a7c8921.png
[github]: https://github.com/xuhaixing/myDocument.git