观察者模式 基本含义 顾名思义就是一个观察者角色 观察 被观察角色的变化 这是一种一对多的对象关系 举个例子
对新生儿的情况进行观察
首先你要有一个新生儿(被观察对象), 护工/护理(观察者) ,记录新生儿的何种生命活动情况并在发生变化时记录数据(抽象实现类) ,反馈给医生和新生儿父母 (使用实现类) ;这个流程就是观察者模式 可以一对一 也可以一对多的关系
具体使用
观察者模式有很多实现方式 看个人喜好 目前主流的还是 注册 —- 通知 —- 销毁注册 的方式
首先我们需要三个角色 第一 观察者(新生儿) 第二 被观察者(护工/护理) 第三 抽象实现类(生命活动变化) 第四 使用实现类(通知医生/新生儿父母)
下面举个例子
首先被观察对象 (新生儿)
package com.observer;
public class MyMessage {
private String name; private int age; private double weight; private double height; public static Builder builder; public MyMessage(Builder builder) { this.name = builder.name; this.age = builder.age; this.weight = builder.weight; this.height = builder.height; } public String getName() { return name; } public void setName(String name) { this.name = name; } public int getAge() { return age; } public void setAge(int age) { this.age = age; } public double getWeight() { return weight; } public void setWeight(double weight) { this.weight = weight; } public double getHeight() { return height; } public void setHeight(double height) { this.height = height; } public static class Builder{ private String name; private int age; private double weight; private double height; public Builder setName(String name){ this.name = name; return this; } public Builder setAge(int age){ this.age = age; return this; } public Builder setWeight(double weight){ this.weight = weight; return this; } public Builder setHeight(double height){ this.height = height; return this; } public MyMessage build(){ return new MyMessage(this); } }
}
定义一个观察者(护工/护理) 任务就是更新数据
/* 抽象接口 * @param 数据泛型 */ public interface ObServer {
void upData(ObServerable obServerable,T data); }
定义一个抽象实现类 任务就是更新数据并刷新
> import java.util.ArrayList;
> import java.util.List;
>
> public class ObServerable<T> {
> List<ObServer<T>> obServers = new ArrayList<ObServer<T>>();
> public void register(ObServer<T> obServer){
> if (obServer == null){
> throw new NullPointerException("ObServer == null");
> }
> synchronized (this){
> if (!obServers.contains(obServer)){
> obServers.add(obServer);
> }
> }
>
> }
> public synchronized void unRegister(ObServer<T> obServer){
> obServers.remove(obServer);
> }
>
> public void notifyObserver(T data){
> for (ObServer<T> obServer:obServers){
> obServer.upData(this,data);
> }
> }
> }
再定义一个使用实现类 (医生/新生儿父母)
模拟数据变化
// test
public static void observerMode(int type){
MyMessage.Builder builder = new MyMessage.Builder();
MyMessage message = null;
switch (type){
case 0:
message = builder.setAge(1).setName("小7").setHeight(40).setWeight(5).build();
break;
case 1:
message = builder.setAge(1).setName("小7").setHeight(41).setWeight(5.5).build();
break;
}
ObServerable<MyMessage> obServerable = new ObServerable<MyMessage>();
ObServer<MyMessage> obServer = new ObServer<MyMessage>() {
@Override
public void upData(ObServerable<MyMessage> obServerable, MyMessage data) {
System.out.print(data.getName()+" 在"+data.getAge()+"岁的时候,身高"+data.getHeight()+"cm,体重"+data.getWeight()+"kg"+"\n");
}
};
obServerable.register(obServer);
obServerable.notifyObserver(message);
obServerable.unRegister(obServer);
}
下面是输出日志