设计模式---观察者模式

标签(空格分隔): 设计模式


引言

提起设计模式,观察者模式很多人都不陌生,因为它实在是太常见了,无论是在软件设计中还是在生活中都可以寻找到他的踪迹。其实软件设计就是对现实生活的抽象。

下面我们就来提及一个生活中的现象问题:

广播员在进行广播,远在山区的大大小小的山村的村民正在使用收音机,收听广播。

这是一个现实世界的问题,我们需要用抽象成软件设计模型,

首先,广播员是一个对象,村民使用的收音机呢,也是一个对象,这两个对象之间有什么联系呢?

广播员只要一说话,收音机就能够得到声音响应。这个过程是一个及时的响应的。

那么如何实现这个问题的抽象呢?----->观察者模式

观察者模式图.png

模型抽象

这里我们做一个规范定义:我们将被观察的对象定义成事件发生者,将观察的对象,我们定义成观察者

广播模型:

事件发生者接口

public interface Observable {
    
    //注册广播接收器
    void register(Observer observer);
    //移除广播接收器
    void removeRegister(Observer observer);
    //通知更新
    void notifyUpdate();
}

观察者接口

public interface Observer<T extends Observable> {
    
    void update(T t);
}

上面两个接口是最上层抽象接口,首先事件发生者里要有注册观察者的方法,同时又要移除观察者的方法,然后是同时所有的观察者跟新消息的方法。

在我们的观察者中呢?很简单,我们就是接收事件发生者里的消息。

可观察者实现类:

public class ObservableImpl implements Observable{
    
    private List<Observer> list = new ArrayList<>();
    
    @Override
    public void register(Observer observer) {
        list.add(observer);
    }

    @Override
    public void removeRegister(Observer observer) {
        list.remove(observer);
    }

    @Override
    public void notifyUpdate() {
        for (Observer observer : list) {
            observer.update(this);
        }
    }
}

上面的事件发生者实现类,我们可以看到,里面持有了一个观察者对象的集合,当我们注册一个观察者的时候,集合就add一个,移除一个观察者的时候集合就remove一个。这个很容易理解,我们的更新的方法是如何实现的呢?我们的结果是通知所有的观察者,这个很自然的想到是遍历集合中的所有观察者对象,然后分别通知就行了。

广播实现类:

/**
 * 广播器
 * @author Sivin
 *
 */
public class Broadcast extends ObservableImpl{

    private String mMsg;
    
    /**
     * 发送消息
     * @param msg
     */
    public void sendMsg(String msg){
        this.mMsg = msg;
        notifyUpdate();
    }
    
    /**
     * 获取消息
     * @return
     */
    public String getMsg(){
        return mMsg;
    }
    
}

简单分析一下,我们的广播实现类:没有什么东西,里面有一个消息变量,然后有一个发送消息的方法,和获取广播消息的方法,很好理解,广播调用发送消息的接口,然后通知所有注册的收音机,确接收消息就行了

/**
 * 收音机的类
 * @author Sivin
 *
 */
public class Radio implements Observer<Broadcast>{

    private String mMsg;
    
    public String getMsg(){
        return mMsg;
    }
    
    @Override
    public void update(Broadcast t) {
        mMsg = t.getMsg();
    }

}

上面的类很容易理解,不用解释了。

好了,我们来测试一下:


public class Test {

    public static void main(String[] args) {
        //创建广播员:
        Broadcast broadcast = new Broadcast();
        
        //创建观察者-->收音机
        Radio radio1 = new Radio();
        Radio radio2 = new Radio();
        Radio radio3 = new Radio();
        
        //注册建立联系
        broadcast.register(radio1);
        broadcast.register(radio2);
        broadcast.register(radio3);
        
        //广播开始广播
        broadcast.sendMsg("广播声音--->:123456");
        
        //接收声音
        System.out.println("收音机radio1接收到:"+radio1.getMsg());
        System.out.println("收音机radio2接收到:"+radio2.getMsg());
        System.out.println("收音机radio3接收到:"+radio3.getMsg());
        
    }
}

下面是运行结果:

收音机radio1接收到:广播声音--->:123456
收音机radio2接收到:广播声音--->:123456
收音机radio3接收到:广播声音--->:123456
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

友情链接更多精彩内容