Android开发中一个很常见的场景是有一个列表，列表上每条Item有个点赞的按钮，当你给这条Item点赞的时候，这个按钮就会变成已点赞状态，相信大家可以脑补到这个场景。这里就用到了观察者模式。
那么什么是观察者模式，我们稍微瞧一下这个模式的定义，不用太在意，看不懂也没关系，我觉得设计模式是需要用代码感受的，加这些定义只是为了让懂的人感受更深，更系统。
观察者模式：
观察者模式
两个抽象类或者接口，
一个是被观察者的抽象类或者接口，需要持有所有观察者的引用，
被观察者要能做三件事儿：
1.可以注册观察者。
2.有注册就有注销。
3.可以通知观察者的方法。
一个是观察者的抽象类或者接口，用来更新自己。
观察者要能做一件事儿，那就是更新自己。
具体举个例子：
虽然我们主要是写android的，但是服务器的东西还是要懂点，就拿简书这个类似于博客的网站来说吧，如果你订阅了或者说关注了一个领域，就能收到这个领域文章的推送，如果没有关注，则不能。是相当于有一个总控制台(被观察者，持有数据源，这里的数据源是我们每个订阅了的人)通知下面的观察者。
在java中可以这么写。(因为java的观察者模式是内置的，所以你只需要实现Observer接口和继承Observable)
观察者的代码：
/**
* 程序员，也就是你，订阅这个专题的人是。观察者
*/
public class Coder implements Observer {
private String yourName;
public Coder(String yourName){
this.yourName=yourName;
}
@Override
public void update(Observable o, Object arg) {
System.out.println("你订阅的"+arg.toString()+"更新了。");
}
@Override
public String toString() {
return "your name "+yourName;
}
}
以下是被观察者和服务器的代码。
/**
* 你订阅的简书android领域
*/
public class JianShuAndroid extends Observable{
public void postNewContentToCoder(String content){
setChanged();
notifyObservers(content);
}
}
/**
* 服务器的代码
*/
public class Server{
public static void main(String[] args){
JianShuAndroid jianShuAndroid=new JianShuAndroid();
Coder coder1=new Coder("name1");
Coder coder2=new Coder("name2");
Coder coder3=new Coder("name3");
jianShuAndroid.addObserver(coder1);
jianShuAndroid.addObserver(coder2);
jianShuAndroid.addObserver(coder3);
jianShuAndroid.postNewContentToCoder("contentChanged");
}
}
(这里顺便提一下，为什么观察者是实现一个observer接口，而被观察者是继承一个抽象类呢？我觉得，被观察者写成抽象类的原因是复用，观察者写成接口的原因是降低代码的耦合度，面向接口编程，在原则里就是依赖倒置原则，我们倒着思考，如果这里不是接口，而是一个具体的类，那么，耦合度就相当高了，如果不是Coder注册就无法添加到observable里，就要修改observable的代码。)
接下来验证我们看看android的套路是怎么玩的。
文章开头提到的RecyclerView，整个列表是一个被观察者也就是这个RecyclerView的Adapter，为什么要叫被观察者呢？因为Adapter持有了所有数据源，而每条Item要做的是观察这些数据源有没有变化，所以就叫被观察者，每个Item就叫观察者。当数据变化的时候，adapter就通知这条Item，数据源发生了变化了(这个通知的过程是notifyDataSetChanged来进行的),我们可以猜想，RecyclerView的内部的模式是观察者模式。
玩观察者模式，假如你用的是java，那么observable，observer是内置的，你的被观察者继承observable，观察者实现observer接口，就行了。其他的语言，如果你搞清了原理，自己写一个也很简单。
上面我们说到了RecyclerView，开始分析(看源码，一万多行的RecyclerView不要急，找我们想要的。我感觉看源码就是像给了你一团毛线让你理顺，当然你要去找那个线头，千万不要陷入泥潭，每一行都看。)
大家找一下这个突破口，也就是线头，我们明显现在已经知道了recyclerview里肯定用到了观察者模式，还有一个重要线索是，我们知道它使怎么通知观察者改变的，就是notifyDataSetChanged。那就从这个开始看起。
找了半天，知道了notifyDataSetChanged是在Adapter里面，而这个adapter开始的第一句就是
public static abstract class Adapter<VH extends ViewHolder> {
private final AdapterDataObservable mObservable = new AdapterDataObservable();
private boolean mHasStableIds = false;
....
....
....
}
很熟悉的字眼，observable(被观察者)来了。看一下这个AdapterDataObservable，不要怕，名字是长了点，但是一般名字长的都是纸老虎。
static class AdapterDataObservable extends Observable<AdapterDataObserver> {
public boolean hasObservers() {
return !mObservers.isEmpty();
}
public void notifyChanged() {
// since onChanged() is implemented by the app, it could do anything, including
// removing itself from {@link mObservers} - and that could cause problems if
// an iterator is used on the ArrayList {@link mObservers}.
// to avoid such problems, just march thru the list in the reverse order.
for (int i = mObservers.size() - 1; i >= 0; i--) {
mObservers.get(i).onChanged();
}
}
public void notifyItemRangeChanged(int positionStart, int itemCount) {
notifyItemRangeChanged(positionStart, itemCount, null);
}
...
...
...
一看，没错这家伙肯定是被观察者，因为它继承了Observable。我们那个简书网站就是这样啊，JianShuAndroid继承了observable。
还记得我们前面说被观察者一般要可以做三件事儿。注册，注销和通知。那么这里也不会例外。我们看到的是通知这件事儿，但是注册和注销是java内部的Observable帮我们实现了。
public abstract class Observable<T> {
/**
* The list of observers. An observer can be in the list at most
* once and will never be null.
*/
protected final ArrayList<T> mObservers = new ArrayList<T>();
/**
* Adds an observer to the list. The observer cannot be null and it must not already
* be registered.
* @param observer the observer to register
* @throws IllegalArgumentException the observer is null
* @throws IllegalStateException the observer is already registered
*/
public void registerObserver(T observer) {
if (observer == null) {
throw new IllegalArgumentException("The observer is null.");
}
synchronized(mObservers) {
if (mObservers.contains(observer)) {
throw new IllegalStateException("Observer " + observer + " is already registered.");
}
mObservers.add(observer);
}
}
/**
* Removes a previously registered observer. The observer must not be null and it
* must already have been registered.
* @param observer the observer to unregister
* @throws IllegalArgumentException the observer is null
* @throws IllegalStateException the observer is not yet registered
*/
public void unregisterObserver(T observer) {
if (observer == null) {
throw new IllegalArgumentException("The observer is null.");
}
synchronized(mObservers) {
int index = mObservers.indexOf(observer);
if (index == -1) {
throw new IllegalStateException("Observer " + observer + " was not registered.");
}
mObservers.remove(index);
}
}
....
....
....
这时候observable出现了，那observer呢？
其实上面就已经出现了。回上一段代码里找，AdapterDataObserver的泛型里是AdapterDataObserver，然后我们全局搜一下就可以发现
private class RecyclerViewDataObserver extends AdapterDataObserver {
RecyclerViewDataObserver() {
}
@Override
public void onChanged() {
assertNotInLayoutOrScroll(null);
if (mAdapter.hasStableIds()) {
// TODO Determine what actually changed.
// This is more important to implement now since this callback will disable all
// animations because we cannot rely on positions.
mState.mStructureChanged = true;
setDataSetChangedAfterLayout();
} else {
mState.mStructureChanged = true;
setDataSetChangedAfterLayout();
}
if (!mAdapterHelper.hasPendingUpdates()) {
requestLayout();
}
}
...
...
...
这就是observer了，这个是干嘛的，根据我们上面说的，有一件事儿，那就是更新数据的，onChanged里面涉及到requestLayout()的，在requestLayout里会重新调用onDraw来重绘。
最后整理一遍这个过程，
在Adapter里面有一个AdapterDataObservable，是被观察者，被观察者必须有三个方法，注册，销毁，通知，这里的注册就是registerAdapterDataObserver，通知就是notify相关的。
在setAdapter的时候，将观察者，也就是RecyclerViewDataObserver注册到AdapterDataObservable里面来维护，观察者里面自然是更新布局。
我们调用notifyDataSetChanged其实就是调用被观察者的notify相关方法
关于观察者模式，有兴趣的话可以看看EventBus和AndroidEventBus的源码，这两个开源库的实现也是运用了观察者模式。
网友评论