Java观察者模式(Observer)-阿里云开发者社区

开发者社区> 游客a74jvhcp7vclg> 正文

Java观察者模式(Observer)

简介: Java观察者模式(Observer)
+关注继续查看

文章目录


观察者模式

一、概述

1. 使用场景

2. UML类图

3. 核心角色

二、手动实现观察者模式

1.定义抽象被观察者角色

2.定义抽象观察者角色

3.定义具体被观察者角色

4.定义具体观察者角色

5.测试

三、Java内置观察者模式实现

1.定义具体被观察者

2.定义具体观察者

3.测试

四、开发中的常用场景:


 观察者模式java GOF23种设计模式中的一种。在最近介绍的Redis和ActiveMQ中都涉及到了观察者模式,所以我们在本文详细介绍下此模式:

观察者模式


 观察者模式又称为发布/订阅(Publish/Subscribe)模式,在对象之间定义了一对多的依赖,这样一来,当一个对象改变状态,依赖它的对象会收到通知并自动更新.


一、概述


1. 使用场景


广播机制场景

20190216231601318.png

聊天室程序的创建。服务器创建好后,A,B,C三个客户端连上来公开聊天。A向服务器发送数据,服务器端聊天数据改变。我们希望将这些聊天数据分别发给他在线的客户。也就是说,每个客户端需要更新服务器端得数据。

网站上,很多人订阅了”java主题”的新闻。当有这个主题新闻时,就会将这些新闻发给所有订阅的人。

大家一起玩CS游戏时,服务器需要将每个人的方位变化发给所有的客户

 上面这些场景,我们都可以使用观察者模式来处理。我们可以把多个订阅者、客户称之为观察者; 需要同步给多个订阅者的数据封装到对象中,称之为目标.


2. UML类图

20190216232041919.png

3. 核心角色


抽象被观察者角色:

 也就是一个抽象主题,它把所有对观察者对象的引用保存在一个集合中,每个主题都可以有任意数量的观察者。抽象主题提供一个接口,可以增加和删除观察者角色。一般用一个抽象类和接口来实现。

抽象观察者角色:

 为所有的具体观察者定义一个接口,在得到主题通知时更新自己。

具体被观察者角色:

 也就是一个具体的主题,在集体主题的内部状态改变时,所有登记过的观察者发出通知。

具体观察者角色:

 实现抽象观察者角色所需要的更新接口,一边使本身的状态与制图的状态相协调。


二、手动实现观察者模式


1.定义抽象被观察者角色

package com.dpb.observer;

import java.util.ArrayList;
import java.util.List;
/**
 * 观察者模式:目标对象模板
 * @author dengp
 *
 */
public interface Subject<T> {
    // 存储订阅者
    List<Observer> list = new ArrayList<>();
    // 注册订阅者
    public void registerObserver(T obs);
    // 移除订阅者
    public void removeObserver(T obs);
    //通知所有的观察者更新状态
    public void notifyAllObservers();
}

2.定义抽象观察者角色

/**
 * 观察者模式:定义观察者 
 * @author dengp
 *
 */
public interface Observer {
    void  update(Subject subject);
}

3.定义具体被观察者角色

/**
 * 观察者模式:目标对象(主体对象 topic)
 * @author dengp
 *
 */
public class ConcreteSubject implements Subject<Observer> {
    
    
    private int state;

    public int getState() {
        return state;
    }

    public void setState(int state) {
        this.state = state;
        //主题对象(目标对象)值发生了变化,请通知所有的观察者
        this.notifyAllObservers();
    }

    @Override
    public void notifyAllObservers() {
        for (Observer obs : list) {
            // 更新每一个观察者中的信息
            obs.update(this);
        }
    }

    @Override
    public void registerObserver(Observer obs) {
        // TODO Auto-generated method stub
        list.add(obs);
    }


    @Override
    public void removeObserver(Observer obs) {
        // TODO Auto-generated method stub
        list.remove(obs);
    }
}

4.定义具体观察者角色

package com.dpb.observer;

/**
 * 观察者模式:观察者 实现
 * @author dengp
 *
 */
public class ObserverA implements Observer {
    
    //myState需要跟目标对象的state值保持一致!
    private int myState;   
    
    /**
     * 更新为和目标对象的值一致
     */
    @Override
    public void update(Subject subject) {
        myState = ((ConcreteSubject)subject).getState();
    }

    public int getMyState() {
        return myState;
    }
    public void setMyState(int myState) {
        this.myState = myState;
    }
}

5.测试

package com.dpb.observer;

public class Client {
    public static void main(String[] args) {
        //目标对象
        ConcreteSubject subject = new ConcreteSubject();
        
        //创建多个观察者
        ObserverA  obs1 = new ObserverA();
        ObserverA  obs2 = new ObserverA();
        ObserverA  obs3 = new ObserverA();
        
        //将这三个观察者添加到subject对象的观察者队伍中
        subject.registerObserver(obs1);
        subject.registerObserver(obs2);
        subject.registerObserver(obs3);
        
        
        //改变subject的状态
        subject.setState(3000);
        System.out.println("########################");
        //我们看看,观察者的状态是不是也发生了变化
        System.out.println(obs1.getMyState());
        System.out.println(obs2.getMyState());
        System.out.println(obs3.getMyState());
        
        //改变subject的状态
        subject.setState(30);
        System.out.println("########################");
        //我们看看,观察者的状态是不是也发生了变化
        System.out.println(obs1.getMyState());
        System.out.println(obs2.getMyState());
        System.out.println(obs3.getMyState());
        
        //改变subject的状态
        subject.setState(99);
        System.out.println("########################");
        //我们看看,观察者的状态是不是也发生了变化
        System.out.println(obs1.getMyState());
        System.out.println(obs2.getMyState());
        System.out.println(obs3.getMyState());
    }
}

20190216233325181.png

三、Java内置观察者模式实现


 在java.util包中包含有基本的Observer接口和Observable抽象类.功能上和Subject接口和Observer接口类似.不过在使用上,就方便多了,因为许多功能比如说注册,删除,通知观察者的那些功能已经内置好了.


1.定义具体被观察者

package com.dpb.observer2;

import java.util.Observable;

/**
 * 目标对象
 * 继承 Observable
 * @author dengp
 *
 */
public class ConcreteSubject extends Observable {
    
    private int state; 
    
    public void set(int s){
        state = s;  //目标对象的状态发生了改变
        setChanged();  //表示目标对象已经做了更改
        notifyObservers(state);  //通知所有的观察者
    }

    public int getState() {
        return state;
    }

    public void setState(int state) {
        this.state = state;
    }
}

观察者只需要继承Observable父类。发送消息的方式执行如下两行代码即可

setChanged();  //表示目标对象已经做了更改
notifyObservers(state);  //通知所有的观察者

Observable源码对应的是:

20190216234306676.png20190216234428190.png

2.定义具体观察者

package com.dpb.observer2;

import java.util.Observable;
import java.util.Observer;
/**
 * 观察者模式:观察者(消息订阅者)
 * 实现Observer接口
 * @author dengp
 *
 */
public class ObserverA implements Observer {

    private int myState;
    
    @Override
    public void update(Observable o, Object arg) {
        myState = ((ConcreteSubject)o).getState();
    }
    public int getMyState() {
        return myState;
    }
    public void setMyState(int myState) {
        this.myState = myState;
    }
}

观察者也就是订阅者只需要实现Observer接口并重写相关update方法即可,在目标实现中我们发现触发的时候执行的就是观察者的update方法。

3.测试

package com.dpb.observer2;

public class Client {
    public static void main(String[] args) {
        //创建目标对象Obserable
        ConcreteSubject subject = new ConcreteSubject();
        
        //创建观察者
        ObserverA obs1 = new ObserverA();
        ObserverA obs2 = new ObserverA();
        ObserverA obs3 = new ObserverA();
        
        //将上面三个观察者对象添加到目标对象subject的观察者容器中
        subject.addObserver(obs1);
        subject.addObserver(obs2);
        subject.addObserver(obs3);
        
        //改变subject对象的状态
        subject.set(3000);
        System.out.println("===============状态修改了!");
        //观察者的状态发生了变化
        System.out.println(obs1.getMyState());
        System.out.println(obs2.getMyState());
        System.out.println(obs3.getMyState());

        subject.set(600);
        System.out.println("===============状态修改了!");
        //观察者的状态发生了变化
        System.out.println(obs1.getMyState());
        System.out.println(obs2.getMyState());
        System.out.println(obs3.getMyState());
        
        //移除一个订阅者
        subject.deleteObserver(obs2);
        subject.set(100);
        System.out.println("===============状态修改了!");
        //观察者的状态发生了变化
        System.out.println(obs1.getMyState());
        System.out.println(obs2.getMyState());
        System.out.println(obs3.getMyState());  
    }
}

20190216235018273.png

这样就实现了官方提供观察者模式,其实这里的Observable和Observer和我们前面自定义的Subject和Observer差不多,只是考虑的比我全面罢了。


四、开发中的常用场景:


聊天室程序的,服务器转发给所有客户端

网络游戏(多人联机对战)场景中,服务器将客户端的状态进行分发

邮件订阅

Servlet中,监听器的实现

Android中,广播机制

JDK的AWT中事件处理模型,基于观察者模式的委派事件模型(DelegationEventModel)

• 事件源----------------目标对象

• 事件监听器------------观察者

京东商城中,群发某商品打折信息



版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
阿里云服务器怎么设置密码?怎么停机?怎么重启服务器?
如果在创建实例时没有设置密码,或者密码丢失,您可以在控制台上重新设置实例的登录密码。本文仅描述如何在 ECS 管理控制台上修改实例登录密码。
10062 0
初探Java设计模式3:行为型模式(策略,观察者等)
转自https://javadoop.com/post/design-pattern 行为型模式 策略模式 观察者模式 责任链模式 模板方法模式 状态模式 行为型模式总结 本系列文章将整理到我在GitHub上的《Java面试指南》仓库,更多精彩内容请到我的仓库里查看 https://github.
2381 0
浅谈java中内置的观察者模式与动态代理的实现
一.关于观察者模式 1.将观察者与被观察者分离开来,当被观察者发生变化时,将通知所有观察者,观察者会根据这些变化做出对应的处理。 2.jdk里已经提供对应的Observer接口(观察者接口)与Observable(被观察者类)用于实现观察者模式 3.关于Observer接口,该接口只有一个update方法,当被观察者发生相关变化时,会通知所有的观察者,观察者接受到通知时,调用update方法进行处理。
781 0
使用OpenApi弹性释放和设置云服务器ECS释放
云服务器ECS的一个重要特性就是按需创建资源。您可以在业务高峰期按需弹性的自定义规则进行资源创建,在完成业务计算的时候释放资源。本篇将提供几个Tips帮助您更加容易和自动化的完成云服务器的释放和弹性设置。
12070 0
阿里云服务器如何登录?阿里云服务器的三种登录方法
购买阿里云ECS云服务器后如何登录?场景不同,阿里云优惠总结大概有三种登录方式: 登录到ECS云服务器控制台 在ECS云服务器控制台用户可以更改密码、更换系.
13875 0
java设计模式(六)--观察者模式
转载:设计模式(中文-文字版) 目录: 简单目标任务实现 观察者模式介绍 观察者模式代码实现 观察者模式是JDK中使用最多的模式之一,非常有用。我们也会一并介绍一对多关系,以及松耦合(对,没错,我们说耦合)。
766 0
JAVA内置的观察者模式样本
DisplayElement.java public interface DisplayElement { public void display(); } CurrentConditionsDisplay.
544 0
阿里云ECS云服务器初始化设置教程方法
阿里云ECS云服务器初始化是指将云服务器系统恢复到最初状态的过程,阿里云的服务器初始化是通过更换系统盘来实现的,是免费的,阿里云百科网分享服务器初始化教程: 服务器初始化教程方法 本文的服务器初始化是指将ECS云服务器系统恢复到最初状态,服务器中的数据也会被清空,所以初始化之前一定要先备份好。
11888 0
Java描述设计模式(11):观察者模式
本文源码:GitHub·点这里 || GitEE·点这里 一、观察者模式 1、概念描述 观察者模式是对象的行为模式,又叫发布-订阅(Publish/Subscribe)模式。观察者模式定义了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象,主题对象在状态发生变化时,会通知所有观察者对象。
725 0
+关注
游客a74jvhcp7vclg
10余年开发架构经验,同时乐于技术分享!
332
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
《2021云上架构与运维峰会演讲合集》
立即下载
《零基础CSS入门教程》
立即下载
《零基础HTML入门教程》
立即下载