知识框架(脑图)
EventBus脑图出现背景
- 多线程环境下容易产生回调地狱和异常
- Android中内置的组件间通信方式繁多(handler、intent、broadcast等等)
解决思路
EventBus的设计思路使用事件总线(EventBus)的publisher/subscriber模式进行解耦,解决组件间通信和多线程问题
具体步骤
(1)添加依赖库
compile 'org.greenrobot:eventbus:3.0.0'
(2)定义事件
事件只是一个POJO(plain old java object,Java原始类型),没有特定的要求。
public class MessageEvent {
public final String message;
public MessageEvent(String message) {
this.message = message;
}
}
(3)准备订阅者
使用注解的方式,指定方法运行的线程 ,参数决定接收的事件,方法名任意,建议由on+事件名组成。
ThreadMode
- ThreadMode.POSTING:跟发布事件的线程一致
- ThreadMode.MAIN:在主线程中运行
- ThreadMode.BACKGROUND:在后台线程中运行(非主线程则直接运行,否则新开一个线程运行)
- ThreadMode.ASYNC:在异步线程中运行(不管post线程,我就是要新开一个线程运行)
@Subscribe(threadMode = ThreadMode.MAIN)
public void onMessageEvent(MessageEvent event) {
Toast.makeText(getActivity(), event.message, Toast.LENGTH_SHORT).show();
}
接着,在适当的时候注册事件,并在适当的时候解注册事件
@Override
public void onStart() {
super.onStart();
EventBus.getDefault().register(this);
}
@Override
public void onStop() {
EventBus.getDefault().unregister(this);
super.onStop();
}
(4)发送事件
可以在任何地方发送事件,然后注册了事件的地方就会收到啦~
EventBus.getDefault().post(new MessageEvent("Hello everyone!"));
Q&A
问题1:EventBus这么简洁,有什么缺点吗?
跟RxJava相比,就是缺乏对事件的处理和再分发。它直接new一个事件,然后发布,你无法对事件进行处理。
问题2:已经消费的事件还有可能重发吗?
开启stickyEvent。
发布事件的时候使用postSticky
EventBus.getDefault().postSticky(new MessageEvent("Hello everyone!"));
而处理事件时,配置sticky = true。这样重启Activity的时候,先前的事件会重分发,省去了使用SharePreferences/Bundle保存状态的步骤~
@Override
public void onStart() {
super.onStart();
EventBus.getDefault().register(this);
}
@Subscribe(sticky = true, threadMode = ThreadMode.MAIN)
public void onEvent(MessageEvent event) {
// UI updates must run on MainThread
textField.setText(event.message);
}
@Override
public void onStop() {
EventBus.getDefault().unregister(this);
super.onStop();
}
当然,当再也不需要这个sticky Event时需要手动移除。
//移除sticky属性,然后将事件返回
MessageEvent stickyEvent = EventBus.getDefault().removeStickyEvent(MessageEvent.class);
// Better check that an event was actually posted before
if(stickyEvent != null) {
// Now do something with it
}
问题3:可以设置订阅者的优先级吗?
可以的,使用注解参数priority轻松搞定
@Subscribe(priority = 1); //默认的是0
public void onEvent(MessageEvent event) {
…
}
问题4:可以停止事件继续往下分发吗?
可以的,使用cancelEventDelivery方法。高优先级的订阅者的特权啊!
// Called in the same thread (default)
@Subscribe
public void onEvent(MessageEvent event){
// Process the event
…
EventBus.getDefault().cancelEventDelivery(event) ;
}
参考文档
- EventBus Documentation:http://greenrobot.org/eventbus/documentation/
网友评论