android平台中,EventBus研究学习

android平台中,EventBus研究学习

大家好,又见面了,我是全栈君。

         当一个Android应用功能越来越多的时候。app中各个部分之间通信。往往採用Observer的方式来进行,即注冊—-通知—-注销的方式运行 各类控件常常须要依据某个状态来更新显示内容。这样的场景常见的解决方案就是定义一个接口,须要关注该事件的控件来实现这个接口。 接口类:
      public interface OnChangedListener {
            void onDataChanged();
        }
       被观察者往往以例如以下形式实现:

public abstract class AbsHTTPRequest {
    private final WeakHashMap<OnChangedListener, Boolean> mListeners = new WeakHashMap<OnChangedListener, Boolean>();
    public interface OnChangedListener {
        void onDataChanged();
    }
    
    /*HTTP's response*/
    public abstract void onResponse();
    
    public final void addListener(OnChangedListener listener) {
        mListeners.put(listener, true);
    }

    public final void removeListener(OnChangedListener listener) {
        mListeners.remove(listener);
    }
    
    protected final void notifyDataChanged() {
        Set<OnChangedListener> keys = mListeners.keySet();
        if(keys != null) {
            Iterator<OnChangedListener> iterator = keys.iterator();
            while(iterator.hasNext()) {
                iterator.next().onDataChanged();
            }
        }
    }
}

    详细的主题角色( 被观察者)
,实现方式例如以下:

public class LoginRequest extends AbsHTTPRequest implements OnChangedListener{
	public void onResponse(){
		addListener(this);
		notifyDataChanged();
	}

	@Override
	public void onDataChanged() {
		// TODO Auto-generated method stub
		System.out.println("LoginRequest");
	}
}

   
  使用观察者模式有一个弊病就是部件之间的耦合度太高,全部的主题角色都须要实现同一个interface。

观察者模式定义了一种一对多的依赖关系,让多个观察者对象同一时候监听某一个主题对象。

假设主题角色被注冊的observer越多。那么须要实现的interface也就越多,接口方法数量也就越多。
     怎样来进行解耦,让代码逻辑更清晰。可读性更强。是一个问题。

     在Android中也有一个类似功能的开源库EventBus。能够非常方便的帮助我们实现观察者模式,而且让各个组件之间的耦合性更低。

      关于EventBus的解说文章,网络业非常多,这里推荐一篇,解说比較具体的blog,http://www.cnblogs.com/angeldevil/p/3715934.html 
对EventBus的认识,不妨从demo入手。先易后难。

首先知道怎样使用,然后再深究源代码,才干循序渐进,吃透当中的设计理念。便于日后的代码调试和模块重构。关于demo,网上有非常多,能够自己去查收。

      EventBus的使用有4个步奏:
1.定义事件类型:
    public class MyEvent
2.注冊订阅者:
    EventBus.getDefault().register(this)
3.发送事件:
    EventBus.getDefault().post(new MyEvent())
4.接收事件,处理
     订阅者回调的函数。官方指导。函数名称以onEvent开头。

    在EventBus模块中,有几个重要的概念。了解了这几个概念后,也就不难懂了。

          Event:能够是随意类型的对象
          Subscriber:订阅者,接收特定的
          Publisher:公布者。用于通知Subscriber发送

          EventType:onEvent函数中的參数。表示事件对象,用户自己定义的。

          Subscriber:订阅源,即调用register注冊的对象,这个对象内包括onEvent成员函数。
SubscribMethod.javafinal class SubscriberMethod {    final Method method;  /*Method类型的method成员表示这个onEvent,即事件处理函数。

同一时候也包括订阅源*/ final ThreadMode threadMode; final Class<?> eventType; /*事件的对象,用户自己定义Object*/... ... ... ... ... ... ... ... ... ... ... ...}

Subscription.java

final class Subscription {
    final Object subscriber;  /*订阅源Subscriber,即调用register注冊的对象*/
    final SubscriberMethod subscriberMethod; /**/
    final int priority;
... ... ... ... ... ... ... ... ... ... ... ...
}
 
类EventBus中。有两个核心的成员
   /*EventType -> List<Subscription>,事件到订阅对象之间的映射*/
    private final Map<Class<?>, CopyOnWriteArrayList<Subscription>> subscriptionsByEventType;
  /* Subscriber -> List<EventType>,订阅对象到它订阅的的全部事件的映射关系*/
    private final Map<Object, List<Class<?>>> typesBySubscriber;

   
  注冊流程:在调用register函数时,EventBus类有多个重载的register函数,可是作者更倾向于使用register(this);含有 多个參数的register函数中,明白标注了@deprecated,原创作者不建议使用。

从代码:

    public void register(Object subscriber) {
        register(subscriber, DEFAULT_METHOD_NAME, false, 0);
    }

能够观察到,全部重载的register函数。都调用到了

    private synchronized void register(Object subscriber, String methodName, boolean sticky, int priority) {
        List<SubscriberMethod> subscriberMethods = subscriberMethodFinder.findSubscriberMethods(subscriber.getClass(),methodName);
        for (SubscriberMethod subscriberMethod : subscriberMethods) {
            subscribe(subscriber, subscriberMethod, sticky, priority);
        }
    }

      当中注冊函数register。默认參数DEFAULT_METHOD_NAME为函数名称”onEvent”,在java放射机制中,全部的事件处理函数名称 统一为“onEvent”,只參数不一致。onEvent的參数为用户自己定义的对象。

      
注冊时。使用SubscriberMethodFinder的对象,调用到findSubscriberMethods方法。获取到List<SubscriberMethod>。
     数组对象Method[],调用getMethods()方法, 获取的是类的全部共同拥有方法,这就包含自身的全部public方法。和从基类继承的、从接口实现的全部public方法。

这也是为啥,我们的onEvent函数,要定义为public方法的原因哦。

    在findSubscriberMethods函数中,进行如此频繁的遍历。就是为了找到List<SubscriberMethod>。

每个订阅者,相应一个List<SubscriberMethod>。有多少onEvent函数,返回的List,就有多少个item。

即查找订阅源内的事件处理方法,同一时候还会查到它的父类中的事件处理方法。返回list,交给

private void subscribe(Object subscriber, SubscriberMethod subscriberMethod, boolean sticky, int priority)

 进行处理。
     Event与Subscriber之间,是一对多的关系。

即一个事件,能够被多个订阅者关注。

     Subscriber与Event之间,也是一对多的关系。

即一个订阅者,能够订阅多个事件。

     subscribe方法。也就是将上述的那样的关系。进行理顺,合理的建立map的映射关系,主要做了这样几件事件。
     a.依据SubscriberMethod中的EventType类型,将Subscribtion对象存放在subscriptionsByEventType中。建立EventType与Subscription的映射。一个事件能够有多个订阅者。
    b.依据Subscriber将EventType存放在typesBySubscriber`中,建立Subscriber到EventType的映射,每一个Subscriber能够订阅多个事件。
    c.假设是Sticky类型的订阅者,直接向它发送上个保存的事件(假设有的话)。
     通过Subscriber到EventType的映射,我们就能够非常方便地使一个Subscriber取消接收事件,通过EventType到Sucscribtion的映射,能够方便地将对应的事件发送到它的每个订阅者。

    与Observer不同的是。使用EventBus。不同的被观察者,不需统一实现Observer中的interface方法。在上层代码中,也不须要逐一进行notify机制。通过Map进行订阅源与事件函数的相应关系,进行解耦,为其核心之处。
       发送流程:
         EventBus.getDefault().post(new EventType());參数为用户自己定义的对象。最为简单的处理方式,实现事件发送。
     当事件发送出去后,全部的订阅者。是怎样调用其事件方法的呢?这个就须要遍历上文提到的subscriptionsByEventType的Map了。
Post发送事件,入口为post函数:public void post(Object event),在postSingleEvent函数中个,有一个重要的处理函数:

    /** Finds all Class objects including super classes and interfaces. */
    private List<Class<?>> findEventTypes(Class<?

> eventClass) { synchronized (eventTypesCache) { List<Class<?>> eventTypes = eventTypesCache.get(eventClass); if (eventTypes == null) { eventTypes = new ArrayList<Class<?

>>(); Class<?> clazz = eventClass; while (clazz != null) { eventTypes.add(clazz); addInterfaces(eventTypes, clazz.getInterfaces()); clazz = clazz.getSuperclass(); } eventTypesCache.put(eventClass, eventTypes); } return eventTypes; } }

         其作用。就是把这个事件类的对象、实现的接口及父类的类对象存到一个List中返回。依据list中的eventTypes,遍历subscriptionsByEventType,获取订阅源对象。进行逐一的调用事件函数。
        这里须要注意的是,当Post一个事件时,这个事件的父事件(事件类的父类事件)、接口事件也会被Post,所以假设订阅者接收Object类型的事件,即包括onEvent(Object object)事件函数。那么Subscriber就能够接收全部的事件。
          通过本篇博文的了解,EventBus就是通过Map。建立订阅源与事件函数的相应关系,进行解耦,来规避Observer的接口方法的多次、频繁的定义。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/116266.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • HTML实体对照表

    HTML实体对照表

    2021年10月20日
  • qt tcpsocket_qt中udp通信

    qt tcpsocket_qt中udp通信设想有如下场景:若干的客户端与服务器端建立连接,建立连接后,服务器端随机发送字符串给客户端,客户端打印输出。该节案例使用TCP编程。服务器端-单线程头文件#pragmaonce////////////////////////////////////////////////////////////////////////////tcp服务端-单线程处理客户端连接#include&lt…

  • bridge桥接模式_Bridge模式

    bridge桥接模式_Bridge模式bridge模式动机案例要点总结笔记动机由于某些类型的固有的实现逻辑,使得他们具有两个变化维度,乃至多个维度的变换如何应对这种”多维度的变化“?如何利用面向对象技术来是使得类型可以轻松地沿着两个乃至多个方向变换而不引入额外地复杂度?案例PC端和Mobile端平台和业务分离朴素class Messager{ public: virtual void Login(string username,string password) = 0; virtual void SendM

  • Latex之数学公式基本使用格式「建议收藏」

    Latex之数学公式基本使用格式「建议收藏」Latex之数学公式基本使用格式一.数学公式格式背景介绍TEX有两种数学公式,一种是夹杂在行文段落中的公式,一般称为行内(inline)数学公式,或正文(in-tex:t)数学公式;另一种就是像单独占据整行居中展示出来的,称为显示(displayed)数学公式(或行间公式、列表公式),显示数学环境更适合表现更复杂的数学内容。两种公式使用不同的方式进入数学模式。在TEX中,行内数学公式一…

  • Python之contextlib库及源码分析建议收藏

    AbstractContextManager(abc.ABC)上下文管理抽象类,子类必须实现__enter__(self)、__exit__(self)ContextDecorator(objec

    2021年12月19日
  • linux svn服务器搭建和配置_如何搭建web服务器

    linux svn服务器搭建和配置_如何搭建web服务器1.安装SVN服务器:检查是否已安装#rpm-qasubversion安装SVN服务器#yuminstallhttpdhttpd-develsubversionmod_dav_svnmod_auth_mysql验证安装#cd/etc/httpd/modules#ls|grepsvnmod_authz_svn.somod_dav_…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号