Observer 模式解析

  写在前面的话,本不想写设计模式相关博文的,因为这个话题已经被写烂了,之所以我还要写它,唯一的原因就是我经常用到它,想记录下而已,如果你恰巧看到此篇博文,又有幸在你读完之后懂了它,那我真的很高兴哈。   关于观察者模式的定义网上也给了几种说法,但是都殊途同归,所以这里我引用百度百科对它的定义:观察者模式(有时又被称为发布(publish )-订阅(Subscribe)模式、模型-视图(View)模式、源-收听者(Listener)模式或从属者模式)是软件设计模式的一种。在此种模式中,一个目标物件管理所有相依于它的观察者物件,并且在它本身的状态改变时主动发出通知。   上面的解释可能太多于官方,简单来说就是维护一个一对多的依赖关系,一个主题发生了改变,订阅这个主题的的所有订阅者都会接到通知。还没理解? 好吧... 我再举个例子,就拿我们devtf网站订阅功能说吧,我们会拿着你们的邮件地址,在网站安装的邮件订阅插件里注册,待我们发布文章时(主题发生改变),所有邮件地址(订阅者)都会被遍历一遍,逐个通知(notify)有新文章发布了,然后我们就会收到一封邮件。

那么何时该使用Observer模式呢?

  当一个抽象的两个方面,一个依赖于另一个。在单独的对象中封装这些方面,让您独立地改变和重用它们。 - 当一个对象更改为一个对象时,需要更改其他对象,而不知道具体需要更改多少对象。 - 当一个对象应该能够通知其他对象,而不做对这些对象的假设的假设。换句话说,你不希望这些对象紧耦合。

说了这么多没有实例怎么能行,这里先贴上demo的类图

所涉及到的角色

  • AbsUserManager 抽象主题(Subject)角色:抽象主题角色把所有对观察者对象的引用保存在一个聚集(比如WeakHashMap.KeySet对象)里,每个主题都可以有任何数量的观察者。抽象主题提供一个接口,可以增加和删除观察者对象。
  • UserManager 具体主题(ConcreteSubject)角色:将有关状态存入具体观察者对象;在具体主题的内部状态改变时,给所有注册过的观察者发出通知。

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

  • FeedActivity 具体观察者(ConcreteObserver)角色:存储相关(demo为Userbean)状态。具体观察者角色实现抽象观察者角色所要求的更新接口,以便使本身的状态与主题的状态保持一致。

具体实现是这样的

抽象观察者角色

/** * Created by 小雨 on 2015/11/16. */

public interface UserListener {

    void onUserUpdate(UserBean userBean);


    void onUserLogout();


    void onUserLogin(UserBean userBean);

}

具体观察者角色

/** * Created by 小雨 on 2015/11/16. */

public class FeedActivity extends AppCompatActivity implements UserListener, View.OnClickListener {

    private TextView vCurrentUserName;

    private UserBean mUserBean;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_feed);

        vCurrentUserName = (TextView) findViewById(R.id.feed_current_user_name);
        vCurrentUserName.setOnClickListener(this);

        init();
    }

    private void init() {

        mUserBean = UserManager.getDefault().getUserBean();
        if (mUserBean != null) {
            vCurrentUserName.setText(mUserBean.getUserName());
        }
        vCurrentUserName.setText("匿名用户");

        UserManager.getDefault().register(this);
    }

    @Override
    public void onClick(View v) {
        startActivity(new Intent().setClass(this, UserCenterActivity.class));
    }

    @Override
    public void onUserUpdate(UserBean userBean) {

    }

    @Override
    public void onUserLogout() {
        vCurrentUserName.setText("匿名用户");
    }

    @Override
    public void onUserLogin(UserBean userBean) {
        vCurrentUserName.setText(userBean.getUserName());
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        UserManager.getDefault().unregister(this);
    }


}

抽象主题角色

   /** * Created by 小雨 on 2015/11/16. */
  public abstract class AbsUserManager {

        private WeakHashMap<UserListener, Void> mListeners = new WeakHashMap<>();

        public void register(UserListener listener) {
            mListeners.put(listener, null);
        }

        public void unregister(UserListener listener) {
            mListeners.remove(listener);
        }

        protected void notifyUserLogin(UserBean userBean) {
            ArrayList<UserListener> allListeners = new ArrayList<>(
                    mListeners.keySet());
            for (UserListener aListener : allListeners) {
                aListener.onUserLogin(userBean);
            }
        }

        protected void notifyUserLogout() {
            ArrayList<UserListener> allListeners = new ArrayList<>(
                    mListeners.keySet());
            for (UserListener aListener : allListeners) {
                aListener.onUserLogout();
            }
        }

        protected void notifyUserUpdate(UserBean userBean) {
            ArrayList<UserListener> allListeners = new ArrayList<>(
                    mListeners.keySet());
            for (UserListener aListener : allListeners) {
                aListener.onUserUpdate(userBean);
            }
        }

    }

具体主题角色

/** * Created by 小雨 on 2015/11/16. */   
public class UserManager extends AbsUserManager {

        private static UserManager userManager;

        private UserBean mUserBean;

        private UserManager() {
            super();
            loadCachedUserBean();
        }

        public static UserManager getDefault() {
            if (userManager == null) {
                synchronized (UserManager.class) {
                    if (userManager == null) {
                        userManager = new UserManager();
                    }
                }
            }
            return userManager;
        }

        private void loadCachedUserBean() {
            // mUserBean = DevtfCache.getDefault().loadCacheUser();
        }

        public void login(UserBean userBean) {
            mUserBean = userBean;
            cacheCurrentUser(userBean);
            notifyUserLogin(userBean);
        }

        public void logout() {
            mUserBean = null;
            clearCachedUser();
            notifyUserLogout();
        }

        public void updateUserBean(UserBean userBean) {
            mUserBean = userBean;
            cacheCurrentUser(userBean);
            notifyUserUpdate(userBean);
        }

        private void clearCacheUser() {
            // TODO: 清楚UserBean缓存
        }

        private void cacheCurrentUser(UserBean userBean) {
            // TODO: 缓存UserBean
        }

        public UserBean getUserBean() {
            return mUserBean;
        }
    } 

  如果你对上面的例子有所疑惑,请随时与我沟通,我会尽已所能给予解释。观察者模式的使用在开发中算是司空见惯了,Java JDK已经对其做了内置支持;在Android SDK中也能看到它的身影,比如:AbsListView---Adapter,所以熟练掌握它算是很有必要的。

发表评论

电子邮件地址不会被公开。 必填项已用*标注