怎么在Java項(xiàng)目中實(shí)現(xiàn)一個(gè)內(nèi)置觀察者模式

這期內(nèi)容當(dāng)中小編將會(huì)給大家?guī)碛嘘P(guān)怎么在Java項(xiàng)目中實(shí)現(xiàn)一個(gè)內(nèi)置觀察者模式，文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

主要使用到的Java API就兩個(gè)類：

Observer接口：觀察者對(duì)象，監(jiān)聽被觀察者對(duì)象數(shù)據(jù)變化，一是數(shù)據(jù)發(fā)生變化 ，就做出相應(yīng)地啥響應(yīng)。
Observable類：被觀察者對(duì)象，提供添加及移出觀察者對(duì)像方法，數(shù)據(jù)發(fā)生喲完成時(shí)并通知所有已經(jīng)添加進(jìn)來的觀察者對(duì)象。

被觀察者代碼示例：

//Observable是被觀察者對(duì)象接口，實(shí)現(xiàn)該接口就是：目標(biāo)（被觀察者）的具體實(shí)現(xiàn)
public class TargetObservable extends Observable {
 // 要觀察的數(shù)據(jù)：消息發(fā)生改變時(shí)，所有被添加的觀察者都能收到通知
 private String message;
 public String getConent() {
  return message;
 }
 public void setMessage(String message) {
  this.message = message;
  // 被觀察者數(shù)據(jù)發(fā)生變化時(shí)，通過以下兩行代碼通知所有的觀察者
  this.setChanged();
  this.notifyObservers(message);
 }
}

2個(gè)觀察者代碼示例：

//Observer對(duì)象是觀察者，實(shí)現(xiàn)Observer的對(duì)象就是具體的觀察者對(duì)象
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) {
  //更新消息數(shù)據(jù)
  System.out.println(name + "收到了發(fā)生變化的數(shù)據(jù)內(nèi)容是："
    + ((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) {
  //更新消息數(shù)據(jù)
  System.out.println(name01 + "收到了發(fā)生變化的數(shù)據(jù)內(nèi)容是："
    + ((TargetObservable) arg0).getConent());
 }
}

測(cè)試代碼：

/**
  * @description：測(cè)試類
  * @author ldm
  * @date 2016-11-1 上午8:29:07
  */
 public static void main(String[] args) {
  // 創(chuàng)建一個(gè)具體的被 觀察者
  TargetObservable observable = new TargetObservable();
  // 創(chuàng)建第一個(gè)觀察者
  TargetObserver one = new TargetObserver();
  one.setObserverName("我是觀察者A");
  // 創(chuàng)建第二個(gè)觀察者
  TargetObserver01 two = new TargetObserver01();
  two.setObserverName("我是觀察者B");
  // 注冊(cè)觀察者
  observable.addObserver(one);
  observable.addObserver(two);
  // 目標(biāo)更新天氣情況
  observable.setMessage("***我要更新的數(shù)據(jù)***");
 }
}

執(zhí)行結(jié)果：

我是觀察者B收到了發(fā)生變化的數(shù)據(jù)內(nèi)容是：—–我要更新的數(shù)據(jù)—–
我是觀察者A收到了發(fā)生變化的數(shù)據(jù)內(nèi)容是：—–我要更新的數(shù)據(jù)—–

模式優(yōu)點(diǎn)：

一個(gè)被觀察者可以對(duì)應(yīng)多個(gè)觀察者，當(dāng)被觀察者發(fā)生變化的時(shí)候，他可以將消息通知給所有已經(jīng)添加觀察者?；诮涌趯?shí)現(xiàn)為程序提供了更大的靈活性。

但在使用時(shí)要注意根據(jù)條件及時(shí)添加或移除觀察者對(duì)象，否則可能導(dǎo)致意料外結(jié)果 。

最后附上Observer和Observable的原碼，這樣我們自己在寫的時(shí)候就知道如何下手了：

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項(xiàng)目中實(shí)現(xiàn)一個(gè)內(nèi)置觀察者模式了，如果剛好有類似的疑惑，不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識(shí)，歡迎關(guān)注億速云行業(yè)資訊頻道。