服务器之家:专注于服务器技术及软件下载分享
分类导航

PHP教程|ASP.NET教程|JAVA教程|ASP教程|编程技术|正则表达式|C/C++|

服务器之家 - 编程语言 - JAVA教程 - Java编程之内置观察者模式实例详解

Java编程之内置观察者模式实例详解

2020-12-10 13:50迟做总比不做强 JAVA教程

这篇文章主要介绍了Java编程之内置观察者模式,结合实例形式较为详细的分析了java内置观察者模式的原理、实现方法及相关注意事项,需要的朋友可以参考下

本文实例讲述了Java内置观察者模式。分享给大家供大家参考,具体如下:

之前也简单地写过观察者模式(又称为发布-订阅模式)小例子,现在项目中也常用到该模式。今天贴一下如何使用Java内置的观察者模式。

主要使用到的Java API就两个类:

Observer接口:观察者对象,监听被观察者对象数据变化,一是数据发生变化 ,就做出相应地啥响应。
Observable类:被观察者对象,提供添加及移出观察者对像方法,数据发生哟完成时并通知所有已经添加进来的观察者对象。

被观察者代码示例:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
//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个观察者代码示例:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
//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());
 }
}
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
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());
 }
}

测试代码:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
/**
  * @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("***我要更新的数据***");
 }
}

执行结果:

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

模式优点:

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

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

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

?
1
2
3
4
5
package java.util;
import java.util.Observable;
public interface Observer {
 void update(Observable var1, Object var2);
}
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
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教程J2ME 程序开发注意要点

    J2ME 程序开发注意要点

    讲Java基础的书籍中都是以J2SE来讲基础,这就给学习造成了一些不必要的麻烦,下面将J2ME中用到的和不需要的Java基础知识做一个简单的说明 ...

    java教程网1532020-05-26
  • JAVA教程详解Spring中Bean的加载的方法

    详解Spring中Bean的加载的方法

    本篇文章主要介绍了Spring中Bean的加载的方法,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧...

    weknow3062020-09-07
  • JAVA教程Java JDK动态代理(AOP)的实现原理与使用详析

    Java JDK动态代理(AOP)的实现原理与使用详析

    所谓代理,就是一个人或者一个机构代表另一个人或者另一个机构采取行动。下面这篇文章主要给大家介绍了关于Java JDK动态代理(AOP)实现原理与使用的...

    衣舞晨风3052020-12-03
  • JAVA教程Java实现Dbhelper支持大数据增删改

    Java实现Dbhelper支持大数据增删改

    这篇文章主要介绍了Java实现Dbhelper支持大数据增删改功能的实现过程,感兴趣的小伙伴们可以参考一下 ...

    邱慕夏1832020-03-25
  • JAVA教程深入理解spring多数据源配置

    深入理解spring多数据源配置

    项目中我们经常会遇到多数据源的问题,尤其是数据同步或定时任务等项目更是如此。本篇文章主要介绍了spring多数据源配置,有兴趣的可以了解一下。...

    wangpeng0472202020-07-23
  • JAVA教程Java中for循环的执行过程分析

    Java中for循环的执行过程分析

    这篇文章主要介绍了Java中for循环的执行过程,实例分析了for循环的执行原理与顺序,对于深入理解Java具有一定参考借鉴价值,需要的朋友可以参考下 ...

    Benjamin_whx2652019-12-09
  • JAVA教程Java的作业调度类库Quartz基本使用指南

    Java的作业调度类库Quartz基本使用指南

    这篇文章主要介绍了Java的作业调度类库Quartz基本使用指南,Quartz能够让类按照指定的计划顺序执行,需要的朋友可以参考下 ...

    goldensun2702020-04-08
  • JAVA教程java全角、半角字符的关系以及转换详解

    java全角、半角字符的关系以及转换详解

    如果搞明白了Java中全角字符和半角字符之间的关系 那他们之间的转换根本就不是个事. 全角字符与半角字符的关系 可以通过下面的程序看看Java中所有字符...

    java技术网5582019-10-22