移动APP

#Android# 学EventBus,你可以参考下我的笔记

知识框架(脑图)

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) ;
}

参考文档

  1. EventBus Documentation:http://greenrobot.org/eventbus/documentation/