Java中的设计模式(七):观察者模式

介绍

观察者模式是行为设计模式之一。当您对对象的状态感兴趣并希望在有任何更改时收到通知时,观察者设计模式非常有用。在观察者模式中,监视另一个对象状态的对象称为Observer,正在被监视的对象称为Subject。

根据GoF,观察者设计模式的意图是;

定义对象之间的一对多依赖关系,以便当一个对象更改状态时,将自动通知和更新其所有依赖项。

Subject包含一个观察者列表,用于通知其状态的任何变化,因此它应该提供观察者可以注册和注销自己的方法。Subject还包含一种方法,用于通知所有观察者任何更改,并且可以在通知观察者时发送更新,或者它可以提供另一种方法来获取更新。

Observer应该有一个方法来设置要监视的对象,以及Subject将使用的另一个方法来通知它们任何更新。
Java提供了内置平台,用于通过java.util.Observable类和java.util.Observer接口实现Observer模式。但是它没有被广泛使用,因为实现非常简单,并且大多数时候我们不希望最终扩展类只是为了实现Observer模式,因为java不在类中提供多重继承。

Java消息服务(JMS)使用Observer设计模式以及Mediator模式,允许应用程序订阅数据并将数据发布到其他应用程序。

模型 - 视图 - 控制器(MVC)框架也使用Observer模式,其中Model是Subject,而Views是观察者,可以注册以获得对模型的任何更改的通知。

观察者模式Java示例

对于我们的观察者模式java程序示例,我们将实现一个简单的Subject,观察者可以注册到这个Subject。每当有任何新消息发布到Subject时,将通知所有寄存器观察者并且他们可以使用该消息。

根据Subject的要求,这里是基础Subject接口,它定义了由任何具体Subject实现的契约方法。

package com.journaldev.design.observer;

public interface Subject {

    //methods to register and unregister observers
    public void register(Observer obj);
    public void unregister(Observer obj);

    //method to notify observers of change
    public void notifyObservers();

    //method to get updates from subject
    public Object getUpdate(Observer obj);

}

接下来我们将为Observer创建契约,将有一个方法将Subject附加到观察者,以及Subject要用来通知任何更改的另一个方法。

package com.journaldev.design.observer;

public interface Observer {

    //method to update the observer, used by subject
    public void update();

    //attach with subject to observe
    public void setSubject(Subject sub);
}

现在我们的契约准备好了,让我们继续我们Subject的具体实施。

package com.journaldev.design.observer;

import java.util.ArrayList;
import java.util.List;

public class MyTopic implements Subject {

    private List<Observer> observers;
    private String message;
    private boolean changed;
    private final Object MUTEX= new Object();

    public MyTopic(){
        this.observers=new ArrayList<>();
    }
    @Override
    public void register(Observer obj) {
        if(obj == null) throw new NullPointerException("Null Observer");
        synchronized (MUTEX) {
        if(!observers.contains(obj)) observers.add(obj);
        }
    }

    @Override
    public void unregister(Observer obj) {
        synchronized (MUTEX) {
        observers.remove(obj);
        }
    }

    @Override
    public void notifyObservers() {
        List<Observer> observersLocal = null;
        //synchronization is used to make sure any observer registered after message is received is not notified
        synchronized (MUTEX) {
            if (!changed)
                return;
            observersLocal = new ArrayList<>(this.observers);
            this.changed=false;
        }
        for (Observer obj : observersLocal) {
            obj.update();
        }

    }

    @Override
    public Object getUpdate(Observer obj) {
        return this.message;
    }

    //method to post message to the topic
    public void postMessage(String msg){
        System.out.println("Message Posted to Topic:"+msg);
        this.message=msg;
        this.changed=true;
        notifyObservers();
    }

}

注册和取消注册观察者的方法实现非常简单,额外的方法是postMessage(),户端应用程序将使用它将String消息发布到主题。请注意布尔变量,以跟踪主题状态的变化并用于通知观察者。此变量是必需的,因此如果没有更新并且某人调用notifyObservers(),则它不会向观察者发送错误通知。

还要注意在notifyObservers()方法中使用同步,以确保仅将通知发送给在将消息发布到主题之前注册的观察者。

以下是将观察主题的观察者的实施。

package com.journaldev.design.observer;

public class MyTopicSubscriber implements Observer {

    private String name;
    private Subject topic;

    public MyTopicSubscriber(String nm){
        this.name=nm;
    }
    @Override
    public void update() {
        String msg = (String) topic.getUpdate(this);
        if(msg == null){
            System.out.println(name+":: No new message");
        }else
        System.out.println(name+":: Consuming message::"+msg);
    }

    @Override
    public void setSubject(Subject sub) {
        this.topic=sub;
    }

}

注意update()方法的实现,它调用Subject getUpdate()方法来获取要使用的消息。我们可以通过将message作为参数传递给update()方法来避免这种调用。

这是一个简单的测试程序,用于使用我们的Subject主题实现。

package com.journaldev.design.observer;

public class ObserverPatternTest {

    public static void main(String[] args) {
        //create subject
        MyTopic topic = new MyTopic();

        //create observers
        Observer obj1 = new MyTopicSubscriber("Obj1");
        Observer obj2 = new MyTopicSubscriber("Obj2");
        Observer obj3 = new MyTopicSubscriber("Obj3");

        //register observers to the subject
        topic.register(obj1);
        topic.register(obj2);
        topic.register(obj3);

        //attach observer to subject
        obj1.setSubject(topic);
        obj2.setSubject(topic);
        obj3.setSubject(topic);

        //check if any update is available
        obj1.update();

        //now send message to subject
        topic.postMessage("New Message");
    }

}

当我们运行上面的程序时,我们得到以下输出。

Obj1:: No new message
Message Posted to Topic:New Message
Obj1:: Consuming message::New Message
Obj2:: Consuming message::New Message
Obj3:: Consuming message::New Message

Java观察者模式类图


观察者设计模式也称为发布 - 订阅模式。其中一些实现是:

  • Swing中的java.util.EventListener
  • javax.servlet.http.HttpSessionBindingListener
  • javax.servlet.http.HttpSessionAttributeListener
  • java.util.Observer
  • java.util.EventListener
  • javax.servlet.http.HttpSessionBindingListener

适用场景:

在以下任何一种情况下使用Observer模式

  • 在一个对象中进行更改会导致其他对象发生更改
  • 当抽象有两个方面时,一个依赖于另一个。将这些方面封装在单独的对象中可让您独立地改变和重用它们。
  • 当一个对象的更改需要更改其他对象时,您不知道需要更改多少个对象。
  • 当一个对象应该能够通知其他对象而不假设这些对象是谁。换句话说,您不希望这些对象紧密耦合。

这就是java中的Observer设计模式,我希望你喜欢它。与评论分享您的爱,并与他人分享。
翻译于:observer-design-pattern-in-java

原文地址:https://www.cnblogs.com/jajian/p/9746433.html

时间: 2024-10-01 19:53:14

Java中的设计模式(七):观察者模式的相关文章

Java中单态设计模式

Java中单态设计模式 2011-09-23 16:38:46|  分类: Java |  标签:technology!  |举报|字号 订阅 此博文是转自新浪博客中一名叫做"俊俊的BLOG“用户的一篇博文.感觉此博文确实很不错,所以在此拿出来分享一下!(笔者只是对其所举的代码略做了一些修改) 一概念: 设计模式:设计模式是指经过大量的实践总结和理论化之后的优选的代码结构.编程风格.以及解决问题的思路. 单态设计模式:采取一定的方法保证在整个软件系统中,对某个类只能产生一个对象实例,并且该类只提

Java中常见设计模式面试

一.设计模式的分类 总体来说设计模式分为三大类: 创建型模式,共五种:工厂方法模式.抽象工厂模式.单例模式.建造者模式.原型模式. 结构型模式,共七种:适配器模式.装饰器模式.代理模式.外观模式.桥接模式.组合模式.享元模式. 行为型模式,共十一种: 策略模式.模板方法模式.观察者模式.迭代子模式.责任链模式.命令模式.备忘录模式.状态模式.访问者模式.中介者模式.解释器模式. 1.请列举出在JDK中几个常用的设计模式? 单例模式用于Runtime, Calendar和其他的一些类中.工厂模式被

Java中的设计模式(八):建造者模式

介绍 今天我们将研究java中的Builder模式.Builder 设计模式是一种创造性的设计模式,如工厂模式和抽象工厂模式. 当Object包含许多属性时,引入了Builder模式来解决Factory和Abstract Factory设计模式的一些问题. 当Object包含许多属性时,Factory和Abstract Factory设计模式存在三个主要问题. 从客户端程序传递到Factory类的参数太多,可能容易出错,因为大多数情况下,参数的类型是相同的,而从客户端来说,很难维护参数的顺序.

浅谈java中内置的观察者模式与动态代理的实现

一.关于观察者模式 1.将观察者与被观察者分离开来,当被观察者发生变化时,将通知所有观察者,观察者会根据这些变化做出对应的处理. 2.jdk里已经提供对应的Observer接口(观察者接口)与Observable(被观察者类)用于实现观察者模式 3.关于Observer接口,该接口只有一个update方法,当被观察者发生相关变化时,会通知所有的观察者,观察者接受到通知时,调用update方法进行处理.贴出源代码: 1 /* 2 * Copyright (c) 1994, 1998, Oracle

JAVA中常用设计模式

设计模式:一个程序员对设计模式的理解:"不懂"为什么要把很简单的东西搞得那么复杂.后来随着软件开发经验的增加才开始明白我所看到的"复杂"恰恰就是设计模式的精髓所在,我所理解的"简单"就是一把钥匙开一把锁的模式,目的仅仅是着眼于解决现在的问题,而设计模式的"复杂"就在于它是要构造一个"万能钥匙",目的是提出一种对所有锁的开锁方案.在真正理解设计模式之前我一直在编写"简单"的代码.这个&qu

黑马程序员——Java中的设计模式

------- android培训.java培训.期待与您交流! ---------- Java中有23种设计模式 按照目的来分,设计模式可以分为创建型模式.结构型模式和行为型模式. 创建型模式用来处理对象的创建过程:结构型模式用来处理类或者对象的组合:行为型模式用来对类或对象怎样交互和怎样分配职责进行描述. 创建型模式用来处理对象的创建过程,主要包含以下5种设计模式:  工厂方法模式(Factory Method Pattern)  抽象工厂模式(Abstract Factory Patt

Android中的设计模式之观察者模式

参考 <设计模式:可复用面向对象软件的基础 >5.7 Observer 观察者 对象行为型模式 <设计模式解析> 18.4 Observer模式 <Android源码设计模式解析与实战>第12章 解决,解耦的钥匙--观察者模式 本人能力有限,如有明显错误,不规范的地方,请指正,谢谢. 意图 定义对象间的一种一对多的依赖关系,当一个对象的状态发生改变时,所有依赖于它的对象都得到通知并自动更新. 别名 依赖(Dependents)发布-订阅(Publish-Subscrib

php中的设计模式之--观察者模式

<?php /** 1. 概述 又称为发布-订阅(Publish-Subscribe)模式.模型-视图(Model-View)模式.源-监听(Source-Listener)模式.或从属者(Dependents)模式 2. 解决的问题 将一个系统分割成一个一些类相互协作的类有一个不好的副作用,那就是需要维护相关对象间的一致性.我们不希望为了维持一致性而使各类紧密耦合,这样会给维护.扩展和重用都带来不便.观察者就是解决这类的耦合关系的. 3. 模式中的角色 3.1 抽象主题(Subject):它把

关于JAVA中状态设计模式的讲解示例代码

为了使同一个方法调用可以产生不同的行为,State 模式在代理(surrogate)的生命周期内切换它所对应的实现(implementation).当你发现,在决定如何实现任何一个方法之前都必须作很多测试的情况下,这是一种优化实现代码的方法.     --     对象去耦(Object decoupling) 例如:童话故事青蛙王子就包含一个对象(一个生物),这个对象的行为取决于它自己所处 的状态.你可以用一个布尔(boolean)值来表示它的状态,测试程序如下: 状态模式:改变对象的行为,