怎么在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()); }}

测试代码：

 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项目中实现一个内置观察者模式了，如果刚好有类似的疑惑，不妨参照上述分析进行理解。如果想知道更多相关知识，欢迎关注编程网精选频道。