观察者模式

一、什么是观察者模式

　　观察者模式是行为模式之一，它的作用是当一个对象的状态发生变化时，能够自动通知其他关联对象，自动刷新对象状态。

　　观察者模式提供给关联对象一种同步通信的手段，使某个对象与依赖它的其他对象之间保持状态同步。

二、观察者模式的结构

三、观察者模式的角色和职责

Subject（被观察者）

　　被观察者对象。当需要被观察者的状态发生变化时，需要通知队列中所有观察者对象。Subject需要维持（添加，删除，通知）一个观察者对象的队列列表。

ConcreteSubject

　　被观察者的具体实现。包含一些基本的属性状态及其他操作。

Observer（观察者）

　　接口或抽象类。当Subject的状态发生变化时，Observer对象将通过一个callback函数的到通知。

ConcreteObserver

　　观察者的具体实现。得到通知后将完成一些具体的业务逻辑处理。

四、观察者模式的典型应用

　　侦听事件驱动程序设计中的外部事件

　　侦听/监视某个对象的状态变化

　　发布者/订阅者模型中，当一个外部时间（新的产品，消息的出现等等）被触发时，通知邮件列表中的订阅者。

 

文章实体

package com.bingoogol.designpattern.observer;

/**
 * 文章实体
 * 
 * @author bingoogol@sina.com
 */
public class Article {
    private String title;
    private String content;

    public Article() {
    }

    public Article(String title, String content) {
        this.title = title;
        this.content = content;
    }

    public String getTitle() {
        return title;
    }

    public void setTitle(String title) {
        this.title = title;
    }

    public String getContent() {
        return content;
    }

    public void setContent(String content) {
        this.content = content;
    }

}

博客用户，被观察者

package com.bingoogol.designpattern.observer;

import java.util.Observable;

/**
 * 博客用户，被观察者
 * 
 * @author bingoogol@sina.com
 */
public class BlogUser extends Observable{
    
    private String name;
    
    
    public BlogUser() {
    }
    public BlogUser(String name) {
        this.name = name;
    }

    public void publish() {
        Article article = new Article("观察者模式", "模式是行为模式之一，它的作用是当一个对象的状态发生变化时，能够自动通知其他关联对象，自动刷新对象状态");
        System.out.println("博主：" + name + " 发布文章");
        System.out.println("文章标题：" + article.getTitle());
        System.out.println("文章内容：" + article.getContent());
        System.out.println("---------------------------------------------------------------");
        this.setChanged();
        this.notifyObservers(article);
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }
}

订阅者，观察者

package com.bingoogol.designpattern.observer;

import java.util.Observable;
import java.util.Observer;

/**
 * 订阅者，观察者
 * 
 * @author bingoogol@sina.com
 */
public class MyObServer implements Observer {
    private String name;
    
    public MyObServer() {
    }

    public MyObServer(String name) {
        this.name = name;
    }

    @Override
    public void update(Observable o, Object arg) {
        Article article = (Article) arg;
        BlogUser blogUser = (BlogUser) o;
        System.out.println("订阅者：" + name + " 收到" + blogUser.getName() + "的文章");
        System.out.println("文章标题：" + article.getTitle());
        System.out.println("文章内容：" + article.getContent());
        System.out.println("---------------------------------------------------------------");
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }
    
}

启动类

package com.bingoogol.designpattern.observer;

/**
 * 启动类
 * 
 * @author bingoogol@sina.com
 */
public class Main {
    public static void main(String[] args) {
        MyObServer obServer1 = new MyObServer("订阅者1");
        MyObServer obServer2 = new MyObServer("订阅者2");
        BlogUser blogUser = new BlogUser("博主1");
        blogUser.addObserver(obServer1);
        blogUser.addObserver(obServer2);
        blogUser.publish();
    }
}