android适配器中的观察者模式

    xiaoxiao2021-08-16  149

    1. 模式介绍

    模式的定义

    定义对象间一种一对多的依赖关系,使得每当一个对象改变状态,则所有依赖于它的对象都会得到通知并被自动更新。

    模式的使用场景

    关联行为场景。需要注意的是,关联行为是可拆分的,而不是“组合”关系;事件多级触发场景;跨系统的消息交换场景,如消息队列、事件总线的处理机制。

    2. UML类图

    角色介绍

    抽象主题 (Subject) 角色  抽象主题角色把所有观察者对象的引用保存在一个聚集(比如ArrayList对象)里,每个主题都可以有任意数量的观察者。抽象主题提供一个接口,可以增加和删除观察者对象,抽象主题角色又叫做抽象被观察者(Observable)角色。

    具体主题 (ConcreteSubject) 角色  将有关状态存入具体观察者对象;在具体主题的内部状态改变时,给所有登记过的观察者发出通知。具体主题角色又叫做具体被观察者(Concrete Observable)角色。

    抽象观察者 (Observer) 角色  为所有的具体观察者定义一个接口,在得到主题的通知时更新自己,这个接口叫做更新接口。

    具体观察者 (ConcreteObserver) 角色  存储与主题的状态自恰的状态。具体观察者角色实现抽象观察者角色所要求的更新接口,以便使本身的状态与主题的状态 像协调。如果需要,具体观察者角色可以保持一个指向具体主题对象的引用。

    三.  ListView中观察者模式的使用—继承AdapterView,组合ListAdapter private void initView() { mListView = (ListView) findViewById(R.id.list_view); findViewById(R.id.update_tv).setOnClickListener(this); mDataList = new ArrayList<String>(); String title = null; for (int i = 0; i < 20; i++) { title = new String("title_" + i); mDataList.add(title); } mAdapter = new DataAdapter(this, mDataList); mListView.setAdapter(mAdapter); } @Override public void onClick(View v) { if (v.getId() == R.id.update_tv) { int len = mDataList.size(); int index = new Random().nextInt(len); mDataList.set(index, "updata_" + index); mAdapter.notifyDataSetChanged(); } } 那么我们需要知道mAdapter.notifyDataSetChanged();具体的实现 public abstract class BaseAdapter implements ListAdapter, SpinnerAdapter {     private final DataSetObservable mDataSetObservable = new DataSetObservable();     public boolean hasStableIds() {         return false;     }         /**     * 向事件源注册观察者     */     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();     }    。。。 } 点击mDataSetObservable.notifyChanged(); public class DataSetObservable extends Observable<DataSetObserver> {     /**      * Invokes {@link DataSetObserver#onChanged} on each observer.      * Called when the contents of the data set have changed.  The recipient      * will obtain the new contents the next time it queries the data set.      */     public void notifyChanged() {         synchronized(mObservers) {             // 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();             }         }     }     。。。 } 其被观察者(事件源)Observable基类的定义为 /**  * Provides methods for registering or unregistering arbitrary observers in an {@link ArrayList}.  *  * This abstract class is intended to be subclassed and specialized to maintain  * a registry of observers of specific types and dispatch notifications to them.  *  * @param T The observer type.  */ 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);         }     } } 到此我们已经知道mAdapter.notifyDataSetChanged();最终是Observable遍历注册的观察者对象集合,执行DataSetObserver.onChanged()。 那么我们就要查看源码看下该观察者被注册到事件源的 直接查看ListView.setAdapter()方法的源码实现    @Override     public void setAdapter(ListAdapter adapter) {         if (mAdapter != null && mDataSetObserver != null) {             mAdapter.unregisterDataSetObserver(mDataSetObserver);         }         resetList();         mRecycler.clear();         if (mHeaderViewInfos.size() > 0|| mFooterViewInfos.size() > 0) {             mAdapter = new HeaderViewListAdapter(mHeaderViewInfos, mFooterViewInfos, adapter);         } else {             mAdapter = adapter;         }         mOldSelectedPosition = INVALID_POSITION;         mOldSelectedRowId = INVALID_ROW_ID;         // AbsListView#setAdapter will update choice mode states.         super.setAdapter(adapter);         if (mAdapter != null) {             mAreAllItemsSelectable = mAdapter.areAllItemsEnabled();             mOldItemCount = mItemCount;             mItemCount = mAdapter.getCount();             checkFocus();             mDataSetObserver = new AdapterDataSetObserver();             mAdapter.registerDataSetObserver(mDataSetObserver);   } 。。。         requestLayout();     } 可以看到在mAdapter.registerDataSetObserver(mDataSetObserver);中已经将观察者对象注册到事件源对象中了。其中mDataSetObserver对象是声明在父类AbsListView中AdapterDataSetObserver mDataSetObserver;而AdapterDataSetObserver是AdapterView的内部类。 public abstract class AdapterView<T extends Adapter> extends ViewGroup {     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();             requestLayout();

            }

    。。。      } }

       ListView中观察者模式的使用数据变化通知界面更新的流程

    1)ListView继承自AdapterView(其中包含内部类AdapterDataSetObserver)

    2)当ListView调用setAdapter(ListAdapteradapter)时,将生成观察者实例(ListView充当了观察者角色),并注册到mAdapter中(ListAdapter充当了被观察者角色)。

    mDataSetObserver= new AdapterDataSetObserver();           

    mAdapter.registerDataSetObserver(mDataSetObserver);

    3)Adapter中数据变化时,将调用mAdapter.notifyDataSetChanged(),实际调用的是mDataObservable的notifyChanged(),其内部将执行每一个observer的onChanged(),也就达到了更新界面的效果。

    观察者模式最佳实践

    项目实践中典型的观察者模式框架:EventBus、RxJava、KVC/KVO(iOS)

    小结 

    1      .为什么引入设计模式?

          使用设计模式有助于软件适应变化,增强可维护性、可复用性。

         设计模式遵循的六大设计原则:SOLID+LawofDemeter。“高内聚、低耦合”

    2.观察者模式主要作用就是解耦。

      将观察者和被观察者进行隔离,只依赖于Observer和Observable抽象。

    3.Android中的源代码,有助于我们理解观察者模式的编码实现方式,理解Listview界面更新的背后逻辑。

    4.观察者模式最佳实践:EventBus、RxJava、KVC/KVO

    转载请注明原文地址: https://ju.6miu.com/read-676486.html

    最新回复(0)