java 设计模式:观察者

1、概念

在对象之间定义了一对多的依赖,使得么当一个对象状态发生改变,其相关依赖对象会收到通知并自动更新。

2、场景

  1. 一个抽象模型有两个方面,其中一个方面依赖于另一个方面
  2. 一个对象的改变将导致一个或多个其他对象也发生改变
  3. 需要在系统中创建一个触发链

3、UML结构图分析

  • 抽象被观察者角色:也就是一个抽象主题,它把所有对观察者对象的引用保存在一个集合中,每个主题都可以有任意数量的观察者。抽象主题提供一个接口,可以增加和删除观察者角色。一般用一个抽象类和接口来实现。
  • 抽象观察者角色:为所有的具体观察者定义一个接口,在得到主题通知时更新自己。
  • 具体被观察者角色:也就是一个具体的主题,在集体主题的内部状态改变时,所有登记过的观察者发出通知。
  • 具体观察者角色:实现抽象观察者角色所需要的更新接口,一边使本身的状态与制图的状态相协调。

4、实际代码分析

实现观察者代码:


/**
*
* 创建观察者抽象类
*/
public interface Observer {

//更新方法
void update(String newStatus);

}

/**
* 创建观察者实现类
*/
public class ConcreteObserver implements Observer {

/**
* 观察者状态
*/
private String observerState;

@Override
public void update(String newStatus) {
observerState = newStatus;
System.out.println(newStatus);
}
}

/**
* 创建抽象目标者
* Created by shidawei on 2019/5/23.
*/
public abstract class Subject {

private List<Observer> mObservers = new ArrayList<>();

/**
* 注册观察
* @param observer
*/
public void attach(Observer observer){
mObservers.add(observer);
System.out.println("注册观察");
}

/**
* 移除观察者
* @param observer
*/
public void detach(Observer observer){
mObservers.remove(observer);
}

/**
* 通知观察者
* @param newStatus
*/
public void notifyObsercers(String newStatus){
for(Observer observer:mObservers){
observer.update(newStatus);
}
}
}

/**
* 实现被观察者
*/
public class ConcreteSubject extends Subject {
private String state;

public String getState() {
return state;
}
public void change(String newState){
state = newState;
System.out.println(newState);
notifyObsercers(newState);
}
}

//测试代码
ConcreteSubject concreteSubject = new ConcreteSubject();
concreteSubject.attach(new ConcreteObsercer());
concreteSubject.attach(new ConcreteObsercer());
concreteSubject.attach(new ConcreteObsercer());
concreteSubject.change("123");

java内部的接口实现:

/**
* Observable 是被观察者对象接口,是对被观察者的实现
*/
public class TargetObervable extends Observable {

private String message;

public String getMessage() {
return message;
}

public void setMessage(String message) {
this.message = message;
//被观察者数据发生改变的时候通过如下两行代码通知所有观察者
this.setChanged();
this.notifyObservers();
}
}
/**
* Observer 对象是观察者,实现Observer的对象就是实现观察者对象
*/
public class TargetOberver implements Observer {


private String name;

public String getName() {
return name;
}

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

@Override
public void update(Observable o, Object arg) {
System.out.println(name + "收到数据变更" + ((TargetObervable) o).getMessage());
}
}

//测试代码

TargetObervable targetObervable = new TargetObervable();
targetObervable.addObserver(new TargetOberver());
targetObervable.addObserver(new TargetOberver());
targetObervable.addObserver(new TargetOberver());
targetObervable.setMessage("1234");

两种观察者对比:

通过读源码Observable.class我们得知对Observer的集合为Vector

Vector为线程安全的,会保证线程安全,但是性能差。可以采用CopyOnWriteArrayList来代替Vector。

观察者设计模式在Android中的实际运用

回调模式:一对一的模式

实现了抽象类/接口的实例实现了负累的提供的抽象方法,然后将该方法还给父类来处理。

Fragment与activity通信的代码实例:

/**
*回调接口,与activity通信
**/

public interface ISwitchCaoZuoRecordFragment {
void toSwitch(CaiZuoRecordFragFragment fragment, CaiZuoRecordFragPresenter presenterDecorator);
}
/**
* activity实现该接口
**/
public class CaoZuoRecordActivity extends BaseActivity<CaoZuoRecordView, CaoZuoRecordPresenter> implements CaoZuoRecordView ,CaiZuoRecordFragFragment.ISwitchCaoZuoRecordFragment{
@Override
public void toSwitch(CaiZuoRecordFragFragment fragment, CaiZuoRecordFragPresenter presenterDecorator) {
mPresenterDecorator = presenterDecorator;
if(presenterDecorator.studentName!=null&&!presenterDecorator.studentName.equals("")){
searchListTitleBar.getSearch().setText(presenterDecorator.studentName);
searchListTitleBar.getClear().setVisibility(View.VISIBLE);
searchListTitleBar.getSearch_layout().setVisibility(View.VISIBLE);
}else{
searchListTitleBar.getSearch().setText("");
searchListTitleBar.getClear().setVisibility(View.GONE);
searchListTitleBar.getSearch_layout().setVisibility(View.GONE);
}

}

/**
*fragment注册和取消
*/
@Override
public void onDetach() {
super.onDetach();
iSwitchCaoZuoRecordFragment = null;

}

@Override
public void onAttach(Context context) {
super.onAttach(context);
if (context instanceof ISwitchCaoZuoRecordFragment) {
iSwitchCaoZuoRecordFragment = (ISwitchCaoZuoRecordFragment) context;
}else{
throw new RuntimeException(context.toString()
+ " 必须实现 ISwitchCaoZuoRecordFragment");
}
}


0 个评论

要回复文章请先登录注册