返回 登录
0

Java内置观察者模式

学习Java的同学注意了!!!
学习过程中遇到什么问题或者想获取学习资源的话,欢迎加入Java学习交流群,群号码:279558494 我们一起学Java!

之前也简单地写过观察者模式(又称为发布-订阅模式)小例子,现在项目中也常用到该模式。今天贴一下如何使用Java内置的观察者模式。
主要使用到的Java API就两个类:
•Observer接口:观察者对象,监听被观察者对象数据变化,一是数据发生变化 ,就做出相应地啥响应。
• Observable类:被观察者对象,提供添加及移出观察者对像方法,数据发生哟完成时并通知所有已经添加进来的观察者对象。
被观察者代码示例:

//Observable是被观察者对象接口,实现该接口就是:目标(被观察者)的具体实现
public class TargetObservable extends Observable {
    // 要观察的数据:消息发生改变时,所有被添加的观察者都能收到通知
    private String message;

    public String getConent() {
        return message;
    }

    public void setMessage(String message) {
        this.message = message;
        // 被观察者数据发生变化时,通过以下两行代码通知所有的观察者
        this.setChanged();
        this.notifyObservers(message);
    }
}

2个观察者代码示例:

//Observer对象是观察者,实现Observer的对象就是具体的观察者对象
public class TargetObserver implements Observer {
    // 定义观察者名称
    private String name;

    public String getObserverName() {
        return name;
    }

    public void setObserverName(String observerName) {
        this.name = observerName;
    }

    @Override
    public void update(Observable arg0, Object arg1) {
        //更新消息数据
        System.out.println(name + "收到了发生变化的数据内容是:"
                + ((TargetObservable) arg0).getConent());
    }
}
public class TargetObserver01 implements Observer {
    // 定义观察者名称
    private String name01;

    public String getObserverName() {
        return name01;
    }

    public void setObserverName(String observerName) {
        this.name01 = observerName;
    }

    @Override
    public void update(Observable arg0, Object arg1) {
        //更新消息数据
        System.out.println(name01 + "收到了发生变化的数据内容是:"
                + ((TargetObservable) arg0).getConent());
    }
}

测试代码:

/**
     * @description:测试类
     * @author ldm
     * @date 2016-11-1 上午8:29:07
     */
    public static void main(String[] args) {
        // 创建一个具体的被 观察者
        TargetObservable observable = new TargetObservable();
        // 创建第一个观察者
        TargetObserver one = new TargetObserver();
        one.setObserverName("我是观察者A");
        // 创建第二个观察者
        TargetObserver01 two = new TargetObserver01();
        two.setObserverName("我是观察者B");
        // 注册观察者
        observable.addObserver(one);
        observable.addObserver(two);
        // 目标更新天气情况
        observable.setMessage("***我要更新的数据***");
    }

}

执行结果:

我是观察者B收到了发生变化的数据内容是:—–我要更新的数据—–

我是观察者A收到了发生变化的数据内容是:—–我要更新的数据—–

模式优点:

一个被观察者可以对应多个观察者,当被观察者发生变化的时候,他可以将消息通知给所有已经添加观察者。基于接口实现为程序提供了更大的灵活性。

但在使用时要注意根据条件及时添加或移除观察者对象,否则可能导致意料外结果 。

最后附上Observer和Observable的原码,这样我们自己在写的时候就知道如何下手了:

package java.util;

import java.util.Observable;

public interface Observer {
    void update(Observable var1, Object var2);
}
package java.util;

import java.util.Observer;
import java.util.Vector;

public class Observable {
    private boolean changed = false;
    private Vector<Observer> obs = new Vector();

    public Observable() {
    }

    public synchronized void addObserver(Observer var1) {
        if(var1 == null) {
            throw new NullPointerException();
        } else {
            if(!this.obs.contains(var1)) {
                this.obs.addElement(var1);
            }

        }
    }

    public synchronized void deleteObserver(Observer var1) {
        this.obs.removeElement(var1);
    }

    public void notifyObservers() {
        this.notifyObservers((Object)null);
    }

    public void notifyObservers(Object var1) {
        Object[] var2;
        synchronized(this) {
            if(!this.changed) {
                return;
            }

            var2 = this.obs.toArray();
            this.clearChanged();
        }

        for(int var3 = var2.length - 1; var3 >= 0; --var3) {
            ((Observer)var2[var3]).update(this, var1);
        }

    }

    public synchronized void deleteObservers() {
        this.obs.removeAllElements();
    }

    protected synchronized void setChanged() {
        this.changed = true;
    }

    protected synchronized void clearChanged() {
        this.changed = false;
    }

    public synchronized boolean hasChanged() {
        return this.changed;
    }

    public synchronized int countObservers() {
        return this.obs.size();
    }
}

学习Java的同学注意了!!!
学习过程中遇到什么问题或者想获取学习资源的话,欢迎加入Java学习交流群,群号码:279558494 我们一起学Java!

评论