行为模式-观察者模式

gfu

发布于 2019-08-28 14:49:45

5410

发布于 2019-08-28 14:49:45

文章被收录于专栏：gfugfu

当对象间存在一对多关系时，则使用观察者模式（Observer Pattern）。比如，当一个对象被修改时，则会自动通知它的依赖对象。观察者模式属于行为型模式。

使用场景

一个抽象模型有两个方面，其中一个方面依赖于另一个方面。将这些方面封装在独立的对象中使它们可以各自独立地改变和复用。
一个对象的改变将导致其他一个或多个对象也发生改变，而不知道具体有多少对象将发生改变，可以降低对象之间的耦合度。
一个对象必须通知其他对象，而并不知道这些对象是谁。
需要在系统中创建一个触发链，A对象的行为将影响B对象，B对象的行为将影响C对象……，可以使用观察者模式创建一种链式触发机制。

注意事项：

JAVA 中已经有了对观察者模式的支持类。
避免循环引用。
如果顺序执行，某一观察者错误会导致系统卡壳，一般采用异步方式。

UML

简单的代码实现

/**
 * 日志系统
 *
 * @author 719383495@qq.com |719383495qq@gmail.com |gfu
 * @date 2019/8/27
 */
public class Main {

    public static void main(String[] args) {
        SubjectImpl subject = new SubjectImpl();
        new ObserverImpl(subject);
        new ObserverImpl(subject);
        new ObserverImpl(subject);
        subject.setUsername("张三");
        new ObserverImpl(subject);
        subject.setUsername("李四");
        subject.notifyObserver();
        new ObserverImpl(subject);
        new ObserverImpl(subject);
        subject.setUsername("王五");
        new ObserverImpl(subject);
        subject.notifyObserver();
    }
}

public interface Observer {

    void update(String username, int id);

}

public class ObserverImpl implements Observer {

    private String username;
    private Subject subject;
    private int id;

    @Override
    public void update(String username,int id) {
        this.username = username;
        this.id = id;
        display();
    }

    public ObserverImpl(Subject subject) {
        this.subject = subject;
        this.subject.registerObserver(this);
    }

    public void display() {
        System.out.println("update" +this.id+" : "+ this.username);
    }

}

public interface Subject {

    void registerObserver(Observer observer);

    void removeObserver(Observer observer);

    void notifyObserver();

}

import java.util.ArrayList;


public class SubjectImpl implements Subject {

    private ArrayList<Observer> observers;
    private String username;
    private int id;

    public SubjectImpl() {
        observers = new ArrayList<>();
    }

    @Override
    public void registerObserver(Observer observer) {
        observers.add(observer);
    }

    @Override
    public void removeObserver(Observer observer) {
        observers.remove(observer);
    }

    @Override
    public void notifyObserver() {
        int len = observers.size();
        for (int i = 0; i <len; i++) {
            observers.get(i).update(username, i);
        }
    }

    public void setUsername(String username) {
        this.username = username;
    }
}

本文参与腾讯云自媒体分享计划，分享自作者个人站点/博客。

原始发表：2019.08.27 ，如有侵权请联系 cloudcommunity@tencent.com 删除

java