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<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数据结构与算法教程》、《java操作dom节点技巧总结》、《java文件与目录操作技巧汇总》和《java缓存操作技巧汇总》

希望本文所述对大家java程序设计有所帮助。