1. 定义？
当一个对象的状态发生改变时，与他相关联的部分对象的状态同时也会发生改变。
比如订阅公众号：
- 比如我订阅了鸿阳的微信公众号，只要他每更新一篇文章都会及时的通知我 [观察者设计模式]；
对应上边定义就是：一个对象的状态发生改变时，就是鸿阳公众号有文章更新，由于我订阅了该公众号，所以说我的部分状态也会发生改变，比如我会去看该公众号更新的文章；
EventBus：和观察者设计模式没有半毛钱关系
2. 角色划分？
被观察者（Observable）：公众号；
具体的被观察者（Concreate Observable）：鸿阳公众号；
观察者（Observer）：微信用户；
具体的观察者（Concreate Observer）：我，Novate
3. 示例代码 - 订阅公众号？
写一个事例代码
被观察者：WXPublicObservable（公众号）；
具体的被观察者：WXAdvanceObservable（鸿阳的公众号）；
观察者：IWXUser（微信用户）；
具体的观察者：WXUser（Novate、WangZiWen）；
4. 示例代码如下
1>：WXPublicObservable，被观察者 - 微信公众号
/**
* Email: 2185134304@qq.com
* Created by Novate 2018/5/27 15:03
* Version 1.0
* Params:
* Description: 微信公众号 - 多个人去订阅的公众号
*/
public class WXPublicObservable {
// 所有订阅用户的集合
private List<IWXUser> mWXUsers ;
public WXPublicObservable(){
mWXUsers = new ArrayList<>() ;
}
/**
* 订阅
*/
public void register(IWXUser wxUser){
mWXUsers.add(wxUser) ;
}
/**
* 取消订阅
*/
public void unregister(IWXUser wxUser){
mWXUsers.remove(wxUser) ;
}
/**
* 文章更新
*/
public void update(String article){
// 推送所有更新的文章
for (IWXUser wXUser : mWXUsers) {
wXUser.push(article);
}
}
}
2>：WXAdvanceObservable，具体的被观察者 - 鸿阳的微信公众号
/**
* Email: 2185134304@qq.com
* Created by Novate 2018/5/27 15:12
* Version 1.0
* Params:
* Description: 具体的被观察者 - 鸿阳的微信公众号
*/
public class WXAdvanceObservable extends WXPublicObservable{
private String article ;
public String getArticle() {
return article;
}
public void setArticle(String article) {
this.article = article;
// 通知更新，推送给微信用户
update(article);
}
}
3>：IWXUser，接口，微信用户；
/**
* Email: 2185134304@qq.com
* Created by Novate 2018/5/27 15:06
* Version 1.0
* Params:
* Description: 微信用户 - 订阅该微信公众号
*/
public interface IWXUser {
/**
* 读文章
*/
void push(String article) ;
}
4>：WXUser，具体的观察者，具体的用户，订阅鸿阳微信公众号的用户
/**
* Email: 2185134304@qq.com
* Created by Novate 2018/5/27 15:14
* Version 1.0
* Params:
* Description: 具体的用户 - 订阅鸿阳的微信公众号
*/
public class WXUser implements IWXUser{
private String name ;
public WXUser(String name){
this.name = name ;
}
@Override
public void push(String article) {
System.out.println(name+"收到了一篇文章："+article);
}
}
5>：创建具体的被观察者和具体的观察者对象，测试代码如下：
/**
* Email: 2185134304@qq.com
* Created by Novate 2018/5/27 15:16
* Version 1.0
* Params:
* Description:
*/
public class Client {
public static void main(String[] args){
// 具体的被观察者 - 微信公众号 - 鸿阳的公众号
WXAdvanceObservable wxAdvanceObservable = new WXAdvanceObservable() ;
// 具体的观察者 - 微信公众号 - Novate
WXUser novate = new WXUser("novate") ;
WXUser wangziwen = new WXUser("wangziwen") ;
// 微信公众号 - 用户订阅公众号
wxAdvanceObservable.register(novate);
wxAdvanceObservable.register(wangziwen);
// 微信公众号 - 推送文章
wxAdvanceObservable.setArticle("《观察者设计模式 - 定义及事例代码》");
// 微信公众号 - 用户取消订阅公众号
wxAdvanceObservable.unregister(wangziwen);
}
}
运行结果打印如下
image
5. 源码中观察者设计模式的使用场景
1>：RxJava源码；
2>：ListView的 Adapter的setDataChange的方法；
6. ListView部分源码分析
1>：ListView中的setAdapter()方法
@Override
public void setAdapter(ListAdapter adapter) {
// 防止多次调用setAdapter，而不去调用notifyDataSetChanged
if (mAdapter != null && mDataSetObserver != null) {
mAdapter.unregisterDataSetObserver(mDataSetObserver);
}
// 给adapter注册一个 mDataSetObserver
mAdapter.registerDataSetObserver(mDataSetObserver);
//
requestLayout();
}
2>：只要调用了 adapter.notifyDataSetChanged()方法，就会执行下边代码：
A：BaseAdapter中的notifyDataSetChanged()：
public void registerDataSetObserver(DataSetObserver observer) {
mDataSetObservable.registerObserver(observer);
}
public void unregisterDataSetObserver(DataSetObserver observer) {
mDataSetObservable.unregisterObserver(observer);
}
/**
* Notifies the attached observers that the underlying data has been changed
* and any View reflecting the data set should refresh itself.
*/
public void notifyDataSetChanged() {
mDataSetObservable.notifyChanged();
}
B：然后调用
public void notifyChanged() {
synchronized(mObservers) {
for (int i = mObservers.size() - 1; i >= 0; i--) {
// 只要一更新，就会调用onChanged()，
// 所以其实是用 onChanged()方法把 ListView与adapter进行关联
mObservers.get(i).onChanged();
}
}
}
3>：这个时候会来到AdapterView的onChanged()方法，来更新ListView；
class AdapterDataSetObserver extends DataSetObserver {
private Parcelable mInstanceState = null;
@Override
public void onChanged() {
mDataChanged = true;
mOldItemCount = mItemCount;
mItemCount = getAdapter().getCount();
// Detect the case where a cursor that was previously invalidated has
// been repopulated with new data.
if (AdapterView.this.getAdapter().hasStableIds() && mInstanceState != null
&& mOldItemCount == 0 && mItemCount > 0) {
AdapterView.this.onRestoreInstanceState(mInstanceState);
mInstanceState = null;
} else {
rememberSyncState();
}
checkFocus();
// 重新执行onMeasure()、onLayout()、onDraw()这几个方法
requestLayout();
}
@Override
public void onInvalidated() {
mDataChanged = true；
checkFocus();
requestLayout();
}
public void clearSavedState() {
mInstanceState = null;
}
}
7. ListView观察者设计模式图解
image
由以上分析ListView观察者设计模式图解可知：
1>：ListView与adapter二者其实关联不太大，ListView只是调用了setAdapter()方法，那么adapter如果数据改变如何通知ListView刷新界面，比如adapter少了一条数据，就需要ListView少显示一条数据；
2>：其实在ListView调用setAdapter()时候，会给它的adapter中注册一群观察者，也就是说ListView中有 Observer，adapter中有一群Observable，也就是说有多个Observable，把ListView中的Observer注册到adapter中的Observable，也就是说把ListView的对象注册到adapter中的Observable中；
3>：只要调用了 notifySetDataChanged()，这个时候adapter中所有的 Observable会进行for循环来调用 Observer中的onChanged()方法；
4>：然后在AdapterView中，调用onChanged()方法，然后再调用 requestLayout()方法，重新执行onMeasure()、onLayout()、onDraw()方法；
