java 自带观察者模式_Java编程之内置观察者模式实例详解

本文实例讲述了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 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程序设计有所帮助。