观察者模式 基本含义 顾名思义就是一个观察者角色 观察 被观察角色的变化 这是一种一对多的对象关系
其目的是 是编码更简单 解耦合 同时提高阅读性
举个例子
对新生儿的情况进行观察
首先你要有一个新生儿(被观察对象), 护工/护理(观察者) ,记录新生儿的何种生命活动情况并在发生变化时记录数据(抽象实现类) ,反馈给医生和新生儿父母 (使用实现类) ;这个流程就是观察者模式 可以一对一 也可以一对多的关系
具体使用
观察者模式有很多实现方式 看个人喜好 目前主流的还是 注册 —- 通知 —- 销毁注册 的方式
首先我们需要三个角色 第一 观察者(新生儿) 第二 被观察者(护工/护理) 第三 抽象实现类(生命活动变化) 第四 使用实现类(通知医生/新生儿父母)
下面举个例子
首先被观察对象 (新生儿)
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 {
List> obServers = new ArrayList>();
public void register(ObServer obServer){
if (obServer == null){
throw new NullPointerException("ObServer == null");
}
synchronized (this){
if (!obServers.contains(obServer)){
obServers.add(obServer);
}
}
}
public synchronized void unRegister(ObServer obServer){
obServers.remove(obServer);
}
public void notifyObserver(T data){
for (ObServer 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 obServerable = new ObServerable(); ObServer obServer = new ObServer() {
@Override
public void upData(ObServerable 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); }