摘要:本文由云社区发表事件总线核心逻辑的实现。实现过程的使用分三个步骤注册监听发送事件和取消监听,相应本文也将分这三步来实现。目前提供了优先级和粘性事件的属性来进一步满足开发需求。
本文由云+社区发表
事件总线核心逻辑的实现。
EventBus的作用Android中存在各种通信场景,如Activity
之间的跳转,Activity
与Fragment
以及其他组件之间的交互,以及在某个耗时操作(如请求网络)之后的callback回调等,互相之之间往往需要持有对方的引用,每个场景的写法也有差异,导致耦合性较高且不便维护。以Activity
和Fragment
的通信为例,官方做法是实现一个接口,然后持有对方的引用,再强行转成接口类型,导致耦合度偏高。再以Activity
的返回为例,一方需要设置setResult
,而另一方需要在onActivityResult
做对应处理,如果有多个返回路径,代码就会十分臃肿。而SimpleEventBus
(本文最终实现的简化版事件总线)的写法如下:
public class MainActivity extends AppCompatActivity {
TextView mTextView;
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
mTextView = findViewById(R.id.tv_demo);
mTextView.setText("MainActivity");
mTextView.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View view) {
Intent intent = new Intent(MainActivity.this, SecondActivity.class);
startActivity(intent);
}
});
EventBus.getDefault().register(this);
}
@Subscribe(threadMode = ThreadMode.MAIN)
public void onReturn(Message message) {
mTextView.setText(message.mContent);
}
@Override
protected void onDestroy() {
super.onDestroy();
EventBus.getDefault().unregister(this);
}
}
来源Activity
:
public class SecondActivity extends AppCompatActivity {
TextView mTextView;
@Override
protected void onCreate(@Nullable Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
mTextView = findViewById(R.id.tv_demo);
mTextView.setText("SecondActivity,点击返回");
mTextView.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View view) {
Message message = new Message();
message.mContent = "从SecondActivity返回";
EventBus.getDefault().post(message);
finish();
}
});
}
}
效果如下:
似乎只是换了一种写法,但在场景愈加复杂后,EventBus
能够体现出更好的解耦能力。
主要涉及三方面的知识:
观察者模式(or 发布-订阅模式)
Android消息机制
Java并发编程
本文可以认为是greenrobot/EventBus这个开源库的源码阅读指南,笔者在看设计模式相关书籍的时候了解到这个库,觉得有必要实现一下核心功能以加深理解。
实现过程EventBus
的使用分三个步骤:注册监听、发送事件和取消监听,相应本文也将分这三步来实现。
定义一个注解:
@Retention(RetentionPolicy.RUNTIME) @Target(ElementType.METHOD) public @interface Subscribe { ThreadMode threadMode() default ThreadMode.POST; }
greenrobot/EventBus
还支持优先级和粘性事件,这里只支持最基本的能力:区分线程,因为如更新UI的操作必须放在主线程。ThreadMode
如下:
public enum ThreadMode { MAIN, // 主线程 POST, // 发送消息的线程 ASYNC // 新开一个线程发送 }
在对象初始化的时候,使用register
方法注册,该方法会解析被注册对象的所有方法,并解析声明了注解的方法(即观察者),核心代码如下:
public class EventBus { ... public void register(Object subscriber) { if (subscriber == null) { return; } synchronized (this) { subscribe(subscriber); } } ... private void subscribe(Object subscriber) { if (subscriber == null) { return; } // TODO 巨踏马难看的缩进 Class> clazz = subscriber.getClass(); while (clazz != null && !isSystemClass(clazz.getName())) { final Method[] methods = clazz.getDeclaredMethods(); for (Method method : methods) { Subscribe annotation = method.getAnnotation(Subscribe.class); if (annotation != null) { Class>[] paramClassArray = method.getParameterTypes(); if (paramClassArray != null && paramClassArray.length == 1) { Class> paramType = convertType(paramClassArray[0]); EventType eventType = new EventType(paramType); SubscriberMethod subscriberMethod = new SubscriberMethod(method, annotation.threadMode(), paramType); realSubscribe(subscriber, subscriberMethod, eventType); } } } clazz = clazz.getSuperclass(); } } ... private void realSubscribe(Object subscriber, SubscriberMethod method, EventType eventType) { CopyOnWriteArrayListsubscriptions = mSubscriptionsByEventtype.get(subscriber); if (subscriptions == null) { subscriptions = new CopyOnWriteArrayList<>(); } Subscription subscription = new Subscription(subscriber, method); if (subscriptions.contains(subscription)) { return; } subscriptions.add(subscription); mSubscriptionsByEventtype.put(eventType, subscriptions); } ... }
执行过这些逻辑后,该对象所有的观察者方法都会被存在一个Map中,其Key是EventType
,即观察事件的类型,Value是订阅了该类型事件的所有方法(即观察者)的一个列表,每个方法和对象一起封装成了一个Subscription
类:
public class Subscription { public final Reference
如此,便是注册监听方法的核心逻辑了。
消息发送消息的发送代码很简单:
public class EventBus { ... private EventDispatcher mEventDispatcher = new EventDispatcher(); private ThreadLocal> mThreadLocalEvents = new ThreadLocal >() { @Override protected Queue initialValue() { return new ConcurrentLinkedQueue<>(); } }; ... public void post(Object message) { if (message == null) { return; } mThreadLocalEvents.get().offer(new EventType(message.getClass())); mEventDispatcher.dispatchEvents(message); } ... }
比较复杂一点的是需要根据注解声明的线程模式在对应的线程进行发布:
public class EventBus { ... private class EventDispatcher { private IEventHandler mMainEventHandler = new MainEventHandler(); private IEventHandler mPostEventHandler = new DefaultEventHandler(); private IEventHandler mAsyncEventHandler = new AsyncEventHandler(); void dispatchEvents(Object message) { QueueeventQueue = mThreadLocalEvents.get(); while (eventQueue.size() > 0) { handleEvent(eventQueue.poll(), message); } } private void handleEvent(EventType eventType, Object message) { List subscriptions = mSubscriptionsByEventtype.get(eventType); if (subscriptions == null) { return; } for (Subscription subscription : subscriptions) { IEventHandler eventHandler = getEventHandler(subscription.subscriberMethod.threadMode); eventHandler.handleEvent(subscription, message); } } private IEventHandler getEventHandler(ThreadMode mode) { if (mode == ThreadMode.ASYNC) { return mAsyncEventHandler; } if (mode == ThreadMode.POST) { return mPostEventHandler; } return mMainEventHandler; } }// end of the class ... }
三种线程模式分别如下,DefaultEventHandler
(在发布线程执行观察者放方法):
public class DefaultEventHandler implements IEventHandler { @Override public void handleEvent(Subscription subscription, Object message) { if (subscription == null || subscription.subscriber.get() == null) { return; } try { subscription.subscriberMethod.method.invoke(subscription.subscriber.get(), message); } catch (IllegalAccessException | InvocationTargetException e) { e.printStackTrace(); } } }
MainEventHandler
(在主线程执行):
public class MainEventHandler implements IEventHandler { private Handler mMainHandler = new Handler(Looper.getMainLooper()); DefaultEventHandler hanlder = new DefaultEventHandler(); @Override public void handleEvent(final Subscription subscription, final Object message) { mMainHandler.post(new Runnable() { @Override public void run() { hanlder.handleEvent(subscription, message); } }); } }
AsyncEventHandler
(新开一个线程执行):
public class AsyncEventHandler implements IEventHandler { private DispatcherThread mDispatcherThread; private IEventHandler mEventHandler = new DefaultEventHandler(); public AsyncEventHandler() { mDispatcherThread = new DispatcherThread(AsyncEventHandler.class.getSimpleName()); mDispatcherThread.start(); } @Override public void handleEvent(final Subscription subscription, final Object message) { mDispatcherThread.post(new Runnable() { @Override public void run() { mEventHandler.handleEvent(subscription, message); } }); } private class DispatcherThread extends HandlerThread { // 关联了AsyncExecutor消息队列的Handle Handler mAsyncHandler; DispatcherThread(String name) { super(name); } public void post(Runnable runnable) { if (mAsyncHandler == null) { throw new NullPointerException("mAsyncHandler == null, please call start() first."); } mAsyncHandler.post(runnable); } @Override public synchronized void start() { super.start(); mAsyncHandler = new Handler(this.getLooper()); } } }
以上便是发布消息的代码。
注销监听最后一个对象被销毁还要注销监听,否则容易导致内存泄露,目前SimpleEventBus
用的是WeakReference
,能够通过GC自动回收,但不知道greenrobot/EventBus
为什么没这样实现,待研究。注销监听其实就是遍历Map,拿掉该对象的订阅即可:
public class EventBus { ... public void unregister(Object subscriber) { if (subscriber == null) { return; } Iterator> iterator = mSubscriptionsByEventtype.values().iterator(); while (iterator.hasNext()) { CopyOnWriteArrayList subscriptions = iterator.next(); if (subscriptions != null) { List foundSubscriptions = new LinkedList<>(); for (Subscription subscription : subscriptions) { Object cacheObject = subscription.subscriber.get(); if (cacheObject == null || cacheObject.equals(subscriber)) { foundSubscriptions.add(subscription); } } subscriptions.removeAll(foundSubscriptions); } // 如果针对某个Event的订阅者数量为空了,那么需要从map中清除 if (subscriptions == null || subscriptions.size() == 0) { iterator.remove(); } } } ... }
以上便是事件总线最核心部分的代码实现,完整代码见vimerzhao/SimpleEventBus,后面发现问题更新或者进行升级也只会改动仓库的代码。
局限性由于时间关系,目前只研究了EventBus
的核心部分,还有几个值得深入研究的点,在此记录一下,也欢迎路过的大牛指点一二。
实际使用时,注解和反射会导致性能问题,但EventBus3
已经通过Subscriber Index
基本解决了这一问题,实现也非常有意思,是通过注解处理器(Annotation Processor
)把耗时的逻辑从运行期提前到了编译期,通过编译期生成的索引来给运行期提速,这也是这个名字的由来。
如果订阅者很多会不会影响体验,毕竟原始的方法是点对点的消息传递,不会有这种问题,如果部分订阅者尚未初始化怎么办。等等。目前EventBus3
提供了优先级和粘性事件的属性来进一步满足开发需求。但是否彻底解决问题了还有待验证。
EventBus
是进程内的消息管理机制,并且从开源社区的反馈来看这个项目是非常成功的,但稍微有点体量的APP都做了进程拆分,所以是否有必要支持多进程,能否在保证性能的情况下提供同等的代码解耦能力,也值得继续挖掘。目前有lsxiao/Apollo和Xiaofei-it/HermesEventBus等可供参考。
greenrobot/EventBus
hehonghui/AndroidEventBus
《Android开发艺术探索》第十章
此文已由作者授权腾讯云+社区发布
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/2555.html
摘要:而不是开始,将服务使用多线程的请求重量级的容器。是启动多个轻便单线程的服务器和流量路由到他们。亮点应用程序是事件驱动,异步和单线程的。通过使用事件总线传递消息通信。为了建立一个消息系统,则需要获得该事件总线。 摘要 如果你对Node.js感兴趣,Vert.x可能是你的下一个大事件:一个建立在JVM上一个类似的架构企业制度。 这一部分介绍Vert.x是通过两个动手的例子(基于Vert.x...
摘要:事件只能携带一个的。例如在上述代码示例中的将所有使用发布事件的地方,全部修改为使用的方法。是否能够编写脚本或者自动化工具,自动化的完成重构工作。实施方案使用注解解析自动生成文件我们都知道,是通过注解来实现的。 欢迎大家前往腾讯云社区,获取更多腾讯海量技术实践干货哦~ 作者:吴涛 导语:EventBus 已经火了很长一段时间了。最近我们项目决定引入EventBus,替换我们播放器现在的事...
摘要:我的个人博客地址资源地址非父子组件传值,事件总线的使用方式我的博客地址如果您对我的博客内容有疑惑或质疑的地方,请在下方评论区留言,或邮件给我,共同学习进步。 欢迎访问我的个人博客:http://www.xiaolongwu.cn 前言 先说一下什么是事件总线,其实就是订阅发布者模式; 比如有一个bus对象,这个对象上有两个方法,一个是on(监听,也就是订阅),一个是emit(触发,也就...
摘要:网络框架结合很有创意的一款开源网络框架,让用户自定义接口,并使用其提供的注解,对接口进行解析和调用,是旗下的产品之一动态代理和反射。所做的事情就是帮助用户简化了大量的网络访问代码,用户只需写少量代码就能得到想要的结果。 网络框架 retrofit 结合okhttp Retrofit很有创意的一款开源网络框架,让用户自定义接口,并使用其提供的注解,对接口进行解析和调用,是Square旗下...
阅读 1136·2021-09-13 10:25
阅读 403·2019-08-30 15:53
阅读 2101·2019-08-30 15:44
阅读 1675·2019-08-29 17:20
阅读 1486·2019-08-29 16:36
阅读 1658·2019-08-29 14:10
阅读 1673·2019-08-29 12:44
阅读 1035·2019-08-23 14:13